This is an automated email from the ASF dual-hosted git repository.
Lee-W pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 80797faf6d0 Fix incorrect documented defaults in Amazon operators and
sensors (#72315)
80797faf6d0 is described below
commit 80797faf6d00d2d5d18ba0f2877073019a2cbbb8
Author: PoAn Yang <[email protected]>
AuthorDate: Mon Sep 7 16:16:54 2026 +0900
Fix incorrect documented defaults in Amazon operators and sensors (#72315)
Signed-off-by: PoAn Yang <[email protected]>
---
.../amazon/src/airflow/providers/amazon/aws/operators/bedrock.py | 2 +-
providers/amazon/src/airflow/providers/amazon/aws/operators/glue.py | 2 +-
providers/amazon/src/airflow/providers/amazon/aws/operators/sqs.py | 2 +-
providers/amazon/src/airflow/providers/amazon/aws/sensors/bedrock.py | 4 ++--
4 files changed, 5 insertions(+), 5 deletions(-)
diff --git
a/providers/amazon/src/airflow/providers/amazon/aws/operators/bedrock.py
b/providers/amazon/src/airflow/providers/amazon/aws/operators/bedrock.py
index 71fa6bf1dd1..62e49872f65 100644
--- a/providers/amazon/src/airflow/providers/amazon/aws/operators/bedrock.py
+++ b/providers/amazon/src/airflow/providers/amazon/aws/operators/bedrock.py
@@ -1225,7 +1225,7 @@ class
BedrockBatchInferenceOperator(AwsBaseOperator[BedrockHook]):
NOTE: The way batch inference jobs work, your jobs are added to a
queue and done "eventually"
so using deferrable mode is much more practical than using
wait_for_completion.
:param waiter_delay: Time in seconds to wait between status checks.
(default: 60)
- :param waiter_max_attempts: Maximum number of attempts to check for job
completion. (default: 10)
+ :param waiter_max_attempts: Maximum number of attempts to check for job
completion. (default: 20)
:param deferrable: If True, the operator will wait asynchronously for the
cluster to stop.
This implies waiting for completion. This mode requires aiobotocore
module to be installed.
(default: False)
diff --git
a/providers/amazon/src/airflow/providers/amazon/aws/operators/glue.py
b/providers/amazon/src/airflow/providers/amazon/aws/operators/glue.py
index c488965ddde..2350dad3596 100644
--- a/providers/amazon/src/airflow/providers/amazon/aws/operators/glue.py
+++ b/providers/amazon/src/airflow/providers/amazon/aws/operators/glue.py
@@ -140,7 +140,7 @@ class GlueJobOperator(ResumableJobMixin,
AwsBaseOperator[GlueJobHook]):
Glue job's ``--conf`` argument so the Glue Spark job sends OL events
to the same backend as Airflow.
Defaults to the ``openlineage.spark_inject_transport_info`` config
value.
:param waiter_delay: Time in seconds to wait between status checks.
(default: 60)
- :param waiter_max_attempts: Maximum number of attempts to check for job
completion. (default: 20)
+ :param waiter_max_attempts: Maximum number of attempts to check for job
completion. (default: 75)
:param resume_glue_job_on_retry: deprecated, use ``durable`` instead.
:param durable: When ``True``, the Glue job run id is persisted to task
state before polling
begins. A worker crash on retry reconnects to the existing run instead
of starting a
diff --git a/providers/amazon/src/airflow/providers/amazon/aws/operators/sqs.py
b/providers/amazon/src/airflow/providers/amazon/aws/operators/sqs.py
index 08d6123eed1..210769dc25f 100644
--- a/providers/amazon/src/airflow/providers/amazon/aws/operators/sqs.py
+++ b/providers/amazon/src/airflow/providers/amazon/aws/operators/sqs.py
@@ -41,7 +41,7 @@ class SqsPublishOperator(AwsBaseOperator[SqsHook]):
:param message_content: The message content (templated)
:param message_attributes: additional attributes for the message (default:
None)
For details of the attributes parameter see
:py:meth:`botocore.client.SQS.send_message`
- :param delay_seconds: message delay (templated) (default: 1 second)
+ :param delay_seconds: message delay (templated) (default: 0 second)
:param message_group_id: This parameter applies only to FIFO
(first-in-first-out) queues. (default: None)
For details of the attributes parameter see
:py:meth:`botocore.client.SQS.send_message`
:param message_deduplication_id: This applies only to FIFO
(first-in-first-out) queues.
diff --git
a/providers/amazon/src/airflow/providers/amazon/aws/sensors/bedrock.py
b/providers/amazon/src/airflow/providers/amazon/aws/sensors/bedrock.py
index 5d00918ec46..e65a35dd62f 100644
--- a/providers/amazon/src/airflow/providers/amazon/aws/sensors/bedrock.py
+++ b/providers/amazon/src/airflow/providers/amazon/aws/sensors/bedrock.py
@@ -407,8 +407,8 @@ class
BedrockBatchInferenceSensor(BedrockBaseSensor[BedrockHook]):
:param deferrable: If True, the sensor will operate in deferrable more.
This mode requires aiobotocore
module to be installed.
(default: False, but can be overridden in config file by setting
default_deferrable to True)
- :param poke_interval: Polling period in seconds to check for the status of
the job. (default: 5)
- :param max_retries: Number of times before returning the current state
(default: 24)
+ :param poke_interval: Polling period in seconds to check for the status of
the job. (default: 120)
+ :param max_retries: Number of times before returning the current state
(default: 75)
:param aws_conn_id: The Airflow connection used for AWS credentials.
If this is ``None`` or empty then the default boto3 behaviour is used.
If
running Airflow in a distributed manner and aws_conn_id is None or
