Use gRPC status for serverless worker registration

Stop relying on an "accepted" response flag for serverless worker registration. The proto removed the accepted field from OnDemandSandboxActivityWorkerSessionResult and the generated _pb2.py/_pb2.pyi were updated accordingly. The worker now simply invokes connect_serverless_activity_worker and relies on gRPC status/transport behavior instead of checking a boolean, and the changelog documents this change. (Regenerated protobuf offsets in pb2 file as part of the proto change.)

Author: YunchuWang

durabletask-azuremanaged/CHANGELOG.md

@@ -21,6 +21,8 @@ adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 - Removed the serverless worker wakeup HTTP listener because ADC sandbox
   workers use outbound DTS registration and do not require an inbound probe
   endpoint.
+- Changed serverless worker registration to rely on gRPC status instead of an
+  accepted response flag.
 
 ## v1.5.0
 

durabletask-azuremanaged/durabletask/azuremanaged/extensions/serverless/worker.py

@@ -119,11 +119,7 @@ def _run_serverless_registration_loop(self) -> None:
                     secure_channel=self._secure_channel,
                     channel_options=self._channel_options)
                 try:
-                    result = client.connect_serverless_activity_worker(self._registration_messages())
-                    if not result.accepted:
-                        self._logger.warning(
-                            "Serverless activity worker registration was rejected: %s",
-                            result.message)
+                    client.connect_serverless_activity_worker(self._registration_messages())
                     retry_delay = 1.0
                 finally:
                     client.close()

durabletask-azuremanaged/durabletask/azuremanaged/internal/serverless_activities_service.proto

@@ -54,7 +54,6 @@ message OnDemandSandboxActivityWorkerHeartbeat {
 }
 
 message OnDemandSandboxActivityWorkerSessionResult {
-  bool accepted = 1;
   string message = 2;
 }
 

durabletask-azuremanaged/durabletask/azuremanaged/internal/serverless_activities_service_pb2.py

@@ -46,12 +46,10 @@ class OnDemandSandboxActivityWorkerHeartbeat(_message.Message):
     def __init__(self, active_activities_count: _Optional[int] = ...) -> None: ...
 
 class OnDemandSandboxActivityWorkerSessionResult(_message.Message):
-    __slots__ = ("accepted", "message")
-    ACCEPTED_FIELD_NUMBER: _ClassVar[int]
+    __slots__ = ("message",)
     MESSAGE_FIELD_NUMBER: _ClassVar[int]
-    accepted: bool
     message: str
-    def __init__(self, accepted: bool = ..., message: _Optional[str] = ...) -> None: ...
+    def __init__(self, message: _Optional[str] = ...) -> None: ...
 
 class OnDemandSandboxActivityDeclaration(_message.Message):
     __slots__ = ("worker_profile_id", "activity_names", "image", "environment_variables", "max_concurrent_activities", "resources", "entrypoint", "cmd")