Ritika-Singhal edited a comment on issue #21348:
URL: https://github.com/apache/airflow/issues/21348#issuecomment-1030723900


   #19787 requires one additional fix in here: 
   
https://github.com/apache/airflow/blob/providers-amazon/3.0.0rc1/airflow/providers/amazon/aws/operators/glue.py
 
   Need to modify the default value of `num_of_dpus` to `None` (which is 
currently set to 6). 
   
   Without this fix, it becomes inconsistent with the logic changed in the 
[airflow/providers/amazon/aws/hooks/glue.py](https://github.com/apache/airflow/pull/19787/files#diff-039a9f654ab15c81177e8747d7dd210768a6c3dcb5404be66f4e3c3a7b732c6a).
 It then gives the error to the user if user doesn't specify `num_of_dpus=None`
   
   ` File 
"/Users/ritika/opt/anaconda3/lib/python3.7/site-packages/airflow/models/taskinstance.py",
 line 1511, in _execute_task
       result = execute_callable(context=context)
     File 
"/Users/ritika/opt/anaconda3/lib/python3.7/site-packages/airflow/providers/amazon/aws/operators/glue.py",
 line 123, in execute
       create_job_kwargs=self.create_job_kwargs,
     File 
"/Users/ritika/opt/anaconda3/lib/python3.7/site-packages/airflow/providers/amazon/aws/hooks/glue.py",
 line 74, in __init__
       raise ValueError("Cannot specify num_of_dpus with custom WorkerType")
   ValueError: Cannot specify num_of_dpus with custom WorkerType
   [2022-02-05, 16:57:41 UTC] {local_task_job.py:154} INFO - Task exited with 
return code 1`


-- 
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: commits-unsubscr...@airflow.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to