Move sandbox normalization helpers to private module

Keep shared on-demand sandbox normalization logic out of the public client and declaration modules by centralizing it in a private normalization module.

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

Author: YunchuWang

durabletask-azuremanaged/durabletask/azuremanaged/preview/on_demand_sandbox/_normalization.py

@@ -0,0 +1,22 @@
+# Copyright (c) Microsoft Corporation.
+# Licensed under the MIT License.
+
+from typing import Iterable, Optional
+
+
+def _normalize_required(value: Optional[str], message: str) -> str:
+    if not value or not value.strip():
+        raise ValueError(message)
+    return value.strip()
+
+
+def _resolve_activity_names(activity_names: str | Iterable[str]) -> list[str]:
+    resolved: list[str] = []
+    seen: set[str] = set()
+    names = [activity_names] if isinstance(activity_names, str) else activity_names
+    for name in names:
+        normalized = name.strip()
+        if normalized and normalized not in seen:
+            resolved.append(normalized)
+            seen.add(normalized)
+    return resolved

durabletask-azuremanaged/durabletask/azuremanaged/preview/on_demand_sandbox/client.py

@@ -6,9 +6,9 @@
 import grpc
 from azure.core.credentials import TokenCredential
 
+from durabletask.azuremanaged.preview.on_demand_sandbox._normalization import _normalize_required
 from durabletask.azuremanaged.preview.on_demand_sandbox.declarations import (
     _build_profile_on_demand_sandbox_activity_declarations,
-    _normalize_required,
 )
 from durabletask.azuremanaged.preview.on_demand_sandbox.transport import (
     OnDemandSandboxActivitiesGrpcTransport,

durabletask-azuremanaged/durabletask/azuremanaged/preview/on_demand_sandbox/declarations.py

@@ -7,6 +7,10 @@
 
 from durabletask import task
 from durabletask.azuremanaged.internal import on_demand_sandbox_activities_service_pb2 as pb
+from durabletask.azuremanaged.preview.on_demand_sandbox._normalization import (
+    _normalize_required,
+    _resolve_activity_names,
+)
 
 
 DEFAULT_WORKER_PROFILE_ID = "default"
@@ -79,18 +83,6 @@ def decorator(cls: type) -> type:
     return decorator
 
 
-def _resolve_activity_names(activity_names: str | Iterable[str]) -> list[str]:
-    resolved: list[str] = []
-    seen: set[str] = set()
-    names = [activity_names] if isinstance(activity_names, str) else activity_names
-    for name in names:
-        normalized = name.strip()
-        if normalized and normalized not in seen:
-            resolved.append(normalized)
-            seen.add(normalized)
-    return resolved
-
-
 def _build_on_demand_sandbox_activity_declaration(
         *,
         activity_names: str | Iterable[str],
@@ -230,12 +222,6 @@ def _normalize_optional_strings(values: Iterable[str]) -> list[str]:
     return [value.strip() for value in values if value and value.strip()]
 
 
-def _normalize_required(value: Optional[str], message: str) -> str:
-    if not value or not value.strip():
-        raise ValueError(message)
-    return value.strip()
-
-
 def _normalize_cpu(value: str) -> str:
     normalized = _normalize_required(value, "On-demand sandbox activity declaration requires CPU resources.")
     milli_cpu = _try_parse_cpu_millicores(normalized)

durabletask-azuremanaged/durabletask/azuremanaged/preview/on_demand_sandbox/worker.py

@@ -9,12 +9,12 @@
 
 from azure.identity import ManagedIdentityCredential
 
+from durabletask.azuremanaged.preview.on_demand_sandbox._normalization import _resolve_activity_names
 from durabletask.azuremanaged.preview.on_demand_sandbox.declarations import (
     DEFAULT_MAX_CONCURRENT_ACTIVITIES,
     DEFAULT_WORKER_PROFILE_ID,
     _build_on_demand_sandbox_worker_heartbeat,
     _build_on_demand_sandbox_worker_start,
-    _resolve_activity_names,
 )
 from durabletask.azuremanaged.preview.on_demand_sandbox.transport import (
     OnDemandSandboxActivitiesGrpcTransport,