airflow-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Poornima Joshi <joshipoornim...@gmail.com>
Subject Re: dagrun_operator in Airflow Version 1.10.10 ERROR - No row was found for one() _run_raw_task result = task_copy.execute(context=context)
Date Mon, 15 Jun 2020 10:49:24 GMT
Thank you

On Fri, Jun 12, 2020 at 4:54 PM SHANIT <shanit.android@gmail.com> wrote:
>
> This issue has been resolved. We need to avoid using execution_date parameter while creating
the `dagrun_operator`
>
> On 2020/06/09 16:33:32, SHANIT <shanit.android@gmail.com> wrote:
> > On Migrating Airflow from V1.10.2 to V1.10.10 One of our DAG have a task which is
of dagrun_operator type.
> > The DAG runs all fine. In fact the python callable of the task mentioned until the
last line. Then it errors out.
> > It errors out
> >
> > ```
> > [2020-06-09 11:36:22,838] {taskinstance.py:1145} ERROR - No row was found for one()
> > Traceback (most recent call last):
> >   File "/usr/local/lib/python3.6/site-packages/airflow/models/taskinstance.py",
line 983, in _run_raw_task
> >     result = task_copy.execute(context=context)
> >   File "/usr/local/lib/python3.6/site-packages/airflow/operators/dagrun_operator.py",
line 95, in execute
> >     replace_microseconds=False)
> >   File "/usr/local/lib/python3.6/site-packages/airflow/api/common/experimental/trigger_dag.py",
line 141, in trigger_dag
> >     replace_microseconds=replace_microseconds,
> >   File "/usr/local/lib/python3.6/site-packages/airflow/api/common/experimental/trigger_dag.py",
line 98, in _trigger_dag
> >     external_trigger=True,
> >   File "/usr/local/lib/python3.6/site-packages/airflow/utils/db.py", line 74, in
wrapper
> >     return func(*args, **kwargs)
> >   File "/usr/local/lib/python3.6/site-packages/airflow/models/dag.py", line 1471,
in create_dagrun
> >     run.refresh_from_db()
> >   File "/usr/local/lib/python3.6/site-packages/airflow/utils/db.py", line 74, in
wrapper
> >     return func(*args, **kwargs)
> >   File "/usr/local/lib/python3.6/site-packages/airflow/models/dagrun.py", line 109,
in refresh_from_db
> >     DR.run_id == self.run_id
> >   File "/usr/local/lib64/python3.6/site-packages/sqlalchemy/orm/query.py"
> > ```
> >
> > Details of this is also posted at https://github.com/apache/airflow/issues/9197
> >



-- 
Thanks & Regards
 Poornima

Mime
View raw message