airflow.example_dags.plugins.business_day_window

Classes

`BusinessDayWindow`	A calendar-month rollup window that yields only weekday (Mon–Fri) period-starts.
`BusinessDayWindowPlugin`	Class used to define AirflowPlugin.

Module Contents

class airflow.example_dags.plugins.business_day_window.BusinessDayWindow(*, direction=Direction.FORWARD)[source]

Bases: airflow.partition_mappers.window.Window

A calendar-month rollup window that yields only weekday (Mon–Fri) period-starts.

The built-in MonthWindow yields every calendar day in the month. BusinessDayWindow skips Saturdays and Sundays, so a monthly downstream asset only waits for the business-day upstream partitions — useful for financial or operational pipelines whose upstream data isn’t produced on weekends.

This class demonstrates registering a custom Window subclass via the AirflowPlugin.windows registry: any plugin that lists it in windows = [...] makes it available to RollupMapper without modifying core Airflow.

Assumes FORWARD direction and a day-1 month anchor — the standard contract for month-aligned temporal upstream mappers.

expected_decoded_type: ClassVar[type][source]

to_upstream(period_start)[source]

Yield each decoded upstream item composing decoded_downstream.

class airflow.example_dags.plugins.business_day_window.BusinessDayWindowPlugin[source]

Bases: airflow.plugins_manager.AirflowPlugin

Class used to define AirflowPlugin.

name = 'business_day_window_plugin'[source]

windows[source]