xjl created AIRFLOW-4142:
----------------------------
Summary: 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
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)
