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 <[email protected]> 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
> 

Reply via email to