fix: postgresql AsyncConnection add await close

shengchenyang · Dec 21, 2023 · f7b6511 · f7b6511
1 parent 35255e2
commit f7b6511
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/ayugespidertools/scraper/pipelines/postgres/asynced.py b/ayugespidertools/scraper/pipelines/postgres/asynced.py
@@ -55,5 +55,8 @@ async def process_item(self, item, spider):
         task.add_done_callback(lambda t: self.running_tasks.discard(t))
         return item
 
+    async def _close_spider(self):
+        await self.conn.close()
+
     def close_spider(self, spider):
-        self.conn.close()
+        return deferred_from_coro(self._close_spider())