Uploaded image for project: 'Apache Airflow'
  1. Apache Airflow
  2. AIRFLOW-6518

Task did not retry when there was temporary metastore db connectivity loss

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.10.6
    • Fix Version/s: None
    • Component/s: database, scheduler
    • Labels:
      None

      Description

      My DAG has got retries configured at the task level. I started a dagrun, then while a task was running the metastore db crashed, the task failed, but the dagrun did not attempt to retry the task (even though task retries are configured!), db recovered 3 seconds after the task failed, instead the dagrun went to FAILED state.

      Last part of log of TaskInstance:

      [2020-01-08 17:34:46,301]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk Traceback (most recent call last):
      [2020-01-08 17:34:46,301]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      [2020-01-08 17:34:46,302]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk args.func(args)
      [2020-01-08 17:34:46,302]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      [2020-01-08 17:34:46,302]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk return f(*args, **kwargs)
      [2020-01-08 17:34:46,302]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      [2020-01-08 17:34:46,302]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk _run(args, dag, ti)
      [2020-01-08 17:34:46,302]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 469, in _run
      [2020-01-08 17:34:46,302]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk pool=args.pool,
      [2020-01-08 17:34:46,302]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/db.py", line 74, in wrapper
      [2020-01-08 17:34:46,302]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk return func(*args, **kwargs)
      [2020-01-08 17:34:46,302]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/models/taskinstance.py", line 962, in _run_raw_task
      [2020-01-08 17:34:46,302]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk self.refresh_from_db()
      [2020-01-08 17:34:46,303]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/db.py", line 74, in wrapper
      [2020-01-08 17:34:46,303]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk return func(*args, **kwargs)
      [2020-01-08 17:34:46,303]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/models/taskinstance.py", line 461, in refresh_from_db
      [2020-01-08 17:34:46,303]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk ti = qry.first()
      [2020-01-08 17:34:46,303]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3265, in first
      [2020-01-08 17:34:46,303]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk ret = list(self[0:1])
      [2020-01-08 17:34:46,303]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3043, in _getitem_
      [2020-01-08 17:34:46,303]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk return list(res)
      [2020-01-08 17:34:46,303]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      [2020-01-08 17:34:46,303]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk return self._execute_and_instances(context)
      [2020-01-08 17:34:46,304]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      [2020-01-08 17:34:46,304]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk querycontext, self._connection_from_session, close_with_result=True
      [2020-01-08 17:34:46,304]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      [2020-01-08 17:34:46,304]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      [2020-01-08 17:34:46,304]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      [2020-01-08 17:34:46,305]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk conn = self.session.connection(**kw)
      [2020-01-08 17:34:46,305]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      [2020-01-08 17:34:46,305]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk execution_options=execution_options,
      [2020-01-08 17:34:46,305]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      [2020-01-08 17:34:46,305]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk engine, execution_options
      [2020-01-08 17:34:46,305]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      [2020-01-08 17:34:46,305]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk conn = bind._contextual_connect()
      [2020-01-08 17:34:46,305]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      [2020-01-08 17:34:46,305]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk self._wrap_pool_connect(self.pool.connect, None),
      [2020-01-08 17:34:46,306]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      [2020-01-08 17:34:46,306]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk e, dialect, self
      [2020-01-08 17:34:46,306]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      [2020-01-08 17:34:46,306]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk util.raise_from_cause(sqlalchemy_exception, exc_info)
      [2020-01-08 17:34:46,306]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      [2020-01-08 17:34:46,306]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk reraise(type(exception), exception, tb=exc_tb, cause=cause)
      [2020-01-08 17:34:46,306]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      [2020-01-08 17:34:46,306]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk return fn()
      [2020-01-08 17:34:46,306]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      [2020-01-08 17:34:46,306]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk return _ConnectionFairy._checkout(self)
      [2020-01-08 17:34:46,307]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      [2020-01-08 17:34:46,307]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk fairy = _ConnectionRecord.checkout(pool)
      [2020-01-08 17:34:46,307]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      [2020-01-08 17:34:46,307]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk rec = pool._do_get()
      [2020-01-08 17:34:46,307]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      [2020-01-08 17:34:46,307]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk return self._create_connection()
      [2020-01-08 17:34:46,307]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      [2020-01-08 17:34:46,307]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk return _ConnectionRecord(self)
      [2020-01-08 17:34:46,308]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      [2020-01-08 17:34:46,308]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk self.__connect(first_connect_check=True)
      [2020-01-08 17:34:46,308]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      [2020-01-08 17:34:46,308]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk connection = pool._invoke_creator(self)
      [2020-01-08 17:34:46,308]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      [2020-01-08 17:34:46,308]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk return dialect.connect(*cargs, **cparams)
      [2020-01-08 17:34:46,309]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      [2020-01-08 17:34:46,309]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk return self.dbapi.connect(*cargs, **cparams)
      [2020-01-08 17:34:46,309]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      [2020-01-08 17:34:46,309]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk return Connection(*args, **kwargs)
      [2020-01-08 17:34:46,309]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      [2020-01-08 17:34:46,309]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk super(Connection, self)._init_(*args, **kwargs2)
      [2020-01-08 17:34:46,310]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      [2020-01-08 17:34:46,310]

      {base_task_runner.py:115}

      INFO - Job 34662: Subtask mytsk (Background on this error at: http://sqlalche.me/e/e3q8)
      [2020-01-08 17:34:48,721]

      {logging_mixin.py:112}

      INFO - [2020-01-08 17:34:48,721]

      {local_task_job.py:78}

      ERROR - Received SIGTERM. Terminating subprocesses
      [2020-01-08 17:34:48,837]

      {helpers.py:308}

      INFO - Sending 15 to GPID 20566
      [2020-01-08 17:34:48,837]

      {helpers.py:286}

      INFO - Process psutil.Process(pid=20566, status='terminated') (20566) terminated with exit code 1

      Part of scheduler logs:

      [2020-01-08 17:34:48,818]

      {scheduler_job.py:1367}

      INFO - Exited execute loop
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc .return self.dbapi.connect(*cargs, **cparams)
      OperationalError File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      : super(Connection, self)._init_(*args, **kwargs2)
      (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      run_job.run()
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      merged = self.query(mapper.class_).get(key[1])
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = self.one_or_none()
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      Process QueuedLocalWorker-17:
      Traceback (most recent call last):
      Process QueuedLocalWorker-2:
      Process QueuedLocalWorker-10:
      File "/usr/lib64/python2.7/multiprocessing/process.py", line 267, in _bootstrap
      Traceback (most recent call last):
      Traceback (most recent call last):
      File "/usr/lib64/python2.7/multiprocessing/process.py", line 267, in _bootstrap
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      File "/usr/lib64/python2.7/multiprocessing/process.py", line 267, in _bootstrap
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      Process QueuedLocalWorker-4:
      Traceback (most recent call last):
      Process QueuedLocalWorker-7:
      File "/usr/lib64/python2.7/multiprocessing/process.py", line 267, in _bootstrap
      Traceback (most recent call last):
      self.run()
      File "/usr/lib64/python2.7/multiprocessing/process.py", line 267, in _bootstrap
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/executors/local_executor.py", line 118, in run
      self.task_queue.task_done()
      File "<string>", line 2, in task_done
      self.run()
      File "/usr/lib64/python2.7/multiprocessing/managers.py", line 759, in _callmethod
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/executors/local_executor.py", line 118, in run
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      self.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/executors/local_executor.py", line 118, in run
      self.task_queue.task_done()
      File "<string>", line 2, in task_done
      File "/usr/lib64/python2.7/multiprocessing/managers.py", line 759, in _callmethod
      self.task_queue.task_done()
      File "<string>", line 2, in task_done
      self.run()
      File "/usr/lib64/python2.7/multiprocessing/managers.py", line 759, in _callmethod
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/executors/local_executor.py", line 118, in run
      self.task_queue.task_done()
      File "<string>", line 2, in task_done
      e, dialect, self
      File "/usr/lib64/python2.7/multiprocessing/managers.py", line 759, in _callmethod
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      self.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/executors/local_executor.py", line 118, in run
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      self.task_queue.task_done()
      File "<string>", line 2, in task_done
      File "/usr/lib64/python2.7/multiprocessing/managers.py", line 759, in _callmethod
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      kind, result = conn.recv()
      kind, result = conn.recv()
      IOError: [Errno 104] Connection reset by peer
      IOError: [Errno 104] Connection reset by peer
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      Process QueuedLocalWorker-14:
      Traceback (most recent call last):
      File "/usr/lib64/python2.7/multiprocessing/process.py", line 267, in _bootstrap
      self.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/executors/local_executor.py", line 118, in run
      self.task_queue.task_done()
      File "<string>", line 2, in task_done
      File "/usr/lib64/python2.7/multiprocessing/managers.py", line 759, in _callmethod
      kind, result = conn.recv()
      IOError: [Errno 104] Connection reset by peer
      kind, result = conn.recv()
      IOError: [Errno 104] Connection reset by peer
      kind, result = conn.recv()
      IOError: [Errno 104] Connection reset by peer
      kind, result = conn.recv()
      IOError: [Errno 104] Connection reset by peer
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      Traceback (most recent call last):
      File "/home/ec2-user/venv/bin/airflow", line 37, in <module>
      args.func(args)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
      return f(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 551, in run
      _run(args, dag, ti)
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/bin/cli.py", line 464, in _run
      run_job.run()
      File "/home/ec2-user/venv/local/lib/python2.7/site-packages/airflow/jobs/base_job.py", line 233, in run
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      session.merge(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2113, in merge
      _resolve_conflict_map=_resolve_conflict_map,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 2186, in _merge
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      merged = self.query(mapper.class_).get(key[1])
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 982, in get
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      return self._get_impl(ident, loading.load_on_pk_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 1094, in _get_impl
      return db_load_fn(self, primary_key_identity)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/loading.py", line 284, in load_on_pk_identity
      return q.one()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3325, in one
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc.OperationalError conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      : (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      ret = self.one_or_none()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3294, in one_or_none
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      ret = list(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3367, in _iter_
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc.OperationalError return self._execute_and_instances(context)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3389, in _execute_and_instances
      : (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      querycontext, self._connection_from_session, close_with_result=True
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3404, in _get_bind_args
      mapper=self._bind_mapper(), clause=querycontext.statement, **kw
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/query.py", line 3382, in _connection_from_session
      conn = self.session.connection(**kw)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1133, in connection
      execution_options=execution_options,
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 1139, in _connection_for_bind
      engine, execution_options
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/orm/session.py", line 432, in _connection_for_bind
      conn = bind._contextual_connect()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2242, in _contextual_connect
      self._wrap_pool_connect(self.pool.connect, None),
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2280, in _wrap_pool_connect
      e, dialect, self
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 1547, in _handle_dbapi_exception_noconnection
      util.raise_from_cause(sqlalchemy_exception, exc_info)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/util/compat.py", line 398, in raise_from_cause
      reraise(type(exception), exception, tb=exc_tb, cause=cause)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/base.py", line 2276, in _wrap_pool_connect
      return fn()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 363, in connect
      return _ConnectionFairy._checkout(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 760, in _checkout
      fairy = _ConnectionRecord.checkout(pool)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 492, in checkout
      rec = pool._do_get()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/impl.py", line 238, in _do_get
      return self._create_connection()
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 308, in _create_connection
      return _ConnectionRecord(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 437, in _init_
      self.__connect(first_connect_check=True)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/pool/base.py", line 639, in __connect
      connection = pool._invoke_creator(self)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/strategies.py", line 114, in connect
      return dialect.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/sqlalchemy/engine/default.py", line 482, in connect
      return self.dbapi.connect(*cargs, **cparams)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/_init_.py", line 84, in Connect
      return Connection(*args, **kwargs)
      File "/home/ec2-user/venv/local/lib64/python2.7/site-packages/MySQLdb/connections.py", line 179, in _init_
      super(Connection, self)._init_(*args, **kwargs2)
      sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (2005, "Unknown MySQL server host 'redacted_dbhosthere' (11)")
      (Background on this error at: http://sqlalche.me/e/e3q8)
      [2020-01-08 17:35:54,711]

      {scheduler_job.py:989}

      INFO - DAG mydag has 5/21 running and queued tasks

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              toopt4 t oo
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated: