Skip to content

Commit 45d37da

Browse files
authored
Increase retries in EmrContainerHook.create_emr_on_eks_cluster (apache#46562)
1 parent b26a5fe commit 45d37da

File tree

1 file changed

+3
-3
lines changed
  • providers/src/airflow/providers/amazon/aws/hooks

1 file changed

+3
-3
lines changed

providers/src/airflow/providers/amazon/aws/hooks/emr.py

+3-3
Original file line numberDiff line numberDiff line change
@@ -362,11 +362,11 @@ def __init__(self, *args: Any, virtual_cluster_id: str | None = None, **kwargs:
362362
# Retry this method when the ``create_virtual_cluster`` raises
363363
# "Cluster XXX is not reachable as its connection is currently being updated".
364364
# Even though the EKS cluster status is ``ACTIVE``, ``create_virtual_cluster`` can raise this error.
365-
# Retrying is the only option.
365+
# Retrying is the only option. Retry up to 3 minutes
366366
@tenacity.retry(
367367
retry=retry_if_exception(is_connection_being_updated_exception),
368-
stop=stop_after_attempt(5),
369-
wait=wait_fixed(10),
368+
stop=stop_after_attempt(12),
369+
wait=wait_fixed(15),
370370
)
371371
def create_emr_on_eks_cluster(
372372
self,

0 commit comments

Comments
 (0)