Untitled

scheduler_1_d48fab2aae5e | Mon Apr 22 13:14:58 UTC 2019 - waiting for Postgres... 1/20
scheduler_1_d48fab2aae5e | [2019-04-22 13:15:17,131] {{settings.py:174}} INFO - settings.configure_orm(): Using pool settings. pool_size=5, pool_recycle=1800, pid=1
scheduler_1_d48fab2aae5e | [2019-04-22 13:15:23,823] {{__init__.py:51}} INFO - Using executor CeleryExecutor
scheduler_1_d48fab2aae5e | [2019-04-22 13:15:31,661] {{cli_action_loggers.py:69}} ERROR - Failed on pre-execution callback using <function default_action_log at 0x7fe92f956730>
scheduler_1_d48fab2aae5e | Traceback (most recent call last):
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line 1236, in _execute_context
scheduler_1_d48fab2aae5e |     cursor, statement, parameters, context
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/default.py", line 536, in do_execute
scheduler_1_d48fab2aae5e |     cursor.execute(statement, parameters)
scheduler_1_d48fab2aae5e | psycopg2.errors.UndefinedTable: relation "log" does not exist
scheduler_1_d48fab2aae5e | LINE 1: INSERT INTO log (dttm, dag_id, task_id, event, execution_dat...
scheduler_1_d48fab2aae5e |                     ^
scheduler_1_d48fab2aae5e |
scheduler_1_d48fab2aae5e |
scheduler_1_d48fab2aae5e | The above exception was the direct cause of the following exception:
scheduler_1_d48fab2aae5e |
scheduler_1_d48fab2aae5e | Traceback (most recent call last):
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/airflow/utils/cli_action_loggers.py", line 67, in on_pre_execution
scheduler_1_d48fab2aae5e |     cb(**kwargs)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/airflow/utils/cli_action_loggers.py", line 98, in default_action_log
scheduler_1_d48fab2aae5e |     session.add(log)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/contextlib.py", line 88, in __exit__
scheduler_1_d48fab2aae5e |     next(self.gen)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/airflow/utils/db.py", line 44, in create_session
scheduler_1_d48fab2aae5e |     session.commit()
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/session.py", line 1023, in commit
scheduler_1_d48fab2aae5e |     self.transaction.commit()
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/session.py", line 487, in commit
scheduler_1_d48fab2aae5e |     self._prepare_impl()
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/session.py", line 466, in _prepare_impl
scheduler_1_d48fab2aae5e |     self.session.flush()
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/session.py", line 2446, in flush
scheduler_1_d48fab2aae5e |     self._flush(objects)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/session.py", line 2584, in _flush
scheduler_1_d48fab2aae5e |     transaction.rollback(_capture_exception=True)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/util/langhelpers.py", line 67, in __exit__
scheduler_1_d48fab2aae5e |     compat.reraise(exc_type, exc_value, exc_tb)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/util/compat.py", line 277, in reraise
scheduler_1_d48fab2aae5e |     raise value
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/session.py", line 2544, in _flush
scheduler_1_d48fab2aae5e |     flush_context.execute()
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/unitofwork.py", line 416, in execute
scheduler_1_d48fab2aae5e |     rec.execute(self)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/unitofwork.py", line 583, in execute
scheduler_1_d48fab2aae5e |     uow,
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/persistence.py", line 245, in save_obj
scheduler_1_d48fab2aae5e |     insert,
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/persistence.py", line 1116, in _emit_insert_statements
scheduler_1_d48fab2aae5e |     statement, params
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line 980, in execute
scheduler_1_d48fab2aae5e |     return meth(self, multiparams, params)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/sql/elements.py", line 273, in _execute_on_connection
scheduler_1_d48fab2aae5e |     return connection._execute_clauseelement(self, multiparams, params)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line 1099, in _execute_clauseelement
scheduler_1_d48fab2aae5e |     distilled_params,
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line 1240, in _execute_context
scheduler_1_d48fab2aae5e |     e, statement, parameters, cursor, context
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line 1458, in _handle_dbapi_exception
scheduler_1_d48fab2aae5e |     util.raise_from_cause(sqlalchemy_exception, exc_info)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/util/compat.py", line 296, in raise_from_cause
scheduler_1_d48fab2aae5e |     reraise(type(exception), exception, tb=exc_tb, cause=cause)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/util/compat.py", line 276, in reraise
scheduler_1_d48fab2aae5e |     raise value.with_traceback(tb)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line 1236, in _execute_context
scheduler_1_d48fab2aae5e |     cursor, statement, parameters, context
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/default.py", line 536, in do_execute
scheduler_1_d48fab2aae5e |     cursor.execute(statement, parameters)
scheduler_1_d48fab2aae5e | sqlalchemy.exc.ProgrammingError: (psycopg2.errors.UndefinedTable) relation "log" does not exist
scheduler_1_d48fab2aae5e | LINE 1: INSERT INTO log (dttm, dag_id, task_id, event, execution_dat...
scheduler_1_d48fab2aae5e |                     ^
scheduler_1_d48fab2aae5e |  [SQL: 'INSERT INTO log (dttm, dag_id, task_id, event, execution_date, owner, extra) VALUES (%(dttm)s, %(dag_id)s, %(task_id)s, %(event)s, %(execution_date)s, %(owner)s, %(extra)s) RETURNING log.id'] [parameters: {'dttm': datetime.datetime(2019, 4, 22, 13, 15, 31, 580400, tzinfo=<Timezone [UTC]>), 'dag_id': None, 'task_id': None, 'event': 'cli_scheduler', 'execution_date': None, 'owner': 'airflow', 'extra': '{"host_name": "668add730bf7", "full_command": "[\'/usr/local/bin/airflow\', \'scheduler\']"}'}] (Background on this error at: http://sqlalche.me/e/f405)
scheduler_1_d48fab2aae5e |   ____________       _____________
scheduler_1_d48fab2aae5e |  ____    |__( )_________  __/__  /________      __
scheduler_1_d48fab2aae5e | ____  /| |_  /__  ___/_  /_ __  /_  __ \_ | /| / /
scheduler_1_d48fab2aae5e | ___  ___ |  / _  /   _  __/ _  / / /_/ /_ |/ |/ /
scheduler_1_d48fab2aae5e |  _/_/  |_/_/  /_/    /_/    /_/  \____/____/|__/
scheduler_1_d48fab2aae5e |
scheduler_1_d48fab2aae5e | Traceback (most recent call last):
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line 1236, in _execute_context
scheduler_1_d48fab2aae5e |     cursor, statement, parameters, context
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/default.py", line 536, in do_execute
scheduler_1_d48fab2aae5e |     cursor.execute(statement, parameters)
scheduler_1_d48fab2aae5e | psycopg2.errors.UndefinedTable: relation "job" does not exist
scheduler_1_d48fab2aae5e | LINE 1: INSERT INTO job (dag_id, state, job_type, start_date, end_da...
scheduler_1_d48fab2aae5e |                     ^
scheduler_1_d48fab2aae5e |
scheduler_1_d48fab2aae5e |
scheduler_1_d48fab2aae5e | The above exception was the direct cause of the following exception:
scheduler_1_d48fab2aae5e |
scheduler_1_d48fab2aae5e | Traceback (most recent call last):
scheduler_1_d48fab2aae5e |   File "/usr/local/bin/airflow", line 32, in <module>
scheduler_1_d48fab2aae5e |     args.func(args)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/airflow/utils/cli.py", line 74, in wrapper
scheduler_1_d48fab2aae5e |     return f(*args, **kwargs)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/airflow/bin/cli.py", line 991, in scheduler
scheduler_1_d48fab2aae5e |     job.run()
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/airflow/jobs.py", line 196, in run
scheduler_1_d48fab2aae5e |     session.commit()
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/session.py", line 1023, in commit
scheduler_1_d48fab2aae5e |     self.transaction.commit()
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/session.py", line 487, in commit
scheduler_1_d48fab2aae5e |     self._prepare_impl()
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/session.py", line 466, in _prepare_impl
scheduler_1_d48fab2aae5e |     self.session.flush()
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/session.py", line 2446, in flush
scheduler_1_d48fab2aae5e |     self._flush(objects)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/session.py", line 2584, in _flush
scheduler_1_d48fab2aae5e |     transaction.rollback(_capture_exception=True)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/util/langhelpers.py", line 67, in __exit__
scheduler_1_d48fab2aae5e |     compat.reraise(exc_type, exc_value, exc_tb)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/util/compat.py", line 277, in reraise
scheduler_1_d48fab2aae5e |     raise value
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/session.py", line 2544, in _flush
scheduler_1_d48fab2aae5e |     flush_context.execute()
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/unitofwork.py", line 416, in execute
scheduler_1_d48fab2aae5e |     rec.execute(self)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/unitofwork.py", line 583, in execute
scheduler_1_d48fab2aae5e |     uow,
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/persistence.py", line 245, in save_obj
scheduler_1_d48fab2aae5e |     insert,
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/orm/persistence.py", line 1116, in _emit_insert_statements
scheduler_1_d48fab2aae5e |     statement, params
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line 980, in execute
scheduler_1_d48fab2aae5e |     return meth(self, multiparams, params)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/sql/elements.py", line 273, in _execute_on_connection
scheduler_1_d48fab2aae5e |     return connection._execute_clauseelement(self, multiparams, params)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line 1099, in _execute_clauseelement
scheduler_1_d48fab2aae5e |     distilled_params,
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line 1240, in _execute_context
scheduler_1_d48fab2aae5e |     e, statement, parameters, cursor, context
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line 1458, in _handle_dbapi_exception
scheduler_1_d48fab2aae5e |     util.raise_from_cause(sqlalchemy_exception, exc_info)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/util/compat.py", line 296, in raise_from_cause
scheduler_1_d48fab2aae5e |     reraise(type(exception), exception, tb=exc_tb, cause=cause)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/util/compat.py", line 276, in reraise
scheduler_1_d48fab2aae5e |     raise value.with_traceback(tb)
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/base.py", line 1236, in _execute_context
scheduler_1_d48fab2aae5e |     cursor, statement, parameters, context
scheduler_1_d48fab2aae5e |   File "/usr/local/lib/python3.6/site-packages/sqlalchemy/engine/default.py", line 536, in do_execute
scheduler_1_d48fab2aae5e |     cursor.execute(statement, parameters)
scheduler_1_d48fab2aae5e | sqlalchemy.exc.ProgrammingError: (psycopg2.errors.UndefinedTable) relation "job" does not exist
scheduler_1_d48fab2aae5e | LINE 1: INSERT INTO job (dag_id, state, job_type, start_date, end_da...
scheduler_1_d48fab2aae5e |                     ^
scheduler_1_d48fab2aae5e |  [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: {'dag_id': None, 'state': 'running', 'job_type': 'SchedulerJob', 'start_date': datetime.datetime(2019, 4, 22, 13, 15, 32, 362097, tzinfo=<Timezone [UTC]>), 'end_date': None, 'latest_heartbeat': datetime.datetime(2019, 4, 22, 13, 15, 32, 362158, tzinfo=<Timezone [UTC]>), 'executor_class': 'CeleryExecutor', 'hostname': '668add730bf7', 'unixname': 'airflow'}] (Background on this error at: http://sqlalche.me/e/f405)