non-retry test in e2e

Signed-off-by: Filinto Duran <[email protected]>

Author: filintod

README.md

@@ -194,7 +194,7 @@ Certain aspects like multi-app activities require the full dapr runtime to be ru
 ```shell
 dapr init || true
 
-dapr run --app-id test-app --dapr-grpc-port  4001 --components-path ./examples/components/
+dapr run --app-id test-app --dapr-grpc-port  4001 --resources-path ./examples/components/
 ```
 
 To run the E2E tests on a specific python version (eg: 3.11), run the following command from the project root:

tests/durabletask/test_orchestration_e2e.py

@@ -546,6 +546,34 @@ def throw_activity_with_retry(ctx: task.ActivityContext, _):
         assert throw_activity_counter == 9
         assert child_orch_counter == 3
 
+    # Test 2: Verify NonRetryableError prevents retries even with retry policy
+    non_retryable_counter = 0
+
+    def throw_non_retryable(ctx: task.ActivityContext, _):
+        nonlocal non_retryable_counter
+        non_retryable_counter += 1
+        raise task.NonRetryableError("Cannot retry this!")
+
+    def orchestrator_with_non_retryable(ctx: task.OrchestrationContext, _):
+        # Even with retry policy, NonRetryableError should fail immediately
+        yield ctx.call_activity(throw_non_retryable, retry_policy=retry_policy)
+
+    with worker.TaskHubGrpcWorker() as w:
+        w.add_orchestrator(orchestrator_with_non_retryable)
+        w.add_activity(throw_non_retryable)
+        w.start()
+        w.wait_for_ready(timeout=10)
+
+        task_hub_client = client.TaskHubGrpcClient()
+        id = task_hub_client.schedule_new_orchestration(orchestrator_with_non_retryable)
+        state = task_hub_client.wait_for_orchestration_completion(id, timeout=30)
+        assert state is not None
+        assert state.runtime_status == client.OrchestrationStatus.FAILED
+        assert state.failure_details is not None
+        assert "Cannot retry this!" in state.failure_details.message
+        # Key assertion: activity was called exactly once (no retries)
+        assert non_retryable_counter == 1
+
 
 def test_retry_timeout():
     # This test verifies that the retry timeout is working as expected.