You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/06/21 15:44:02 UTC

[jira] [Commented] (AIRFLOW-4142) airflow delete sub dag error

    [ https://issues.apache.org/jira/browse/AIRFLOW-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869613#comment-16869613 ] 

ASF GitHub Bot commented on AIRFLOW-4142:
-----------------------------------------

ashb commented on pull request #4959: [AIRFLOW-4142] 'DagRun' has no attribute 'task_id'
URL: https://github.com/apache/airflow/pull/4959
 
 
   
 
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


> airflow delete sub dag error
> ----------------------------
>
>                 Key: AIRFLOW-4142
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-4142
>             Project: Apache Airflow
>          Issue Type: Bug
>          Components: api
>    Affects Versions: 1.10.2
>            Reporter: xjl
>            Priority: Major
>         Attachments: 0001-type-object-DagRun-has-no-attribute-task_id.patch
>
>
> airflow delete sub dag error because DagRun class has no attr task_id
>  airflow delete_dag example_subdag_operator.section-1
> Traceback (most recent call last):
>  File "/bin/airflow", line 32, in <module>
>  args.func(args)
>  File "/usr/lib/python2.7/site-packages/airflow/utils/cli.py", line 74, in wrapper
>  return f(*args, **kwargs)
>  File "/usr/lib/python2.7/site-packages/airflow/bin/cli.py", line 255, in delete_dag
>  message = api_client.delete_dag(dag_id=args.dag_id)
>  File "/usr/lib/python2.7/site-packages/airflow/api/client/local_client.py", line 37, in delete_dag
>  count = delete_dag.delete_dag(dag_id)
>  File "/usr/lib/python2.7/site-packages/airflow/utils/db.py", line 73, in wrapper
>  return func(*args, **kwargs)
>  File "/usr/lib/python2.7/site-packages/airflow/api/common/experimental/delete_dag.py", line 60, in delete_dag
>  count += session.query(m).filter(m.dag_id == p, m.task_id == c).delete()
> AttributeError: type object 'DagRun' has no attribute 'task_id'



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)