Loading etl/stg/stg_build_db_structure.py +10 −1 Original line number Diff line number Diff line import logging import os import time from sqlalchemy import (Column, ForeignKey, Integer, Loading @@ -12,6 +14,7 @@ from assets.commons import (get_pg_engine, setup_logger) from sqlalchemy.orm import declarative_base from sqlalchemy.orm import relationship from sqlalchemy.exc import OperationalError logger = setup_logger(name='DB_SETUP') Base = declarative_base() Loading Loading @@ -188,4 +191,10 @@ class RatioMaps(Base): mom_zero_map_2 = relationship("MomentZeroMaps", foreign_keys=[mom_zero_name_2, run_id]) Base.metadata.create_all(engine) try: Base.metadata.create_all(bind=engine) except OperationalError: logger.error('Connection failed. Sleeping and retrying') time.sleep(3) Base.metadata.create_all(bind=engine) logger.info('Connection successful! DB initialized as needed.') Loading
etl/stg/stg_build_db_structure.py +10 −1 Original line number Diff line number Diff line import logging import os import time from sqlalchemy import (Column, ForeignKey, Integer, Loading @@ -12,6 +14,7 @@ from assets.commons import (get_pg_engine, setup_logger) from sqlalchemy.orm import declarative_base from sqlalchemy.orm import relationship from sqlalchemy.exc import OperationalError logger = setup_logger(name='DB_SETUP') Base = declarative_base() Loading Loading @@ -188,4 +191,10 @@ class RatioMaps(Base): mom_zero_map_2 = relationship("MomentZeroMaps", foreign_keys=[mom_zero_name_2, run_id]) Base.metadata.create_all(engine) try: Base.metadata.create_all(bind=engine) except OperationalError: logger.error('Connection failed. Sleeping and retrying') time.sleep(3) Base.metadata.create_all(bind=engine) logger.info('Connection successful! DB initialized as needed.')