Apply sandbox image proto updates

Author: YunchuWang

durabletask-azuremanaged/durabletask/azuremanaged/internal/SANDBOX_PROTO_SOURCE_COMMIT_HASH

@@ -1 +1 @@
-cd99bc4f734eb9abc5fad49b76eea7a1396f3216
+49a4dea8f9d8f62f026645135ec9bad71b73d7b4

durabletask-azuremanaged/durabletask/azuremanaged/internal/sandbox_service_pb2.py

@@ -52,7 +52,7 @@ class SandboxActivityWorkerSessionResult(_message.Message):
     def __init__(self, message: _Optional[str] = ...) -> None: ...
 
 class SandboxActivityDeclaration(_message.Message):
-    __slots__ = ("worker_profile_id", "activity_names", "image", "environment_variables", "max_concurrent_activities", "resources", "entrypoint", "cmd", "scheduler_managed_identity_client_id")
+    __slots__ = ("worker_profile_id", "activity_names", "image", "environment_variables", "max_concurrent_activities", "resources", "scheduler_managed_identity_client_id")
     class EnvironmentVariablesEntry(_message.Message):
         __slots__ = ("key", "value")
         KEY_FIELD_NUMBER: _ClassVar[int]
@@ -66,27 +66,27 @@ class SandboxActivityDeclaration(_message.Message):
     ENVIRONMENT_VARIABLES_FIELD_NUMBER: _ClassVar[int]
     MAX_CONCURRENT_ACTIVITIES_FIELD_NUMBER: _ClassVar[int]
     RESOURCES_FIELD_NUMBER: _ClassVar[int]
-    ENTRYPOINT_FIELD_NUMBER: _ClassVar[int]
-    CMD_FIELD_NUMBER: _ClassVar[int]
     SCHEDULER_MANAGED_IDENTITY_CLIENT_ID_FIELD_NUMBER: _ClassVar[int]
     worker_profile_id: str
     activity_names: _containers.RepeatedScalarFieldContainer[str]
     image: SandboxActivityImage
     environment_variables: _containers.ScalarMap[str, str]
     max_concurrent_activities: int
     resources: SandboxActivityResources
-    entrypoint: _containers.RepeatedScalarFieldContainer[str]
-    cmd: _containers.RepeatedScalarFieldContainer[str]
     scheduler_managed_identity_client_id: str
-    def __init__(self, worker_profile_id: _Optional[str] = ..., activity_names: _Optional[_Iterable[str]] = ..., image: _Optional[_Union[SandboxActivityImage, _Mapping]] = ..., environment_variables: _Optional[_Mapping[str, str]] = ..., max_concurrent_activities: _Optional[int] = ..., resources: _Optional[_Union[SandboxActivityResources, _Mapping]] = ..., entrypoint: _Optional[_Iterable[str]] = ..., cmd: _Optional[_Iterable[str]] = ..., scheduler_managed_identity_client_id: _Optional[str] = ...) -> None: ...
+    def __init__(self, worker_profile_id: _Optional[str] = ..., activity_names: _Optional[_Iterable[str]] = ..., image: _Optional[_Union[SandboxActivityImage, _Mapping]] = ..., environment_variables: _Optional[_Mapping[str, str]] = ..., max_concurrent_activities: _Optional[int] = ..., resources: _Optional[_Union[SandboxActivityResources, _Mapping]] = ..., scheduler_managed_identity_client_id: _Optional[str] = ...) -> None: ...
 
 class SandboxActivityImage(_message.Message):
-    __slots__ = ("image_ref", "managed_identity_client_id")
+    __slots__ = ("image_ref", "managed_identity_client_id", "entrypoint", "cmd")
     IMAGE_REF_FIELD_NUMBER: _ClassVar[int]
     MANAGED_IDENTITY_CLIENT_ID_FIELD_NUMBER: _ClassVar[int]
+    ENTRYPOINT_FIELD_NUMBER: _ClassVar[int]
+    CMD_FIELD_NUMBER: _ClassVar[int]
     image_ref: str
     managed_identity_client_id: str
-    def __init__(self, image_ref: _Optional[str] = ..., managed_identity_client_id: _Optional[str] = ...) -> None: ...
+    entrypoint: _containers.RepeatedScalarFieldContainer[str]
+    cmd: _containers.RepeatedScalarFieldContainer[str]
+    def __init__(self, image_ref: _Optional[str] = ..., managed_identity_client_id: _Optional[str] = ..., entrypoint: _Optional[_Iterable[str]] = ..., cmd: _Optional[_Iterable[str]] = ...) -> None: ...
 
 class SandboxActivityResources(_message.Message):
     __slots__ = ("cpu", "memory")

durabletask-azuremanaged/durabletask/azuremanaged/internal/sandbox_service_pb2.pyi

@@ -70,6 +70,8 @@ def ConnectSandboxActivityWorker(self, request_iterator, context):
 
     def DeclareSandboxActivities(self, request, context):
         """Declares sandbox activities before any live worker stream exists.
+        This private preview supports activity execution only as a business
+        decision; orchestrations and entities are not part of this contract.
         This is a configuration contract and does not advertise active worker
         capacity.
         """

durabletask-azuremanaged/durabletask/azuremanaged/internal/sandbox_service_pb2_grpc.py

@@ -140,8 +140,8 @@ def _build_sandbox_activity_declaration(
         max_concurrent_activities=max_concurrent_activities)
     declaration.activity_names.extend(resolved_activity_names)
     declaration.environment_variables.update(environment_variables or {})
-    declaration.entrypoint.extend(_normalize_optional_strings(entrypoint or []))
-    declaration.cmd.extend(_normalize_optional_strings(cmd or []))
+    declaration.image.entrypoint.extend(_normalize_optional_strings(entrypoint or []))
+    declaration.image.cmd.extend(_normalize_optional_strings(cmd or []))
     return declaration
 
 

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

@@ -78,8 +78,8 @@ def configure(self, options) -> None:
         assert declaration.resources.memory == "1Gi"
         assert declaration.max_concurrent_activities == 3
         assert declaration.environment_variables["SANDBOX_SAMPLE_MARKER"] == "custom-value"
-        assert list(declaration.entrypoint) == []
-        assert list(declaration.cmd) == []
+        assert list(declaration.image.entrypoint) == []
+        assert list(declaration.image.cmd) == []
     finally:
         sandbox_declarations._worker_profiles.pop("pytest-profile-a", None)
 
@@ -182,8 +182,8 @@ def test_build_sandbox_activity_declaration() -> None:
     assert declaration.resources.memory == "1Gi"
     assert declaration.environment_variables["CUSTOM_ENV"] == "custom-value"
     assert declaration.max_concurrent_activities == 3
-    assert list(declaration.entrypoint) == ["python"]
-    assert list(declaration.cmd) == ["/app/remote_worker.py"]
+    assert list(declaration.image.entrypoint) == ["python"]
+    assert list(declaration.image.cmd) == ["/app/remote_worker.py"]
 
 
 def test_build_sandbox_activity_declaration_accepts_adc_resource_quantities() -> None: