airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bolke de Bruin (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (AIRFLOW-214) TaskInstance can get detached in process_dag
Date Thu, 09 Jun 2016 18:10:20 GMT

     [ https://issues.apache.org/jira/browse/AIRFLOW-214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Bolke de Bruin closed AIRFLOW-214.
----------------------------------
    Resolution: Fixed

> TaskInstance can get detached in process_dag
> --------------------------------------------
>
>                 Key: AIRFLOW-214
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-214
>             Project: Apache Airflow
>          Issue Type: Bug
>          Components: scheduler
>            Reporter: Bolke de Bruin
>             Fix For: Airflow 1.8
>
>
> Is some rare occasions the TaskInstance can get detached in process_dag. It is unclear
why
> {code}[2016-06-06 17:47:37,048] {models.py:3444} INFO - Updating state for <DagRun
example_skip_dag @ 2016-06-05 00:00:00: scheduled__2016-06-05T00:00:00, externally triggered:
False> considering 8 task(s)
> [2016-06-06 17:47:37,059] {jobs.py:670} ERROR - Instance <TaskInstance at 0x10d3e9410>
is not bound to a Session; attribute refresh operation cannot proceed
> Traceback (most recent call last):
>   File "/Users/bolke/Documents/dev/airflow_env/lib/python2.7/site-packages/airflow-1.7.1.2-py2.7.egg/airflow/jobs.py",
line 667, in _do_dags
>     self.process_dag(dag, tis_out)
>   File "/Users/bolke/Documents/dev/airflow_env/lib/python2.7/site-packages/airflow-1.7.1.2-py2.7.egg/airflow/jobs.py",
line 531, in process_dag
>     task = dag.get_task(ti.task_id)
>   File "/Users/bolke/Documents/dev/airflow_env/lib/python2.7/site-packages/sqlalchemy/orm/attributes.py",
line 237, in __get__
>     return self.impl.get(instance_state(instance), dict_)
>   File "/Users/bolke/Documents/dev/airflow_env/lib/python2.7/site-packages/sqlalchemy/orm/attributes.py",
line 578, in get
>     value = state._load_expired(state, passive)
>   File "/Users/bolke/Documents/dev/airflow_env/lib/python2.7/site-packages/sqlalchemy/orm/state.py",
line 474, in _load_expired
>     self.manager.deferred_scalar_loader(self, toload)
>   File "/Users/bolke/Documents/dev/airflow_env/lib/python2.7/site-packages/sqlalchemy/orm/loading.py",
line 610, in load_scalar_attributes
>     (state_str(state)))
> DetachedInstanceError: Instance <TaskInstance at 0x10d3e9410> is not bound to a
Session; attribute refresh operation cannot proceed{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message