Skip to content

Add team_name column to trigger table for multi-team triggerer support#67305

Open
ramitkataria wants to merge 2 commits into
apache:mainfrom
aws-mwaa:ramitkataria/mt/trigger-db
Open

Add team_name column to trigger table for multi-team triggerer support#67305
ramitkataria wants to merge 2 commits into
apache:mainfrom
aws-mwaa:ramitkataria/mt/trigger-db

Conversation

@ramitkataria
Copy link
Copy Markdown
Contributor

Adds a nullable team_name column (FK -> team.name, ondelete=SET NULL) with an index to the trigger table. This is the schema foundation for team-scoped triggerer instances. Follow-up PRs will populate the column at trigger creation time and add query filtering so each triggerer only processes its team's triggers.

When a team is deleted, in-flight triggers become global (NULL) and are picked up by the global triggerer to run to completion.

No behavioral change, this PR only adds the column, migration, and constructor parameter.


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.

Adds a nullable `team_name` column (FK -> team.name, ondelete=SET NULL) with
an index to the trigger table. This is the schema foundation for team-scoped
triggerer instances. Follow-up PRs will populate the column at trigger
creation time and add query filtering so each triggerer only processes its
team's triggers.

When a team is deleted, in-flight triggers become global (NULL) and are
picked up by the global triggerer to run to completion.

No behavioral change, this PR only adds the column, migration, and
constructor parameter.
@ramitkataria
Copy link
Copy Markdown
Contributor Author

cc @vincbeck @o-nikolas

Comment thread airflow-core/src/airflow/models/trigger.py
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