diff --git a/build_analytics/build_analytics/extractor/start.py b/build_analytics/build_analytics/extractor/start.py
index 90f59c1..d7f86e3 100644
--- a/build_analytics/build_analytics/extractor/start.py
+++ b/build_analytics/build_analytics/extractor/start.py
@@ -64,12 +64,13 @@ def start(yml_path: str):
         logging.error('unsupported DB schema: want %s, have %s',
                       DB_SCHEMA_VER, cur_version)
         sys.exit(1)
+    db.close_conn()
 
     while True:
         logging.info('Starting extraction proccess')
         api = APIclient(api_root=config.albs_url,
                         jwt=config.jwt, timeout=config.api_timeout)
-
+        db = DB(config.db_config)
         extractor = Extractor(config, api, db)
 
         logging.info('Starting builds insertion')