airflow.example_dags.plugins.decreasing_priority_weight_strategy¶

Classes¶

`DecreasingPriorityStrategy`	A priority weight strategy that decreases the priority weight with each attempt of the DAG task.
`DecreasingPriorityWeightStrategyPlugin`	Class used to define AirflowPlugin.

class airflow.example_dags.plugins.decreasing_priority_weight_strategy.DecreasingPriorityStrategy[source]¶

Bases: airflow.task.priority_strategy.PriorityWeightStrategy

A priority weight strategy that decreases the priority weight with each attempt of the DAG task.

get_weight(ti)[source]¶

Get the priority weight of a task.

class airflow.example_dags.plugins.decreasing_priority_weight_strategy.DecreasingPriorityWeightStrategyPlugin[source]¶

Bases: airflow.plugins_manager.AirflowPlugin

Class used to define AirflowPlugin.