[
https://issues.apache.org/jira/browse/AIRFLOW-4414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869778#comment-16869778
]
ASF GitHub Bot commented on AIRFLOW-4414:
-----------------------------------------
ashb commented on pull request #5276: [AIRFLOW-4414] AWSAthenaOperator: Push
QueryExecutionID to XCom
URL: https://github.com/apache/airflow/pull/5276
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
> 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
> Priority: Minor
>
> 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)
