@@ -361,37 +361,35 @@ async def test_run(monkeypatch, clear_queue, clear_database):
361361 # Assert the tasks were queued
362362 queue_items_set = set (get_queue_items ())
363363
364- assert queue_items_set == set (
365- [
366- json .dumps (
367- {
368- "type" : "process_monitor" ,
369- "payload" : {
370- "monitor_id" : monitors_instances [0 ].id ,
371- "tasks" : ["search" , "update" ],
372- },
373- }
374- ),
375- json .dumps (
376- {
377- "type" : "process_monitor" ,
378- "payload" : {
379- "monitor_id" : monitors_instances [1 ].id ,
380- "tasks" : ["search" , "update" ],
381- },
382- }
383- ),
384- json .dumps (
385- {
386- "type" : "process_monitor" ,
387- "payload" : {
388- "monitor_id" : monitors_instances [2 ].id ,
389- "tasks" : ["search" , "update" ],
390- },
391- }
392- ),
393- ]
394- )
364+ assert queue_items_set == {
365+ json .dumps (
366+ {
367+ "type" : "process_monitor" ,
368+ "payload" : {
369+ "monitor_id" : monitors_instances [0 ].id ,
370+ "tasks" : ["search" , "update" ],
371+ },
372+ }
373+ ),
374+ json .dumps (
375+ {
376+ "type" : "process_monitor" ,
377+ "payload" : {
378+ "monitor_id" : monitors_instances [1 ].id ,
379+ "tasks" : ["search" , "update" ],
380+ },
381+ }
382+ ),
383+ json .dumps (
384+ {
385+ "type" : "process_monitor" ,
386+ "payload" : {
387+ "monitor_id" : monitors_instances [2 ].id ,
388+ "tasks" : ["search" , "update" ],
389+ },
390+ }
391+ ),
392+ }
395393
396394
397395async def test_run_no_sleep (mocker , monkeypatch ):
0 commit comments