Wrap gRPC StatusRuntimeException across all client and worker gRPC calls

Aberta
#274 0 comentários 1 reação 2 responsáveis Ver no GitHub

@bachuv já está trabalhando nisso.

Desde 7/4/2026.

  • #278 de @copilot-swe-agent — fechado sem integrar

Avaliação

Esta issue ainda não foi avaliada.

Descrição

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);
}
Linguagem predominante
Java
Estrelas
29
Forks
18
Merge médio
1d 10h
PRs com merge (30d)
2

Guia de contribuição

Abrir o guia de contribuição

Primeiros passos

  1. Leia a issue inteira e depois o guia de contribuição do projeto.
  2. Comente na issue dizendo que vai assumir — evita que duas pessoas façam o mesmo trabalho.
  3. Faça um fork do repositório e trabalhe em uma branch.
  4. Abra um pull request que referencie o número da issue.

Mais de microsoft/durabletask-java

Todas as issues de microsoft/durabletask-java

Issues semelhantes

Mais issues de Java

Receba novas issues na sua caixa de entrada

Um resumo curto de issues do GitHub para quem está começando.