Fix unclosed aiohttp sessions (#63)

dipdup-io · Jun 21, 2021 · 05f368f · 05f368f
1 parent 1be3c3a
commit 05f368f
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/dipdup/dipdup.py b/src/dipdup/dipdup.py
@@ -190,9 +190,9 @@ async def run(self, reindex: bool, oneshot: bool) -> None:
                 await asyncio.gather(*datasource_tasks, *worker_tasks)
             except KeyboardInterrupt:
                 pass
-
-            self._logger.info('Closing datasource sessions')
-            await asyncio.gather(*[d.close_session() for d in self._datasources.values()])
+            finally:
+                self._logger.info('Closing datasource sessions')
+                await asyncio.gather(*[d.close_session() for d in self._datasources.values()])
 
     async def migrate(self) -> None:
         codegen = DipDupCodeGenerator(self._config, self._datasources_by_config)