Das Luftstromobjekt „NoneType“ hat kein Attribut „is_paused“. Wie kann ich das Problem beheben? ⇐ Python

[Anonymous]

Ich bin ein Neuling im Bereich Airflow und folge einfach dem Tutorial, um einen Dag auszuführen. Eigentlich habe ich es erfolgreich gemacht, aber das Problem besteht darin, dass, wenn ich versuche, den Tag anzuhalten, indem ich eine Befehlszeile wie „airflow pause dag_id eingebe, es einen AttributeError auslöst: „NoneType“-Objekt hat kein Attribut „is_paused“

Und der Traceback lautet:

Code: Select all

File "/anaconda3/bin/airflow", line 32, in 
args.func(args)
File "/anaconda3/lib/python3.6/site-packages/airflow/utils/cli.py", line 74, in wrapper
return f(*args, **kwargs)
File "/anaconda3/lib/python3.6/site-packages/airflow/bin/cli.py", line 365, in pause
set_is_paused(True, args, dag)
File "/anaconda3/lib/python3.6/site-packages/airflow/bin/cli.py", line 379, in set_is_paused
dm.is_paused = is_paused

Also überprüfe ich die Python-Datei im Ausgabeverzeichnis, aber sie wurde von Airflow codiert und ich weiß nicht, wie ich das beheben kann?!!!

Code: Select all

SHOW:~ macbook$ airflow list_dags
[2018-09-07 21:31:38,262] {__init__.py:51} INFO - Using executor SequentialExecutor
[2018-09-07 21:31:38,381] {models.py:258} INFO - Filling up the DagBag from /Users/macbook/airflow/dags

-------------------------------------------------------------------
DAGS
-------------------------------------------------------------------
example_bash_operator
example_branch_dop_operator_v3
example_branch_operator
example_http_operator
example_kubernetes_executor
example_kubernetes_operator
example_passing_params_via_test_command
example_python_operator
example_short_circuit_operator
example_skip_dag
example_subdag_operator
example_subdag_operator.section-1
example_subdag_operator.section-2
example_trigger_controller_dag
example_trigger_target_dag
example_xcom
haha
latest_only
latest_only_with_trigger
test_utils
tutorial

SHOW:~ macbook$ airflow pause haha
[2018-09-07 21:35:41,366] {__init__.py:51} INFO - Using executor SequentialExecutor
[2018-09-07 21:35:41,496] {models.py:258} INFO - Filling up the DagBag from /Users/macbook/airflow/dags
Traceback (most recent call last):
File "/anaconda3/bin/airflow", line 32, in 
args.func(args)
File "/anaconda3/lib/python3.6/site-packages/airflow/utils/cli.py", line 74, in wrapper
return f(*args, **kwargs)
File "/anaconda3/lib/python3.6/site-packages/airflow/bin/cli.py", line 365, in pause
set_is_paused(True, args, dag)
File "/anaconda3/lib/python3.6/site-packages/airflow/bin/cli.py", line 379, in set_is_paused
dm.is_paused = is_paused
AttributeError: 'NoneType' object has no attribute 'is_paused'