uranusjr commented on code in PR #47677:
URL: https://github.com/apache/airflow/pull/47677#discussion_r1992945608
##########
task-sdk/tests/task_sdk/execution_time/test_task_runner.py:
##########
@@ -864,18 +832,7 @@ def test_run_with_asset_inlets(create_runtime_ti,
mock_supervisor_comms):
AssetProfile(name="name", uri="s3://bucket/my-task",
type="Asset"),
AssetProfile(name="new-name", uri="s3://bucket/my-task",
type="Asset"),
],
- outlet_events=[
- {
- "asset_alias_events": [],
- "extra": {},
- "key": {"name": "name", "uri": "s3://bucket/my-task"},
- },
- {
- "asset_alias_events": [],
- "extra": {},
- "key": {"name": "new-name", "uri":
"s3://bucket/my-task"},
- },
- ],
+ outlet_events=[],
Review Comment:
`outlet_events` now only include entries that don’t have the default extra.
None of these have custom extras so they are not included in this list anymore.
There is a test making sure outlets without an entry in `outlet_events` are
still emitted correctly.
--
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]
