Airflow quick start not working
Hi, I just started using Airflow, but I can not perform a task during a quick start: airflow run example_bash_operator runme_0 2015-01-01
.
I just created a conda environment with python 2.7.6 and installed airflow
via pip
which I installed airflow==1.8.0
. Then I ran the commands listed here https://airflow.incubator.apache.org/start.html .
When I try to start the first instance of the task, nothing happens when I view the UI. Here's the command output:
(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
On the other hand, filling works fine: airflow backfill example_bash_operator -s 2015-01-01 -e 2015-01-02
.
What am I missing?
source to share
The run command is used to start one instance of a task. But it will only be able to work if you have cleared the previous runs. To clear the mileage:
- go to Airflow UI (graph view)
- Click on a specific task and click on Clear
You should now be able to run the task using the cmd you originally had.
To view the logs for this task, you can run: vi / Users / se7entyse7en / airflow / logs / example_bash_operator / runme_0 / 2015-01-01T00: 00: 00
I had a task like:
t2 = BashOperator(
task_id='sleep',
depends_on_past=False,
bash_command='sleep 35',
dag=dag)
I was able to see changes in the state of the task as it was completed.
source to share