- operator result PythonOperator.python_callable push to xcom (with task_id=taskId)
- task_instance is part of context, so it can be paramter of function.
task_instance.xcom_pull() task_instance.xcom_pull(task_ids='task1')