jscheffl commented on issue #37577: URL: https://github.com/apache/airflow/issues/37577#issuecomment-1963045271
I did a regression and can confirm the analysis you made. Problem is that the expansion makes a lazy XCom resolution and this requires airflow codebase and XCom database access - thus both airflow python code and correct DB connection string needs to be there. I can also confirm that your proposed workaround to put a PythonOperator in between resolves the problem as this would do the lazy aggregate. If not easily to be fixed I'd propose the documentation should mention this at least. Current restrictions of XCom in KPO are solely about how XCom is passed outof the operator but no statement about the inpout in case of task maping aggregation / lazy XCom restriction. -- 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]
