ALBS-1026: add statistics for each build_task step #1
@ -64,12 +64,13 @@ def start(yml_path: str):
|
|||||||
logging.error('unsupported DB schema: want %s, have %s',
|
logging.error('unsupported DB schema: want %s, have %s',
|
||||||
DB_SCHEMA_VER, cur_version)
|
DB_SCHEMA_VER, cur_version)
|
||||||
sys.exit(1)
|
sys.exit(1)
|
||||||
|
db.close_conn()
|
||||||
|
|
||||||
while True:
|
while True:
|
||||||
logging.info('Starting extraction proccess')
|
logging.info('Starting extraction proccess')
|
||||||
api = APIclient(api_root=config.albs_url,
|
api = APIclient(api_root=config.albs_url,
|
||||||
jwt=config.jwt, timeout=config.api_timeout)
|
jwt=config.jwt, timeout=config.api_timeout)
|
||||||
|
db = DB(config.db_config)
|
||||||
extractor = Extractor(config, api, db)
|
extractor = Extractor(config, api, db)
|
||||||
|
|
||||||
logging.info('Starting builds insertion')
|
logging.info('Starting builds insertion')
|
||||||
|
Loading…
Reference in New Issue
Block a user