misc: specify remove date for deprecations warnings (#63505)

olegkachur-e · Oleg Kachur · web-flow · commit 059e9a40ecbd · 2026-03-26T21:47:49.000+02:00
Co-authored-by: Oleg Kachur &lt;kachur@google.com&gt;
diff --git a/providers/google/src/airflow/providers/google/cloud/hooks/dataflow.py b/providers/google/src/airflow/providers/google/cloud/hooks/dataflow.py
@@ -708,7 +708,7 @@ def start_template_dataflow(
 
         if on_new_job_id_callback:
             warnings.warn(
-                "on_new_job_id_callback is Deprecated. Please start using on_new_job_callback",
+                "on_new_job_id_callback is Deprecated. Please start using on_new_job_callback. Planned removal date: October 5, 2026.",
                 AirflowProviderDeprecationWarning,
                 stacklevel=3,
             )
@@ -885,7 +885,7 @@ def start_flex_template(
 
         if on_new_job_id_callback:
             warnings.warn(
-                "on_new_job_id_callback is Deprecated. Please start using on_new_job_callback",
+                "on_new_job_id_callback is Deprecated. Please start using on_new_job_callback. Planned removal date: October 5, 2026.",
                 AirflowProviderDeprecationWarning,
                 stacklevel=3,
             )
@@ -1067,7 +1067,7 @@ def is_job_dataflow_running(
         if variables:
             warnings.warn(
                 "The variables parameter has been deprecated. You should pass project_id using "
-                "the project_id parameter.",
+                "the project_id parameter. Planned removal date: October 5, 2026.",
                 AirflowProviderDeprecationWarning,
                 stacklevel=4,
             )
@@ -1076,7 +1076,7 @@ def is_job_dataflow_running(
             location = DEFAULT_DATAFLOW_LOCATION
             warnings.warn(
                 "The location argument will be become mandatory in future versions, "
-                f"currently, it defaults to {DEFAULT_DATAFLOW_LOCATION}, please set the location explicitly.",
+                f"currently, it defaults to {DEFAULT_DATAFLOW_LOCATION}, please set the location explicitly. Planned removal date: October 5, 2026.",
                 AirflowProviderDeprecationWarning,
                 stacklevel=4,
             )
diff --git a/providers/google/src/airflow/providers/google/cloud/hooks/gcs.py b/providers/google/src/airflow/providers/google/cloud/hooks/gcs.py
@@ -776,7 +776,7 @@ def list(
         """
         if delimiter and delimiter != "/":
             warnings.warn(
-                "Usage of 'delimiter' param is deprecated, please use 'match_glob' instead",
+                "Usage of 'delimiter' param is deprecated, please use 'match_glob' instead. Planned removal date: October 5, 2026.",
                 AirflowProviderDeprecationWarning,
                 stacklevel=2,
             )
diff --git a/providers/google/src/airflow/providers/google/cloud/hooks/pubsub.py b/providers/google/src/airflow/providers/google/cloud/hooks/pubsub.py
@@ -165,7 +165,7 @@ def _validate_messages(messages) -> None:
                     b64decode(message["data"])
                     warnings.warn(
                         "The base 64 encoded string as 'data' field has been deprecated. "
-                        "You should pass bytestring (utf-8 encoded).",
+                        "You should pass bytestring (utf-8 encoded). Planned removal date: October 5, 2026.",
                         AirflowProviderDeprecationWarning,
                         stacklevel=4,
                     )
diff --git a/providers/google/src/airflow/providers/google/cloud/links/dataproc.py b/providers/google/src/airflow/providers/google/cloud/links/dataproc.py
@@ -41,7 +41,7 @@ def __getattr__(name: str) -> Any:
         warnings.warn(
             (
                 "DATAPROC_JOB_LOG_LINK has been deprecated and will be removed in the next MAJOR release."
-                " Please use DATAPROC_JOB_LINK instead"
+                " Please use DATAPROC_JOB_LINK instead. Planned removal date: October 5, 2026."
             ),
             AirflowProviderDeprecationWarning,
             stacklevel=2,
diff --git a/providers/google/src/airflow/providers/google/cloud/log/stackdriver_task_handler.py b/providers/google/src/airflow/providers/google/cloud/log/stackdriver_task_handler.py
@@ -113,7 +113,7 @@ def __init__(
         if name is not NOTSET:
             warnings.warn(
                 "Param `name` is deprecated and will be removed in a future release. "
-                "Please use `gcp_log_name` instead. ",
+                "Please use `gcp_log_name` instead. Planned removal date: October 5, 2026.",
                 AirflowProviderDeprecationWarning,
                 stacklevel=2,
             )
diff --git a/providers/google/src/airflow/providers/google/cloud/operators/dataproc.py b/providers/google/src/airflow/providers/google/cloud/operators/dataproc.py
@@ -669,7 +669,7 @@ def __init__(
                 f"Passing cluster parameters by keywords to `{type(self).__name__}` will be deprecated. "
                 "Please provide cluster_config object using `cluster_config` parameter. "
                 "You can use `airflow.dataproc.ClusterGenerator.generate_cluster` "
-                "method to obtain cluster object.",
+                "method to obtain cluster object. Planned removal date: October 5, 2026.",
                 AirflowProviderDeprecationWarning,
                 stacklevel=2,
             )
diff --git a/providers/google/src/airflow/providers/google/cloud/operators/gcs.py b/providers/google/src/airflow/providers/google/cloud/operators/gcs.py
@@ -231,7 +231,7 @@ def __init__(
         self.prefix = prefix
         if delimiter:
             warnings.warn(
-                "Usage of 'delimiter' is deprecated, please use 'match_glob' instead",
+                "Usage of 'delimiter' is deprecated, please use 'match_glob' instead. Planned removal date: October 5, 2026.",
                 AirflowProviderDeprecationWarning,
                 stacklevel=2,
             )
diff --git a/providers/google/src/airflow/providers/google/cloud/operators/kubernetes_engine.py b/providers/google/src/airflow/providers/google/cloud/operators/kubernetes_engine.py
@@ -459,7 +459,7 @@ def _alert_deprecated_body_fields(self) -> None:
         for deprecated_field, replacement in deprecated_body_fields_with_replacement:
             if self._body_field(deprecated_field):
                 warnings.warn(
-                    f"The body field '{deprecated_field}' is deprecated. Use '{replacement}' instead.",
+                    f"The body field '{deprecated_field}' is deprecated. Use '{replacement}' instead. Planned removal date: October 5, 2026.",
                     AirflowProviderDeprecationWarning,
                     stacklevel=2,
                 )
diff --git a/providers/google/src/airflow/providers/google/cloud/sensors/bigquery.py b/providers/google/src/airflow/providers/google/cloud/sensors/bigquery.py
@@ -82,7 +82,7 @@ def __init__(
                 kwargs["poke_interval"] = kwargs["polling_interval"]
                 warnings.warn(
                     "Argument `poll_interval` is deprecated and will be removed "
-                    "in a future release.  Please use `poke_interval` instead.",
+                    "in a future release.  Please use `poke_interval` instead. Planned removal date: October 5, 2026.",
                     AirflowProviderDeprecationWarning,
                     stacklevel=2,
                 )
diff --git a/providers/google/src/airflow/providers/google/cloud/transfers/azure_fileshare_to_gcs.py b/providers/google/src/airflow/providers/google/cloud/transfers/azure_fileshare_to_gcs.py
@@ -105,7 +105,7 @@ def __init__(
         if self.directory_path is None and self.directory_name is not None:
             self.directory_path = self.directory_name
             warnings.warn(
-                "Use 'directory_path' instead of 'directory_name'.",
+                "Use 'directory_path' instead of 'directory_name'. Planned removal date: October 5, 2026.",
                 AirflowProviderDeprecationWarning,
                 stacklevel=2,
             )
diff --git a/providers/google/src/airflow/providers/google/cloud/transfers/bigquery_to_mssql.py b/providers/google/src/airflow/providers/google/cloud/transfers/bigquery_to_mssql.py
@@ -68,7 +68,7 @@ def __init__(
     ) -> None:
         if mssql_table is not None:
             warnings.warn(
-                "The `mssql_table` parameter has been deprecated. Use `target_table_name` instead.",
+                "The `mssql_table` parameter has been deprecated. Use `target_table_name` instead. Planned removal date: October 5, 2026.",
                 AirflowProviderDeprecationWarning,
                 stacklevel=2,
             )
diff --git a/providers/google/src/airflow/providers/google/cloud/transfers/gcs_to_gcs.py b/providers/google/src/airflow/providers/google/cloud/transfers/gcs_to_gcs.py
@@ -206,14 +206,14 @@ def __init__(
         self.source_bucket = source_bucket
         if source_object and WILDCARD in source_object:
             warnings.warn(
-                "Usage of wildcard (*) in 'source_object' is deprecated, utilize 'match_glob' instead",
+                "Usage of wildcard (*) in 'source_object' is deprecated, utilize 'match_glob' instead. Planned removal date: October 5, 2026.",
                 AirflowProviderDeprecationWarning,
                 stacklevel=2,
             )
         self.source_object = source_object
         if source_objects and any(WILDCARD in obj for obj in source_objects):
             warnings.warn(
-                "Usage of wildcard (*) in 'source_objects' is deprecated, utilize 'match_glob' instead",
+                "Usage of wildcard (*) in 'source_objects' is deprecated, utilize 'match_glob' instead. Planned removal date: October 5, 2026.",
                 AirflowProviderDeprecationWarning,
                 stacklevel=2,
             )
@@ -222,7 +222,7 @@ def __init__(
         self.destination_object = destination_object
         if delimiter:
             warnings.warn(
-                "Usage of 'delimiter' is deprecated, please use 'match_glob' instead",
+                "Usage of 'delimiter' is deprecated, please use 'match_glob' instead. Planned removal date: October 5, 2026.",
                 AirflowProviderDeprecationWarning,
                 stacklevel=2,
             )
diff --git a/providers/google/src/airflow/providers/google/cloud/triggers/kubernetes_engine.py b/providers/google/src/airflow/providers/google/cloud/triggers/kubernetes_engine.py
@@ -114,7 +114,7 @@ def __init__(
 
         if should_delete_pod is not None:
             warnings.warn(
-                "`should_delete_pod` parameter is deprecated, please use `on_finish_action`",
+                "`should_delete_pod` parameter is deprecated, please use `on_finish_action`. Planned removal date: October 5, 2026.",
                 AirflowProviderDeprecationWarning,
                 stacklevel=2,
             )
@@ -294,7 +294,7 @@ def __init__(
     @property
     def pod_name(self):
         warnings.warn(
-            "`pod_name` parameter is deprecated, please use `pod_names`",
+            "`pod_name` parameter is deprecated, please use `pod_names`. Planned removal date: October 5, 2026.",
             AirflowProviderDeprecationWarning,
             stacklevel=2,
         )

Original file line number	Diff line number	Diff line change
`@@ -776,7 +776,7 @@ def list(`
`776`	`776`	`"""`
`777`	`777`	`if delimiter and delimiter != "/":`
`778`	`778`	`warnings.warn(`
`779`		`- "Usage of 'delimiter' param is deprecated, please use 'match_glob' instead",`
	`779`	`+ "Usage of 'delimiter' param is deprecated, please use 'match_glob' instead. Planned removal date: October 5, 2026.",`
`780`	`780`	`AirflowProviderDeprecationWarning,`
`781`	`781`	`stacklevel=2,`
`782`	`782`	`)`
Original file line number	Diff line number	Diff line change
`@@ -165,7 +165,7 @@ def _validate_messages(messages) -> None:`
`165`	`165`	`b64decode(message["data"])`
`166`	`166`	`warnings.warn(`
`167`	`167`	`"The base 64 encoded string as 'data' field has been deprecated. "`
`168`		`- "You should pass bytestring (utf-8 encoded).",`
	`168`	`+ "You should pass bytestring (utf-8 encoded). Planned removal date: October 5, 2026.",`
`169`	`169`	`AirflowProviderDeprecationWarning,`
`170`	`170`	`stacklevel=4,`
`171`	`171`	`)`
Original file line number	Diff line number	Diff line change
`@@ -41,7 +41,7 @@ def __getattr__(name: str) -> Any:`
`41`	`41`	`warnings.warn(`
`42`	`42`	`(`
`43`	`43`	`"DATAPROC_JOB_LOG_LINK has been deprecated and will be removed in the next MAJOR release."`
`44`		`- " Please use DATAPROC_JOB_LINK instead"`
	`44`	`+ " Please use DATAPROC_JOB_LINK instead. Planned removal date: October 5, 2026."`
`45`	`45`	`),`
`46`	`46`	`AirflowProviderDeprecationWarning,`
`47`	`47`	`stacklevel=2,`
Original file line number	Diff line number	Diff line change
`@@ -113,7 +113,7 @@ def __init__(`
`113`	`113`	`if name is not NOTSET:`
`114`	`114`	`warnings.warn(`
`115`	`115`	"Param `name` is deprecated and will be removed in a future release. "
`116`		- "Please use `gcp_log_name` instead. ",
	`116`	+ "Please use `gcp_log_name` instead. Planned removal date: October 5, 2026.",
`117`	`117`	`AirflowProviderDeprecationWarning,`
`118`	`118`	`stacklevel=2,`
`119`	`119`	`)`
Original file line number	Diff line number	Diff line change
`@@ -669,7 +669,7 @@ def __init__(`
`669`	`669`	f"Passing cluster parameters by keywords to `{type(self).__name__}` will be deprecated. "
`670`	`670`	"Please provide cluster_config object using `cluster_config` parameter. "
`671`	`671`	"You can use `airflow.dataproc.ClusterGenerator.generate_cluster` "
`672`		`- "method to obtain cluster object.",`
	`672`	`+ "method to obtain cluster object. Planned removal date: October 5, 2026.",`
`673`	`673`	`AirflowProviderDeprecationWarning,`
`674`	`674`	`stacklevel=2,`
`675`	`675`	`)`
Original file line number	Diff line number	Diff line change
`@@ -231,7 +231,7 @@ def __init__(`
`231`	`231`	`self.prefix = prefix`
`232`	`232`	`if delimiter:`
`233`	`233`	`warnings.warn(`
`234`		`- "Usage of 'delimiter' is deprecated, please use 'match_glob' instead",`
	`234`	`+ "Usage of 'delimiter' is deprecated, please use 'match_glob' instead. Planned removal date: October 5, 2026.",`
`235`	`235`	`AirflowProviderDeprecationWarning,`
`236`	`236`	`stacklevel=2,`
`237`	`237`	`)`
Original file line number	Diff line number	Diff line change
`@@ -459,7 +459,7 @@ def _alert_deprecated_body_fields(self) -> None:`
`459`	`459`	`for deprecated_field, replacement in deprecated_body_fields_with_replacement:`
`460`	`460`	`if self._body_field(deprecated_field):`
`461`	`461`	`warnings.warn(`
`462`		`- f"The body field '{deprecated_field}' is deprecated. Use '{replacement}' instead.",`
	`462`	`+ f"The body field '{deprecated_field}' is deprecated. Use '{replacement}' instead. Planned removal date: October 5, 2026.",`
`463`	`463`	`AirflowProviderDeprecationWarning,`
`464`	`464`	`stacklevel=2,`
`465`	`465`	`)`
Original file line number	Diff line number	Diff line change
`@@ -82,7 +82,7 @@ def __init__(`
`82`	`82`	`kwargs["poke_interval"] = kwargs["polling_interval"]`
`83`	`83`	`warnings.warn(`
`84`	`84`	"Argument `poll_interval` is deprecated and will be removed "
`85`		- "in a future release. Please use `poke_interval` instead.",
	`85`	+ "in a future release. Please use `poke_interval` instead. Planned removal date: October 5, 2026.",
`86`	`86`	`AirflowProviderDeprecationWarning,`
`87`	`87`	`stacklevel=2,`
`88`	`88`	`)`
Original file line number	Diff line number	Diff line change
`@@ -105,7 +105,7 @@ def __init__(`
`105`	`105`	`if self.directory_path is None and self.directory_name is not None:`
`106`	`106`	`self.directory_path = self.directory_name`
`107`	`107`	`warnings.warn(`
`108`		`- "Use 'directory_path' instead of 'directory_name'.",`
	`108`	`+ "Use 'directory_path' instead of 'directory_name'. Planned removal date: October 5, 2026.",`
`109`	`109`	`AirflowProviderDeprecationWarning,`
`110`	`110`	`stacklevel=2,`
`111`	`111`	`)`