Wrap gRPC StatusRuntimeException across all client and worker gRPC calls

Offen

#274 erstellt am 25.3.2026 0 Kommentare 1 Reaktion 2 zugewiesene Personen Auf GitHub ansehen

@bachuv arbeitet bereits daran.

Seit 07.4.2026.

#278 von @copilot-swe-agent — ohne Merge geschlossen

Bewertung

Dieses Issue wurde noch nicht bewertet.

Beschreibung

Enhancement

Summary

Most gRPC calls in the Java SDK let raw io.grpc.StatusRuntimeException escape to callers. The .NET SDK wraps RpcException (at minimum StatusCode.Cancelled → OperationCanceledException) for all entity client methods. The Java SDK should provide consistent domain-level exception wrapping so callers don't need to depend on gRPC types and so we can have .NET feature parity.

Current Behavior

The majority of gRPC methods across DurableTaskGrpcClient, GrpcDurableEntityClient, and DurableTaskGrpcWorker let StatusRuntimeException propagate unwrapped:

DurableTaskGrpcClient — no wrapping:

suspendInstance()
resumeInstance()
terminate()
raiseEvent()
createInstanceWithRaise()
getInstanceMetadata()

DurableTaskGrpcClient — wraps specific codes only:

waitForInstanceStart() — DEADLINE_EXCEEDED → TimeoutException
waitForInstanceCompletion() — DEADLINE_EXCEEDED → TimeoutException
purgeInstances() — DEADLINE_EXCEEDED → TimeoutException
rewindInstance() — NOT_FOUND → IllegalArgumentException, FAILED_PRECONDITION → IllegalStateException

GrpcDurableEntityClient — no wrapping:

signalEntity()
getEntityMetadata()
queryEntities()
cleanEntityStorage()

DurableTaskGrpcWorker — no wrapping:

completeActivityTask()
completeOrchestratorTask()
completeEntityTask()

Expected Behavior

gRPC transport exceptions should be translated into SDK-level exceptions. At minimum:

CANCELLED → CancellationException (closest Java equivalent to .NET's OperationCanceledException)
NOT_FOUND → IllegalArgumentException or a dedicated not-found exception
DEADLINE_EXCEEDED → TimeoutException (already done for some methods)

.NET SDK Reference

The .NET GrpcDurableEntityClient wraps RpcException for every entity method:

catch (RpcException e) when (e.StatusCode == StatusCode.Cancelled)
{
    throw new OperationCanceledException(
        $"The {nameof(this.SignalEntityAsync)} operation was canceled.", e, cancellation);
}

Vorherrschende Sprache: Java
Sterne: 29
Forks: 18
Ø Merge: 1 T. 10 Std.
Gemergte PRs (30 T.): 2

Beitragsleitfaden

Beitragsleitfaden öffnen

Erste Schritte

Lesen Sie das ganze Issue und danach den Beitragsleitfaden des Projekts.
Schreiben Sie ins Issue, dass Sie es übernehmen — das erspart doppelte Arbeit.
Forken Sie das Repository und arbeiten Sie in einem Branch.
Öffnen Sie einen Pull Request, der die Issue-Nummer nennt.

Mehr aus microsoft/durabletask-java

Apply DurableHttpRequest.HttpRetryOptions when scheduling durable HTTP retries Offen

Needs: Triage :mag:

Schwierigkeit 4/5 3-5 Tage Anfängerfreundlichkeit 48/100

microsoft/durabletask-java#303 · Erstellt am 17.9.2026
RetryContext.lastAttemptNumber is inflated when retriable task is awaited via ctx.anyOf(...) Offen

Needs: Triage :mag:

Schwierigkeit 4/5 3-5 Tage Anfängerfreundlichkeit 45/100

microsoft/durabletask-java#290 · 2 Kommentare · Erstellt am 20.5.2026
Add Durable Task middleware support Offen

Needs: Triage :mag:

Schwierigkeit 5/5 Über eine Woche Anfängerfreundlichkeit 35/100

microsoft/durabletask-java#285 · Erstellt am 05.5.2026
ContinueAsNew does not support specifying a new orchestration version Offen

Needs: Triage :mag:

Schwierigkeit 3/5 1-2 Tage Anfängerfreundlichkeit 68/100

microsoft/durabletask-java#276 · Erstellt am 27.3.2026
Jackson deserialization issue with Kotlin and data classes Offen

Needs: Triage :mag:

Schwierigkeit 4/5 3-5 Tage Anfängerfreundlichkeit 42/100

microsoft/durabletask-java#270 · Erstellt am 10.3.2026

Alle Issues in microsoft/durabletask-java