GitHub user Snaptonis added a comment to the discussion: Serialization issues with external_python decorator
Thank you for your answer. Regarding `can't pickle local object`, get_config is a @task() that returns a dict, where the values are read from the dag params. The resulting XCom is then passed to an external_python task that is expanded with partial args. So far so good. But the next task, which is also external and uses the XCom created by the prior task, fails. So the tasks never use get_config() but only the result of it. Same goes for the connection, the @task() only returns a dict that is used by following tasks. GitHub link: https://github.com/apache/airflow/discussions/71281#discussioncomment-17961481 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected]
