One - One Code All

Blog Content

airflow给task传参数-tp json

Python 并行计算   2014-01-29 22:21:26

参考官网: http://airflow.incubator.apache.org/cli.html


test

Test a task instance. This will run a task without checking for dependencies or recording its state in the database.

airflow test [-h] [-sd SUBDIR] [-dr] [-tp TASK_PARAMS]
             dag_id task_id execution_date

Positional Arguments

dag_idThe id of the dag
task_idThe id of the task
execution_dateThe execution date of the DAG

Named Arguments

-sd, --subdir

File location or directory from which to look for the dag

Default: /Users/kaxil/airflow/dags

-dr, --dry_run

Perform a dry run

Default: False

-tp, --task_params

Sends a JSON params dict to the task


-tp '{"key":"value"}'


上一篇:javascript点击超链接弹出确认取消对话框并跳转
下一篇:python中数组,矩阵,列表间的相互转换

The minute you think of giving up, think of the reason why you held on so long.