Marek Suppa created AIRFLOW-4414:
------------------------------------
Summary: AWSAthenaOperator does not push QueryExecutionID to XCom
Key: AIRFLOW-4414
URL: https://issues.apache.org/jira/browse/AIRFLOW-4414
Project: Apache Airflow
Issue Type: Improvement
Components: aws
Reporter: Marek Suppa
Assignee: Marek Suppa
AWSAthenaOperator should make it easy to push QueryExecutionID to XCom which it
currently does not. The best way of achieving that would currently most
probably be
{code}
class MyAWSAthenaOperator(AWSAthenaOperator):
def execute(self, context):
super(MyAWSAthenaOperator, self).execute(context)
# just so that this gets `xcom_push`(ed)
return self.query_execution_id
{code}
The fix should be as simple as adding {code}return
self.query_execution_id{code} at the end of {{execute}} function.
I will add that as part of this task.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
