`airflow.sensors.weekday`¶

Module Contents¶

class airflow.sensors.weekday.DayOfWeekSensor(*, week_day, use_task_execution_day=False, **kwargs)[source]¶

Bases: airflow.sensors.base.BaseSensorOperator

Waits until the first specified day of the week. For example, if the execution day of the task is ‘2018-12-22’ (Saturday) and you pass ‘FRIDAY’, the task will wait until next Friday.

Example (with single day):

weekend_check = DayOfWeekSensor(
    task_id='weekend_check',
    week_day='Saturday',
    use_task_execution_day=True,
    dag=dag)

Example (with multiple day using set):

weekend_check = DayOfWeekSensor(
    task_id='weekend_check',
    week_day={'Saturday', 'Sunday'},
    use_task_execution_day=True,
    dag=dag)

Example (with WeekDay enum):

# import WeekDay Enum
from airflow.utils.weekday import WeekDay

weekend_check = DayOfWeekSensor(
    task_id='weekend_check',
    week_day={WeekDay.SATURDAY, WeekDay.SUNDAY},
    use_task_execution_day=True,
    dag=dag)

Parameters

week_day (set or str 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 week_day. Execution Date is Useful for backfilling. If False, uses system’s day of the week. Useful when you don’t want to run anything on weekdays on the system.

poke(self, context)[source]¶

airflow.sensors.weekday¶

Module Contents¶

`airflow.sensors.weekday`¶