Hello All,
I have created sample workflow(test-workflow.py) exactly same as tutorial.py
except schedule_interval='*/2 * * * *' i.e. every even minute.
I have executed command ' python test-workflow.py' .
Workflow is getting listed in AirFlow-
airflow list_tasks test-workflow
[2016-07-05 12:49:48,027] {__init__.py:36} INFO - Using executor
SequentialExecutor
[2016-07-05 12:49:48,958] {models.py:154} INFO - Filling up the DagBag from
/home/pari/airflow/dags
print_date
sleep
templated
How to schedule this dag.
Do I need to use "airflow scheduler -d test-workflow" command or there are
any other options.
Thanks
Pari
