def context_to_airflow_vars(context):
 params = dict()
 dag = context.get('dag')
 if (dag and dag.dag_id):
  params['airflow.ctx.dag.dag_id'] = dag.dag_id
 dag_run = context.get('dag_run')
 if (dag_run and dag_run.execution_date):
  params['airflow.ctx.dag_run.execution_date'] = dag_run.execution_date.isoformat()
 task = context.get('task')
 if (task and task.task_id):
  params['airflow.ctx.task.task_id'] = task.task_id
 task_instance = context.get('task_instance')
 if (task_instance and task_instance.execution_date):
  params['airflow.ctx.task_instance.execution_date'] = task_instance.execution_date.isoformat()
 return params

def context_to_airflow_vars ( context ) : params = dict ( ) dag = context . get ( 'dag' ) if ( dag and dag . dag_id ) : params [ 'airflow.ctx.dag.dag_id' ] = dag . dag_id dag_run = context . get ( 'dag_run' ) if ( dag_run and dag_run . execution_date ) : params [ 'airflow.ctx.dag_run.execution_date' ] = dag_run . execution_date . isoformat ( ) task = context . get ( 'task' ) if ( task and task . task_id ) : params [ 'airflow.ctx.task.task_id' ] = task . task_id task_instance = context . get ( 'task_instance' ) if ( task_instance and task_instance . execution_date ) : params [ 'airflow.ctx.task_instance.execution_date' ] = task_instance . execution_date . isoformat ( ) return params
given a context .