astro-anand commented on PR #53939:
URL: https://github.com/apache/airflow/pull/53939#issuecomment-3141513167
I've tried updating the _serialize_outlet_events method to use the serialize
function defined in serde.py, but I'm still getting the same error.
```python
def _serialize_outlet_events(events: OutletEventAccessorsProtocol) ->
Iterator[dict[str, Any]]:
from airflow.serialization.serde import serialize
if TYPE_CHECKING:
assert isinstance(events, OutletEventAccessors)
# We just collect everything the user recorded in the accessors.
# Further filtering will be done in the API server.
for key, accessor in events._dict.items():
if isinstance(key, AssetUniqueKey):
yield {"dest_asset_key": attrs.asdict(key), "extra":
serialize(accessor.extra)}
for alias_event in accessor.asset_alias_events:
yield attrs.asdict(alias_event)
```
--
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]
