Adding a compat shim for secrets_masker that was moved to shared

task-sdk/src/airflow/sdk/execution_time/secrets_masker.py

@@ -0,0 +1,45 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+
+"""
+Compatibility module for secrets_masker.
+
+This module provides backward compatibility for providers that still import
+from airflow.sdk.execution_time.secrets_masker. The actual implementation
+has been moved to airflow.sdk._shared.secrets_masker.
+"""
+
+from __future__ import annotations
+
+import warnings
+
+warnings.warn(
+    "Importing from 'airflow.sdk.execution_time.secrets_masker' is deprecated and will be removed in a future version. "
+    "Please use 'airflow.sdk._shared.secrets_masker' instead.",
+    DeprecationWarning,
+    stacklevel=2,
+)
+
+
+def __getattr__(name: str):
+    """Dynamically import attributes from the shared secrets_masker location."""
+    try:
+        import airflow.sdk._shared.secrets_masker as new_module
+
+        return getattr(new_module, name)
+    except AttributeError:
+        raise AttributeError(f"module '{__name__}' has no attribute '{name}'")