エアフローのクイックスタートが機能しない

Question

こんにちは、エアフローの使用を開始しましたが、クイックスタートのタスクを実行できません。airflow run example_bash_operator runme_0 2015-01-01。

私はちょうどpython 2.7.6でcondha環境を作成し、airflow==1.8.0をインストールしたairflowからpipをインストールしました。それから私はここに記載されたコマンドを実行したhttps://airflow.incubator.apache.org/start.html。

最初のタスクインスタンスを実行しようとすると、UIを見ても何も起きないようです。ここでは、コマンドの出力を示します：

(airflow) ✔ se7entyse7en in ~/Projects/airflow  $ airflow run example_bash_operator runme_0 2015-01-01 
[2017-07-28 12:06:22,992] {__init__.py:57} INFO - Using executor SequentialExecutor 
Sending to executor. 
[2017-07-28 12:06:23,950] {__init__.py:57} INFO - Using executor SequentialExecutor 
Logging into: /Users/se7entyse7en/airflow/logs/example_bash_operator/runme_0/2015-01-01T00:00:00 

一方埋め戻しが正常に動作します：airflow backfill example_bash_operator -s 2015-01-01 -e 2015-01-02。

私には何が欠けていますか？

Answer 1

私は、単一のタスクが実行された場合、DAGの一部としてBrowse > Task Instancesの下にリストされていることがわかりました。

Answer 2

runコマンドは、単一のタスクインスタンスを実行するために使用されます。 これまでの実行をすべてクリアした場合にのみ実行することができます。

• は、特定のタスクをクリックしてエアフローUI（グラフ表示）
• を行くと、今あなたがして、タスクを実行することができますクリアに

をクリックしてください：実行をクリアする 最初に持っていたcmd。あなたが実行することができ、このタスクのログを表示するには

： VI /ユーザ/ se7entyse7en /気流/ログ/ example_bash_operator/runme_0/2015-01-01T00：00：00

私のようなタスクを持っていました：

t2 = BashOperator(
    task_id='sleep', 
    depends_on_past=False, 
    bash_command='sleep 35', 
    dag=dag) 

実行されたタスクの状態の変化を確認できました。