"""Unit tests for Spotify Workflow.""" from unittest import mock from unittest.mock import MagicMock from data_landing_zone.flows.spotify.flow import Flow def test_decider_reports_unavailable(): """Test decider execution when reports are unavailable.""" check_status = MagicMock() check_status.result = { 'check_available_reports.stop': True} schedule = MagicMock(return_value=check_status) flow = Flow() flow.decider(schedule) schedule.assert_has_calls([ mock.call('bootstrap', mock.ANY), mock.call('grab_drop_files', mock.ANY, requires=mock.ANY)])