From 0885926524a46970d12a1e6bc56a81bf51b11fca Mon Sep 17 00:00:00 2001 From: Wei Lee Date: Thu, 25 Jan 2024 18:41:44 +0800 Subject: [PATCH] fix(google): remove unnecessay poll_interval --- .../providers/google/cloud/operators/bigquery.py | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/astronomer/providers/google/cloud/operators/bigquery.py b/astronomer/providers/google/cloud/operators/bigquery.py index 4a6c01446..4ad33feef 100644 --- a/astronomer/providers/google/cloud/operators/bigquery.py +++ b/astronomer/providers/google/cloud/operators/bigquery.py @@ -33,9 +33,7 @@ def __init__(self, *args: Any, **kwargs: Any) -> None: stacklevel=2, ) - poll_interval: float = kwargs.pop("poll_interval", 4.0) super().__init__(*args, deferrable=True, **kwargs) - self.poll_interval = poll_interval class BigQueryCheckOperatorAsync(BigQueryCheckOperator): @@ -55,9 +53,7 @@ def __init__(self, *args: Any, **kwargs: Any) -> None: DeprecationWarning, stacklevel=2, ) - poll_interval: float = kwargs.pop("poll_interval", 4.0) super().__init__(*args, deferrable=True, **kwargs) - self.poll_interval = poll_interval class BigQueryGetDataOperatorAsync(BigQueryGetDataOperator): @@ -77,10 +73,8 @@ def __init__(self, *args: Any, use_legacy_sql: bool = False, **kwargs: Any) -> N DeprecationWarning, stacklevel=2, ) - poll_interval: float = kwargs.pop("poll_interval", 4.0) super().__init__(*args, deferrable=True, **kwargs) self.use_legacy_sql = use_legacy_sql - self.poll_interval = poll_interval class BigQueryIntervalCheckOperatorAsync(BigQueryIntervalCheckOperator): @@ -100,9 +94,7 @@ def __init__(self, *args: Any, **kwargs: Any) -> None: DeprecationWarning, stacklevel=2, ) - poll_interval: float = kwargs.pop("poll_interval", 4.0) super().__init__(*args, deferrable=True, **kwargs) - self.poll_interval = poll_interval class BigQueryValueCheckOperatorAsync(BigQueryValueCheckOperator): @@ -122,6 +114,4 @@ def __init__(self, *args: Any, **kwargs: Any) -> None: DeprecationWarning, stacklevel=2, ) - poll_interval: float = kwargs.pop("poll_interval", 4.0) super().__init__(*args, deferrable=True, **kwargs) - self.poll_interval = poll_interval