Имеется модуль с session_scope. Могу ли я смело его подключать к своим отдельным скриптам, содержимое которых будет выполняться параллельно в отдельных airflow dag?
engine_mydb = create_engine(mydb_setting)
@contextmanager
def session_scope():
try:
session = Session(bind=engine_mydb)
yield session
session.commit()
except Exception as e:
send_error(e)
session.rollback()
finally:
session.close()
