vincbeck commented on code in PR #66487:
URL: https://github.com/apache/airflow/pull/66487#discussion_r3202099383
##########
airflow-core/tests/unit/dag_processing/test_collection.py:
##########
@@ -327,6 +327,45 @@ def test_change_asset_property_sync_extra(self, dag_maker,
session):
assert len(orm_assets) == 1
assert next(iter(orm_assets.values())).extra == {"foo": "new"}
+ @pytest.mark.usefixtures("testing_dag_bundle")
+ def
test_sync_assets_preserves_allow_producer_teams_from_other_bundle(self,
dag_maker, session):
+ """When a producer bundle (without allow_producer_teams) is synced
after a consumer bundle
+ (with allow_producer_teams), the stored allow_producer_teams must not
be wiped out."""
+ from airflow.models.asset import DagScheduleAssetReference
Review Comment:
Sure thing
--
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]
