diff --git a/src/dipdup/dipdup.py b/src/dipdup/dipdup.py
index 3454060cd..8a5316573 100644
--- 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)