You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "jack (JIRA)" <ji...@apache.org> on 2019/04/23 10:01:00 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=16823909#comment-16823909 ]
jack commented on AIRFLOW-4142:
-------------------------------
Confirmed with 1.10.3:
{code:java}
Traceback (most recent call last):
File "/usr/local/bin/airflow", line 32, in <module>
args.func(args)
File "/usr/local/lib/python3.5/dist-packages/airflow/utils/cli.py", line 74, in wrapper
return f(*args, **kwargs)
File "/usr/local/lib/python3.5/dist-packages/airflow/bin/cli.py", line 252, in delete_dag
message = api_client.delete_dag(dag_id=args.dag_id)
File "/usr/local/lib/python3.5/dist-packages/airflow/api/client/local_client.py", line 37, in delete_dag
count = delete_dag.delete_dag(dag_id)
File "/usr/local/lib/python3.5/dist-packages/airflow/utils/db.py", line 73, in wrapper
return func(*args, **kwargs)
File "/usr/local/lib/python3.5/dist-packages/airflow/api/common/experimental/delete_dag.py", line 61, 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'{code}
However running:
{code:java}
airflow delete_dag example_subdag_operator
{code}
works.
> 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)