Self._wrap_pool_connect(, None),įile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/engine/base.py", line 2279, in _wrap_pool_connectįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/engine/base.py", line 1544, in _handle_dbapi_exception_noconnection With self._optional_conn_ctx_manager(connection) as conn:įile "/usr/lib64/python3.6/contextlib.py", line 81, in _enter_įile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/engine/base.py", line 2037, in _optional_conn_ctx_managerįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/engine/base.py", line 2239, in _contextual_connect _all(engine)įile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/sql/schema.py", line 4294, in create_allĭdl.SchemaGenerator, self, checkfirst=checkfirst, tables=tablesįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/engine/base.py", line 2045, in _run_visitor Return self._maybe_set_cache(_task_meta(self.id))įile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/celery/backends/base.py", line 386, in get_task_metaįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/celery/backends/database/_init_.py", line 53, in _innerįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/celery/backends/database/_init_.py", line 122, in _get_task_meta_forįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/celery/backends/database/_init_.py", line 99, in ResultSessionįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/celery/backends/database/session.py", line 59, in session_factoryįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/celery/backends/database/session.py", line 54, in prepare_models Res = (celery_task, celery_task.state)įile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/celery/result.py", line 473, in stateįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/celery/result.py", line 412, in _get_task_meta The above exception was the direct cause of the following exception:įile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/airflow/executors/celery_executor.py", line 106, in fetch_celery_task_state Is the server running locally and acceptingĬonnections on Unix domain socket "/var/run/postgresql/.s.PGSQL.5432"? Psycopg2.OperationalError: could not connect to server: No such file or directory Return (*cargs, **cparams)įile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/psycopg2/_init_.py", line 126, in connectĬonn = _connect(dsn, connection_factory=connection_factory, **kwasync) Return nnect(*cargs, **cparams)įile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/engine/default.py", line 453, in connect
#AIRFLOW SCHEDULER CONNECTION IN USE CODE#
To isolate issue, Testing the connections to postgres manually works without issuesĮxample connection code (sqlalchemy postgres functioning) from sqlalchemy import create_engineĮngine = echo=True, pool_size=6, max_overflow=10, encoding='latin1')Įrror Celery Task ID: ('example_dag', 'bash_task', datetime.datetime(2018, 10, 8, 0, 0, tzinfo=), 1)įile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/engine/base.py", line 2275, in _wrap_pool_connectįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/pool/base.py", line 363, in connectįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/pool/base.py", line 760, in _checkoutįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/pool/base.py", line 492, in checkoutįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/pool/impl.py", line 139, in _do_getįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/util/langhelpers.py", line 68, in _exit_Ĭompat.reraise(exc_type, exc_value, exc_tb)įile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/util/compat.py", line 153, in reraiseįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/pool/impl.py", line 136, in _do_getįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connectionįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/pool/base.py", line 437, in _init_įile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/pool/base.py", line 639, in _connectįile "/kaiser2/airflow_venv/lib64/python3.6/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect Is there any version incompatibilities, appreciate any help to resolve. Airflow scheduler crashing with postgres sqlalchemy connection error (details of error below) This error exists in one environment, other similar environment works.
0 kommentar(er)
