Tomasz created AIRFLOW-4765:
-------------------------------
Summary: Recursion error in DataProcPigOperator
Key: AIRFLOW-4765
URL: https://issues.apache.org/jira/browse/AIRFLOW-4765
Project: Apache Airflow
Issue Type: Bug
Components: gcp
Affects Versions: 1.10.3
Reporter: Tomasz
Assignee: Tomasz
Fix For: 1.10.4
Recursion error in DataProcPigOperator in execute method:
{code:java}
class DataProcPigOperator(DataProcJobBaseOperator):
...
def execute(self, context):
self.create_job_template()
if self.query is None:
self.job_template.add_query_uri(self.query_uri)
else:
self.job_template.add_query(self.query)
self.job_template.add_variables(self.variables)
self.execute(context) -> super().execute(context){code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
