adding await to job manager process self.generate_remote_file

biothings · May 22, 2023 · 9d3e0ca · 9d3e0ca
1 parent b009e92
commit 9d3e0ca
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/biothings/hub/dataload/dumper.py b/biothings/hub/dataload/dumper.py
@@ -2163,7 +2163,7 @@ async def create_todump_list(self, force=False, job_manager=None, **kwargs):
         if job_manager:
             pinfo = self.get_pinfo()
             pinfo["step"] = "check"
-            job = job_manager.defer_to_process(pinfo, partial(self.generate_remote_file))
+            job = await job_manager.defer_to_process(pinfo, partial(self.generate_remote_file))
         else:
             # otherwise, just run it with asyncio loop directly
             async def run(fut):