天天看点

Airflow Concept

DAG:定义调度信息,定义任务之间的关系和依赖

Operator:定义任务,描述DAG中的一个任务节点,可以认为是执行任务的模板

Task:Operator被传入特定的参数实例化之后,就被称为task,这就是为什么称Operator为任务模板的原因;

Task instance:根据DAG中定义的调度信息和依赖关系,以及Operator中定义的任务的具体内容,可以生成一个Task Instance;一个task instance 代表一个Task一次特定的运行, 他整合了 dag, task(Operator的具体实例),和 dag中的调度信息生成的一个将要运行此任务的时间点。 Task instances是有指示状态的,状态可以是 “running”, “success”, “failed”, “skipped”, “up for retry”等等;

参考