You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@airflow.apache.org by Pariksheet Barapatre <pa...@gmail.com> on 2016/07/05 07:21:41 UTC

How to schedule a DAG

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