SoftDed commented on issue #36837:
URL: https://github.com/apache/airflow/issues/36837#issuecomment-1900330806
I've found a workaround for this problem. I can manually create a session:
```
def print_triggering_dataset_events(triggering_dataset_events=None,
**kwargs):
from airflow.utils.session import create_session
with create_session() as session:
<--------------------------------------------------------------------------------------
here
for dataset, dataset_list in triggering_dataset_events.items():
for dataset_event in dataset_list:
print('Task result: ',
dataset_event.source_task_instance.xcom_pull(task_ids='test', session=session))
<------- and here
```
--
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]
