`airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators`¶

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

Module Contents¶

`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]¶

This is the main method to derive when creating an operator.

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]¶

This is the main method to derive when creating an operator.

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]¶