The GitHub Actions job "Tests (AMD)" on airflow.git/trigger-policy has failed. Run started by GitHub user Lee-W (triggered by Lee-W).
Head commit for run: c6e145e337e331a87a9f57c1ca5a033a8d44cf56 / Wei Lee <[email protected]> Add rollup trigger policies for partitioned Dag runs Introduce ``RollupTriggerPolicy`` (``wait_for_all``, ``allow_missing``, ``minimum_count``) so a ``RollupMapper`` can fire the downstream Dag run without waiting for every upstream key in the window: - ``WAIT_FOR_ALL`` (default, behavior-preserving): fire only when every expected upstream key has arrived. - ``ALLOW_MISSING(n)``: fire when at most ``n`` of the expected keys are still missing. Use when occasional producer dropouts shouldn't block the rollup. - ``MINIMUM_COUNT(n)``: fire as soon as ``n`` keys have arrived. Use for "fire ASAP once we have enough". The policy is dispatched on the scheduler hot path by ``SchedulerJobRunner._check_rollup_asset_status``, so the satisfied? check stays a single integer comparison and the scheduler tick remains bounded. Back-compat: ``RollupMapper.deserialize`` defaults to ``WAIT_FOR_ALL`` when the serialized payload predates ``trigger_policy`` so pre-existing serialized Dags survive the upgrade without ``KeyError``. Report URL: https://github.com/apache/airflow/actions/runs/26101813998 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
