airflow.providers.standard.operators.datetime¶

Classes¶

BranchDateTimeOperator

Branches into one of two lists of tasks depending on the current datetime.

Functions¶

target_times_as_dates(base_date, lower, upper)

Ensure upper and lower time targets are datetimes by combining them with base_date.

Module Contents¶

class airflow.providers.standard.operators.datetime.BranchDateTimeOperator(*, follow_task_ids_if_true, follow_task_ids_if_false, target_lower, target_upper, use_task_logical_date=False, **kwargs)[source]¶

Bases: airflow.providers.standard.operators.branch.BaseBranchOperator

Branches into one of two lists of tasks depending on the current datetime.

For more information on how to use this operator, take a look at the guide: BranchDateTimeOperator.

True branch will be returned when datetime.datetime.now() falls below target_upper and above target_lower.

Parameters:

follow_task_ids_if_true (str | collections.abc.Iterable[str]) – task_id, task_group_id, or a list of task_ids and/or task_group_ids to follow if datetime.datetime.now() falls above target_lower and below target_upper.
follow_task_ids_if_false (str | collections.abc.Iterable[str]) – task_id, task_group_id, or a list of task_ids and/or task_group_ids to follow if datetime.datetime.now() falls below target_lower or above target_upper.
target_lower (datetime.datetime | datetime.time | None) – target lower bound.
target_upper (datetime.datetime | datetime.time | None) – target upper bound.
use_task_logical_date (bool) – If True, uses task’s logical date to compare with targets. Logical date is useful for backfilling. If False, uses system’s date.

target_lower[source]¶

target_upper[source]¶

follow_task_ids_if_true[source]¶

follow_task_ids_if_false[source]¶

use_task_logical_date = False[source]¶

choose_branch(context)[source]¶

Abstract method to choose which branch to run.

Subclasses should implement this, running whatever logic is necessary to choose a branch and returning a task_id or list of task_ids. If None is returned, all downstream tasks will be skipped.

Parameters:: context (airflow.providers.common.compat.sdk.Context) – Context dictionary as passed to execute()

airflow.providers.standard.operators.datetime.target_times_as_dates(base_date, lower, upper)[source]¶

Ensure upper and lower time targets are datetimes by combining them with base_date.