File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed
unit_tests/sources/declarative/async_job Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -144,10 +144,14 @@ def test_given_timeout_when_create_and_get_completed_partitions_then_free_budget
144144 )
145145 orchestrator = self ._orchestrator ([_A_STREAM_SLICE ], job_tracker )
146146
147- with pytest .raises (AirbyteTracedException ) as error :
147+ with pytest .raises (AirbyteTracedException ):
148148 list (orchestrator .create_and_get_completed_partitions ())
149149
150- assert "Job an api job id has timed out" in str (error .value )
150+ assert job_tracker .try_to_get_intent ()
151+ assert (
152+ self ._job_repository .start .call_args_list
153+ == [call (_A_STREAM_SLICE )] * _MAX_NUMBER_OF_ATTEMPTS
154+ )
151155
152156 @mock .patch (sleep_mock_target )
153157 def test_given_failure_when_create_and_get_completed_partitions_then_raise_exception (
You can’t perform that action at this time.
0 commit comments