vincbeck commented on code in PR #68242:
URL: https://github.com/apache/airflow/pull/68242#discussion_r3376071666
##########
airflow-core/src/airflow/assets/manager.py:
##########
@@ -197,9 +197,8 @@ def _filter_dags_by_team(
:param asset_model: the AssetModel whose scheduled_dags carry
allow_producer_teams.
:param source_is_api: True if the event was triggered via the REST API
(not a DAG task).
:param session: SQLAlchemy session.
- :param allow_consumer_teams: list of team names allowed to consume.
Empty/None means no filtering.
- :param allow_global_consumers: whether teamless consumers are allowed.
Only applies when
- allow_consumer_teams is non-empty.
+ :param allow_consumer_teams: list of team names allowed to consume.
None means no team-based filtering.
Review Comment:
Good idea :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
