You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Vlasov Denis (JIRA)" <ji...@apache.org> on 2019/01/10 13:16:00 UTC
[jira] [Closed] (AIRFLOW-3667) Airflow scheduler not started as
daemon
[ https://issues.apache.org/jira/browse/AIRFLOW-3667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Vlasov Denis closed AIRFLOW-3667.
---------------------------------
Resolution: Fixed
> Airflow scheduler not started as daemon
> ---------------------------------------
>
> Key: AIRFLOW-3667
> URL: https://issues.apache.org/jira/browse/AIRFLOW-3667
> Project: Apache Airflow
> Issue Type: Bug
> Components: scheduler
> Affects Versions: 1.8.2
> Reporter: Vlasov Denis
> Priority: Major
>
> When use bash command "airflow scheduler" it works. When use "airflow scheduler -D" in $AIRFLOW_HOME\airflow-scheduler.err i have error message:
> "Traceback (most recent call last):
> File "/usr/bin/airflow", line 28, in <module>
> args.func(args)
> File "/usr/lib/python2.7/site-packages/airflow/bin/cli.py", line 874, in scheduler
> job.run()
> File "/usr/lib/python2.7/site-packages/airflow/jobs.py", line 195, in run
> session.commit()
> File "/usr/lib/python2.7/site-packages/sqlalchemy/orm/session.py", line 943, in commit
> self.transaction.commit()
> File "/usr/lib/python2.7/site-packages/sqlalchemy/orm/session.py", line 467, in commit
> self._prepare_impl()
> File "/usr/lib/python2.7/site-packages/sqlalchemy/orm/session.py", line 447, in _prepare_impl
> self.session.flush()
> File "/usr/lib/python2.7/site-packages/sqlalchemy/orm/session.py", line 2254, in flush
> self._flush(objects)
> File "/usr/lib/python2.7/site-packages/sqlalchemy/orm/session.py", line 2380, in _flush
> transaction.rollback(_capture_exception=True)
> File "/usr/lib/python2.7/site-packages/sqlalchemy/util/langhelpers.py", line 66, in exit
> compat.reraise(exc_type, exc_value, exc_tb)
> File "/usr/lib/python2.7/site-packages/sqlalchemy/orm/session.py", line 2344, in _flush
> flush_context.execute()
> File "/usr/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.py", line 391, in execute
> rec.execute(self)
> File "/usr/lib/python2.7/site-packages/sqlalchemy/orm/unitofwork.py", line 556, in execute
> uow
> File "/usr/lib/python2.7/site-packages/sqlalchemy/orm/persistence.py", line 181, in save_obj
> mapper, table, insert)
> File "/usr/lib/python2.7/site-packages/sqlalchemy/orm/persistence.py", line 866, in _emit_insert_statements
> execute(statement, params)
> File "/usr/lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 948, in execute
> return meth(self, multiparams, params)
> File "/usr/lib/python2.7/site-packages/sqlalchemy/sql/elements.py", line 269, in _execute_on_connection
> return connection._execute_clauseelement(self, multiparams, params)
> File "/usr/lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 1060, in _execute_clauseelement
> compiled_sql, distilled_params
> File "/usr/lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 1200, in _execute_context
> context)
> File "/usr/lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 1413, in _handle_dbapi_exception
> exc_info
> File "/usr/lib/python2.7/site-packages/sqlalchemy/util/compat.py", line 265, in raise_from_cause
> reraise(type(exception), exception, tb=exc_tb, cause=cause)
> File "/usr/lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 1193, in _execute_context
> context)
> File "/usr/lib/python2.7/site-packages/sqlalchemy/engine/default.py", line 509, in do_execute
> cursor.execute(statement, parameters)
> sqlalchemy.exc.OperationalError: (psycopg2.OperationalError) could not receive data from server: Bad file descriptor
> [SQL: 'INSERT INTO job (dag_id, state, job_type, start_date, end_date, latest_heartbeat, executor_class, hostname, unixname) VALUES (%(dag_id)s, %(state)s, %(job_type)s, %(start_date)s, %(end_date)s, %(latest_heartbeat)s, %(executor_class)s, %(hostname)s, %(unixname)s) RETURNING job.id'] [parameters: \{'unixname': 'airflow', 'end_date': None, 'job_type': u'SchedulerJob', 'hostname': 'airflow.ic.local', 'latest_heartbeat': datetime.datetime(2019, 1, 10, 14, 26, 3, 472595), 'state': u'running', 'executor_class': 'CeleryExecutor', 'start_date': datetime.datetime(2019, 1, 10, 14, 26, 3, 472578), 'dag_id': None}] (Background on this error at: http://sqlalche.me/e/e3q8)"
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)