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