fix format of running jobs added from resumen hook

shub_workflow/crawl.py

@@ -174,8 +174,11 @@ def workflow_loop(self) -> bool:
 
     def resume_running_job_hook(self, job: JobDict):
         key = job["key"]
-        job_args_override = cast(JobParams, job.get("spider_args", {}).copy())
-        job_args_override["tags"] = job["tags"]
+        spider_args = job.get("spider_args", {}).copy()
+        job_args_override = JobParams({
+            "tags": job["tags"],
+            "spider_args": spider_args,
+        })
         self._running_job_keys[key] = job["spider"], job_args_override
         _LOG.info(f"added running job {key}")
 

tests/test_crawl_manager.py

@@ -147,6 +147,10 @@ def test_schedule_spider_with_resume(self, mocked_super_schedule_spider, mocked_
         manager._on_start()
         self.assertTrue(manager.is_resumed)
         self.assertEqual(len(manager._running_job_keys), 1)
+
+        for v in manager._running_job_keys.values():
+            self.assertEqual(set(v[1].keys()), {"spider_args", "tags"})
+
         self.assertEqual(mocked_get_jobs.call_count, len(mocked_get_jobs_side_effect))
         mocked_add_job_tags.assert_any_call(tags=["FLOW_ID=3a20", "NAME=test", "OTHER=other"])
 
@@ -499,6 +503,9 @@ def set_parameters_gen(self):
         self.assertTrue(manager.is_resumed)
         self.assertEqual(len(manager._running_job_keys), 1)
 
+        for v in manager._running_job_keys.values():
+            self.assertEqual(set(v[1].keys()), {"spider_args", "tags"})
+
         # first loop: acquire running job.
         manager.is_finished = lambda x: None
         result = next(manager._run_loops())