Address Copilot feedback (6)

Signed-off-by: Sergio Herrera <627709+seherv@users.noreply.github.com>

Author: seherv

ext/dapr-ext-workflow/dapr/ext/workflow/_durabletask/internal/shared.py

@@ -29,7 +29,13 @@ def is_async_callable(fn: Any) -> bool:
     candidate = fn
     while isinstance(candidate, functools.partial):
         candidate = candidate.func
-    candidate = inspect.unwrap(candidate) if callable(candidate) else candidate
+    if callable(candidate):
+        try:
+            candidate = inspect.unwrap(candidate)
+        except ValueError:
+            # Cyclic ``__wrapped__`` chain from a malformed decorator. Fall back to the
+            # outermost callable; misclassification is preferable to crashing dispatch.
+            pass
     if inspect.iscoroutinefunction(candidate):
         return True
     if not inspect.isfunction(candidate) and hasattr(candidate, '__call__'):

ext/dapr-ext-workflow/dapr/ext/workflow/_durabletask/worker.py

@@ -1143,8 +1143,11 @@ async def _execute_activity_async(
                     instance_id,
                 )
             except RuntimeError as exc:
-                # Manager thread pool shut down (worker is tearing down). Treat as transient:
-                # the sidecar will re-dispatch the work item once the worker reconnects.
+                # Only swallow if the manager thread pool was shut down (worker is tearing
+                # down). The sidecar will re-dispatch the work item once the worker reconnects.
+                # Other RuntimeErrors are unexpected and bubble up to the work-item processor.
+                if not self._async_worker_manager._shutdown:
+                    raise
                 self._logger.warning(
                     f"Could not deliver activity response for '{req.name}#{req.taskId}': "
                     f'{exc}. The sidecar will re-dispatch this work item.'

ext/dapr-ext-workflow/docs/concurrency.md

@@ -70,9 +70,10 @@ hosts or need per-call timeout isolation, stick with per-call clients.
 ## Re-running the benchmark
 
 ```bash
+uv sync --all-packages --group dev
 uv run python ext/dapr-ext-workflow/benchmarks/bench_async_activities.py
 ```
 
-Override the 120 s sustained run with `DAPR_BENCH_SUSTAINED_SECONDS=30` for a
-faster local check. Set `DAPR_BENCH_WITH_SIDECAR=1` to exercise the end-to-end
-path against a real sidecar. The script creates `benchmarks/RESULTS.md`.
+Override the 120 s sustained run with `DAPR_BENCH_SUSTAINED_SECONDS=30`
+for a faster local check. Set `DAPR_BENCH_WITH_SIDECAR=1` to exercise the
+end-to-end path against a real sidecar. The script creates `benchmarks/RESULTS.md`.