You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@airflow.apache.org by "Tomasz (JIRA)" <ji...@apache.org> on 2019/06/11 15:01:00 UTC

[jira] [Created] (AIRFLOW-4765) Recursion error in DataProcPigOperator

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)