使用xcom_pull()方法来提取任务中的job_id, task_id和task_state，并确保正确传递operator对象的task_id参数。示例如下：

在PythonOperator中：

def my_func(**context): #执行BigqueryOperator op = BigQueryOperator( task_id='my_task_id', ... ) task_id = op.task_id context['task_instance'].xcom_push(key='task_id', value=task_id)

在另一个任务中提取job_id, task_id和task_state：

def my_other_func(**context): task_id = context['task_instance'].xcom_pull(key='task_id') ti = TaskInstance(task_id, dag_id=) job_id = ti.xcom_pull(key=None, task_ids='my_task_id', include_prior_dates=True)[0]['job_id'] task_state = ti.xcom_pull(key=None, task_ids='my_task_id', include_prior_dates=True)[0]['state']