Default sandbox sample activities to unversioned

Author: YunchuWang

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

@@ -61,7 +61,7 @@ class Activity:
     def add_activity(
             self,
             activity: str | Callable[..., Any],
-            version: Optional[str]) -> None:
+            version: Optional[str] = None) -> None:
         """Add an activity to the sandbox worker profile worker_profile."""
         activity_name = task.get_name(activity) if callable(activity) else activity
         self.activities.append(SandboxActivity(

examples/sandboxes/README.md

@@ -45,10 +45,11 @@ the pushed image reference. `RemoteWorkerProfile.configure()` declares CPU,
 memory, max concurrency, customer environment variables, and sandbox activity
 identities with `options.image.image_ref`,
 `options.image.managed_identity_client_id`, and
-`options.add_activity(name, version)`. This sample uses an unversioned activity
-identity (`version=None`) because Python orchestrations currently schedule
-activities by name. The declarer and remote worker both use `activities.py` so
-they stay in sync.
+`options.add_activity(name)`. This sample uses an unversioned activity identity
+because Python orchestrations currently schedule activities by name. The sandbox
+metadata API can carry an optional activity version for future activity-version
+support, but this sample intentionally omits it. The declarer and remote worker
+both use `activities.py` so they stay in sync.
 
 The remote worker code cannot pass Durable Task Scheduler runtime settings to the SDK. In a
 sandbox, `SandboxWorker()` reads `DTS_ENDPOINT`,

examples/sandboxes/main_app.py

@@ -86,7 +86,7 @@ def configure(self, options) -> None:
         options.memory = "2048Mi"
         options.max_concurrent_activities = 1
         options.environment_variables["SANDBOX_SAMPLE_MARKER"] = "sandboxes-python-sample-marker"
-        options.add_activity(REMOTE_HELLO.name, version=REMOTE_HELLO.version)
+        options.add_activity(REMOTE_HELLO.name)
 
 
 print(f"Using taskhub: {taskhub_name}")

examples/sandboxes/remote_worker.py

@@ -20,7 +20,7 @@ def _remote_hello(ctx: task.ActivityContext, name: str) -> str:
 
 
 with SandboxWorker() as worker:
-    worker.add_activity(_remote_hello, version=REMOTE_HELLO.version)
+    worker.add_activity(_remote_hello)
     worker.start()
     print("Python sandbox remote worker is running. Press Ctrl+C to stop.")
     try:

tests/durabletask-azuremanaged/test_sandboxes_extension.py

@@ -144,6 +144,16 @@ def test_profile_options_add_activities_accepts_activity_range() -> None:
     ]
 
 
+def test_profile_options_add_activity_defaults_to_unversioned() -> None:
+    options = SandboxWorkerProfileOptions(worker_profile_id="pytest-unversioned-profile")
+
+    options.add_activity("RemoteHello")
+
+    assert resolve_activities(options.activities) == [
+        SandboxActivity("RemoteHello", None),
+    ]
+
+
 def test_sandbox_worker_profile_requires_activity() -> None:
     try:
         try: