airflow.operators.weekday
¶
Module Contents¶
Classes¶
Branches into one of two lists of tasks depending on the current day. |
- class airflow.operators.weekday.BranchDayOfWeekOperator(*, follow_task_ids_if_true: Union[str, Iterable[str]], follow_task_ids_if_false: Union[str, Iterable[str]], week_day: Union[str, Iterable[str]], use_task_execution_day: bool = False, **kwargs)[source]¶
Bases:
airflow.operators.branch.BaseBranchOperator
Branches into one of two lists of tasks depending on the current day. For more information on how to use this operator, take a look at the guide: BranchDayOfWeekOperator
- Parameters
follow_task_ids_if_true (str or list[str]) – task id or task ids to follow if criteria met
follow_task_ids_if_false (str or list[str]) – task id or task ids to follow if criteria does not met
week_day (iterable or airflow.utils.weekday.WeekDay) –
Day of the week to check (full name). Optionally, a set of days can also be provided using a set. Example values:
"MONDAY"
,{"Saturday", "Sunday"}
{WeekDay.TUESDAY}
{WeekDay.SATURDAY, WeekDay.SUNDAY}
use_task_execution_day (bool) – If
True
, uses task’s execution day to compare with is_today. Execution Date is Useful for backfilling. IfFalse
, uses system’s day of the week.