[GitHub] [airflow] VladaZakharova commented on pull request #33308: Fix impersonate beam condition lower than 2.39.0 always evaluating true

Fri, 11 Aug 2023 00:14:05 -0700 


VladaZakharova commented on PR #33308:
URL: https://github.com/apache/airflow/pull/33308#issuecomment-1674303777

   Hi Team!
   I was not really suspicious about this condition on Beam version, because 
for me, even using version 2.46.0 didn't cause any errors at all:
   ![Screenshot 2023-08-11 09 10 
54](https://github.com/apache/airflow/assets/80038284/b4fa175d-f161-4c53-843d-7e043b96a5b3)
   
   Please, correct me if i am running the operator not in correct way to 
reproduce the error:
   ```
    start_python_pipeline_dataflow_runner = BeamRunPythonPipelineOperator(
           task_id="start_python_pipeline_dataflow_runner",
           runner="DataflowRunner",
           py_file=GCS_PYTHON_SCRIPT,
           pipeline_options={
               "tempLocation": GCS_TMP,
               "stagingLocation": GCS_STAGING,
               "output": GCS_OUTPUT,
           },
           py_options=[],
           py_requirements=["apache-beam[gcp]==2.46.0"],
           py_interpreter="python3",
           py_system_site_packages=False,
           dataflow_config=DataflowConfiguration(
               job_name="{{task.task_id}}", project_id=GCP_PROJECT_ID, 
location="us-central1"
           ),
           deferrable=True,
       )
   ```


-- 
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.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to