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.

Module Contents

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.

name = 'decreasing_priority_weight_strategy_plugin'[source]
priority_weight_strategies[source]

Was this entry helpful?