catchup with backlog

ric-evans · ric-evans · commit 8e19316898bf · 2025-01-17T14:55:01.000-06:00
diff --git a/skydriver/k8s/scan_backlog.py b/skydriver/k8s/scan_backlog.py
@@ -144,7 +144,7 @@ async def _run(
             )
         except database.mongodc.DocumentNotFoundException:
             timer_main_loop.fastforward()
-            continue  # empty queue-
+            continue  # there's no scan to start
 
         # request a workflow on EWMS
         try:
diff --git a/tests/integration/test_rest_routes.py b/tests/integration/test_rest_routes.py
@@ -804,7 +804,7 @@ async def _after_scan_start_logic(
     assert resp["result"] == {}
 
     # wait backlogger to request to ewms
-    await asyncio.sleep(int(os.environ["SCAN_BACKLOG_RUNNER_SHORT_DELAY"]) * 2)  # extra
+    await asyncio.sleep(int(os.environ["SCAN_BACKLOG_RUNNER_DELAY"]) * 5)  # extra
     ewms_workflow_id = (await rc.request("GET", f"/scan/{scan_id}/manifest"))[
         "ewms_workflow_id"
     ]

Original file line number	Diff line number	Diff line change
`@@ -144,7 +144,7 @@ async def _run(`
`144`	`144`	`)`
`145`	`145`	`except database.mongodc.DocumentNotFoundException:`
`146`	`146`	`timer_main_loop.fastforward()`
`147`		`- continue # empty queue-`
	`147`	`+ continue # there's no scan to start`
`148`	`148`
`149`	`149`	`# request a workflow on EWMS`
`150`	`150`	`try:`
Original file line number	Diff line number	Diff line change
`@@ -804,7 +804,7 @@ async def _after_scan_start_logic(`
`804`	`804`	`assert resp["result"] == {}`
`805`	`805`
`806`	`806`	`# wait backlogger to request to ewms`
`807`		`- await asyncio.sleep(int(os.environ["SCAN_BACKLOG_RUNNER_SHORT_DELAY"]) * 2) # extra`
	`807`	`+ await asyncio.sleep(int(os.environ["SCAN_BACKLOG_RUNNER_DELAY"]) * 5) # extra`
`808`	`808`	`ewms_workflow_id = (await rc.request("GET", f"/scan/{scan_id}/manifest"))[`
`809`	`809`	`"ewms_workflow_id"`
`810`	`810`	`]`