Skip to content

Add multi-team query filtering to triggerer trigger assignment#67517

Merged
vincbeck merged 1 commit into
apache:mainfrom
aws-mwaa:ramitkataria/mt/trigger-queries
May 26, 2026
Merged

Add multi-team query filtering to triggerer trigger assignment#67517
vincbeck merged 1 commit into
apache:mainfrom
aws-mwaa:ramitkataria/mt/trigger-queries

Conversation

@ramitkataria
Copy link
Copy Markdown
Contributor

@ramitkataria ramitkataria commented May 26, 2026

When core.multi_team is enabled, the triggerer's polling queries now filter triggers by team_name. A team-scoped triggerer (--team-name X) only picks up triggers with team_name='X', while a global triggerer (no --team-name) only picks up triggers with team_name IS NULL.

When core.multi_team is disabled, no filtering is applied and queries remain unchanged from the non-multi-team path. This handles the edge case where multi-team is disabled after triggers were already created with a team assignment, so those triggers are still picked up instead of being orphaned.

Team and queue filters combine as AND conditions.

cc @vincbeck @o-nikolas


Was generative AI tooling used to co-author this PR?
  • Yes (Claude Code - Opus 4.6)

  • Read the Pull Request Guidelines for more information. Note: commit author/co-author name and email in commits become permanently public when merged.
  • For fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
  • When adding dependency, check compliance with the ASF 3rd Party License Policy.
  • For significant user-facing changes create newsfragment: {pr_number}.significant.rst, in airflow-core/newsfragments. You can add this file in a follow-up commit after the PR is created so you know the PR number.

When core.multi_team is enabled, the triggerer's polling queries now
filter triggers by team_name. A team-scoped triggerer (--team-name X)
only picks up triggers with team_name='X', while a global triggerer
(no --team-name) only picks up triggers with team_name IS NULL.

When core.multi_team is disabled, no filtering is applied and queries
remain unchanged from the non-multi-team path. This handles the edge
case where multi-team is disabled after triggers were already created
with a team assignment, so those triggers are still picked up rather
than orphaned.

Team and queue filters combine as AND conditions.
@ramitkataria ramitkataria force-pushed the ramitkataria/mt/trigger-queries branch from 063e722 to 8182f40 Compare May 26, 2026 00:56
@vincbeck vincbeck merged commit dfdcf02 into apache:main May 26, 2026
79 checks passed
@vincbeck vincbeck deleted the ramitkataria/mt/trigger-queries branch May 26, 2026 19:13
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants