fix(google): remove unnecessay poll_interval

astronomer · Jan 25, 2024 · 0885926 · 0885926
1 parent ec4880a
commit 0885926
Showing 1 changed file with 0 additions and 10 deletions.
diff --git 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