airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators¶

Example DAG demonstrating the usage of dynamic task mapping with non-TaskFlow operators.

Attributes¶

`AddOneOperator`	A custom operator that adds one to the input.
`SumItOperator`	A custom operator that sums the input.

class airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators.AddOneOperator(value, **kwargs)[source]¶

A custom operator that adds one to the input.

execute(context)[source]¶

Derive when creating an operator.

The main method to execute the task. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

class airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators.SumItOperator(values, **kwargs)[source]¶

A custom operator that sums the input.

execute(context)[source]¶

Derive when creating an operator.

The main method to execute the task. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators.add_one_task[source]¶