()
| 21 | |
| 22 | |
| 23 | def get_engine_conn(): |
| 24 | conf = get_engine_config() |
| 25 | db_url = get_engine_uri(conf) |
| 26 | engine = create_engine(db_url, |
| 27 | connect_args={"options": f"-c search_path={conf.dbSchema}", "connect_timeout": conf.timeout}, |
| 28 | pool_timeout=conf.timeout) |
| 29 | return engine |
| 30 | |
| 31 | |
| 32 | def get_data_engine(): |
no test coverage detected