File tree Expand file tree Collapse file tree 1 file changed +7
-2
lines changed
services/director-v2/tests/unit/with_dbs/comp_scheduler Expand file tree Collapse file tree 1 file changed +7
-2
lines changed Original file line number Diff line number Diff line change @@ -347,9 +347,14 @@ async def test_schedule_all_pipelines_logs_error_if_it_find_old_pipelines(
347347 )
348348 with caplog .at_level (logging .ERROR ):
349349 await schedule_all_pipelines (initialized_app )
350+ lost_pipeline_messages = [
351+ msg
352+ for msg in caplog .messages
353+ if "lost pipelines" in msg and "re-scheduled" in msg
354+ ]
350355 assert (
351- "found 1 lost pipelines, they will be re-scheduled now" in caplog . messages
352- )
356+ len ( lost_pipeline_messages ) > 0
357+ ), f"Expected lost pipeline message, got: { caplog . messages } "
353358 _assert_scheduler_client_called_once_with (
354359 scheduler_rabbit_client_parser ,
355360 SchedulePipelineRabbitMessage (
You can’t perform that action at this time.
0 commit comments