From 8483b2ccaac5e65dd7fec3edf46e5e0813f2484b Mon Sep 17 00:00:00 2001 From: pierrejeambrun Date: Thu, 22 May 2025 14:14:09 +0200 Subject: [PATCH] Fix default deferable hook for cloud provider --- .../src/airflow/providers/google/cloud/operators/pubsub.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/providers/google/src/airflow/providers/google/cloud/operators/pubsub.py b/providers/google/src/airflow/providers/google/cloud/operators/pubsub.py index c7ca9e3e64951..ba2703dce4803 100644 --- a/providers/google/src/airflow/providers/google/cloud/operators/pubsub.py +++ b/providers/google/src/airflow/providers/google/cloud/operators/pubsub.py @@ -40,6 +40,7 @@ SchemaSettings, ) +from airflow.configuration import conf from airflow.exceptions import AirflowException from airflow.providers.google.cloud.hooks.pubsub import PubSubHook from airflow.providers.google.cloud.links.pubsub import PubSubSubscriptionLink, PubSubTopicLink @@ -770,7 +771,7 @@ def __init__( messages_callback: Callable[[list[ReceivedMessage], Context], Any] | None = None, gcp_conn_id: str = "google_cloud_default", impersonation_chain: str | Sequence[str] | None = None, - deferrable: bool = False, + deferrable: bool = conf.getboolean("operators", "default_deferrable", fallback=False), poll_interval: int = 300, **kwargs, ) -> None: