diff --git a/astronomer/providers/google/cloud/operators/dataproc.py b/astronomer/providers/google/cloud/operators/dataproc.py index 8c4dc17b3..fd455aa4b 100644 --- a/astronomer/providers/google/cloud/operators/dataproc.py +++ b/astronomer/providers/google/cloud/operators/dataproc.py @@ -60,9 +60,8 @@ def __init__( DeprecationWarning, stacklevel=2, ) + kwargs["polling_interval_seconds"] = polling_interval super().__init__(deferrable=True, **kwargs) - - self.polling_interval = polling_interval if self.timeout is None: self.timeout: float = 24 * 60 * 60 @@ -109,7 +108,7 @@ def __init__( DeprecationWarning, stacklevel=2, ) + kwargs["polling_interval_seconds"] = polling_interval super().__init__(deferrable=True, **kwargs) - self.polling_interval = polling_interval if self.timeout is None: self.timeout: float = 24 * 60 * 60