氣流快速啓動不起作用

嗨我剛開始使用氣流，但我無法設法在快速啓動運行中完成任務：airflow run example_bash_operator runme_0 2015-01-01。氣流快速啓動不起作用

我剛剛用python 2.7.6創建了一個conda環境，並安裝了airflow到pip，它安裝了airflow==1.8.0。然後我運行這裏列出的命令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。

我缺少什麼？

來源

2017-07-28 se7entyse7en

我剛剛發現，如果單個任務運行，那麼它將作爲任何DAG的一部分列在Browse > Task Instances之下。

來源

2017-07-28 10:28:40 se7entyse7en

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)

我可以在任務執行時看到任務狀態的變化。

來源

2017-09-06 00:00:22 Neil

氣流快速啓動不起作用

回答

相關問題