Use sync_to_async to mitigate DB connection issues

closes #9385 Required PR: pulp/pulpcore#1625
pulp · Sep 17, 2021 · f75dea2 · f75dea2
1 parent 20096ce
commit f75dea2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/CHANGES/9385.misc b/CHANGES/9385.misc
@@ -0,0 +1,2 @@
+Use sync_to_async to mitigate DB connection issues and comply with Django 3.2 ORM usage in async
+code.
diff --git a/pulp_container/app/tasks/sync_stages.py b/pulp_container/app/tasks/sync_stages.py
@@ -145,7 +145,8 @@ async def run(self):
 
         for manifest_future in future_manifests:
             man = await manifest_future.resolution()
-            with man._artifacts.get().file.open() as content_file:
+            artifact = await sync_to_async(man._artifacts.get)()
+            with artifact.file.open() as content_file:
                 raw = content_file.read()
             content_data = json.loads(raw)
             man_dc = man_dcs[man.digest]