Add Durable Task middleware support
Personne n'a encore pris cette issue.
Évaluation
- Difficulté
- 5/5
- Temps estimé
- Plus d'une semaine
- Accessibilité débutants
- 35/100
- Type d'issue
- Fonctionnalité
- Clarté
- Plutôt claire
- Activité
- Calme
- Stack technique
- java
- Domaine
- backend-api-design
Piste de recherche
Commencez par lire la spécification de middleware cross-SDK liée et le guide utilisateur .NET, puis examinez les API de durable worker/builder dans ce Java SDK. Utilisez les points d’entrée proposés du middleware d’orchestration et d’activité pour transposer la conception, y compris les fonctionnalités de contexte et les règles de validation. Le travail est considéré comme terminé lorsque les tests d’acceptation listés, la documentation et l’intégration des fonctionnalités de l’hôte sont implémentés, sans modification de wire ou de protobuf.
Rédigé par le modèle d'indexation à partir du texte de l'issue.
Description
Summary
Track adding SDK-level Durable Task middleware support to the Java SDK, aligned with the .NET reference implementation.
Reference spec: https://github.com/microsoft/durabletask-dotnet/blob/feature/durable-task-middleware/doc/cross-sdk-middleware.md
.NET user guide: https://github.com/microsoft/durabletask-dotnet/blob/feature/durable-task-middleware/doc/durable-task-middleware.md
Motivation: https://github.com/Azure/azure-functions-durable-extension/issues/3054
The spec may shift until the .NET v1 implementation is merged. This issue is intended to track the Java design and implementation work so it can follow the same durable middleware contract with idiomatic API names.
Proposed shape
Names are illustrative, not final API commitments.
workerBuilder.useOrchestrationMiddleware((ctx, next) -> {
if (!ctx.isReplaying()) {
logger.info("starting orchestration {}", ctx.getInstanceId());
}
return next.invoke(ctx);
});
workerBuilder.useActivityMiddleware((ctx, next) -> {
Optional<Object> cached = cache.tryGet(ctx.getName(), ctx.getInput());
if (cached.isPresent()) {
ctx.setResult(cached.get());
return CompletableFuture.completedFuture(null);
}
return next.invoke(ctx);
});
Design points to cover
- Builder-level registration APIs for orchestration and activity middleware.
- Registration ordering: first registered middleware runs outermost and unwinds last.
- Context interfaces that expose durable task name, instance ID, version/parent/tags where available, input, raw input where available, replay state for orchestrations, features, and result after
next. - A feature collection keyed by
Class<T>or another type-safe Java abstraction. - Integration with dependency injection frameworks where present, without requiring a particular DI container.
- Orchestration middleware determinism guidance for replay, including replay-safe logging and avoiding nondurable
CompletableFuture/threading usage, wall-clock time, random values, file/network I/O, and mutable process state. - Activity middleware short-circuiting through an explicit
setResultAPI. - Host integration pattern for Azure Functions or other hosts to attach invocation context through features instead of durable middleware depending on host middleware internals.
Acceptance criteria
- Orchestration and activity middleware APIs are exposed at the durable worker/builder level.
- Middleware executes in registration order and unwinds in reverse order.
- Orchestration middleware must call
next.invoke(ctx)exactly once when completing successfully; missing or duplicate calls are rejected where feasible. - Activity middleware can call
next.invoke(ctx)once or short-circuit only throughctx.setResult(...); duplicatenextis invalid. - Host-specific objects can be passed through features without serialization into durable history.
- Documentation covers replay determinism and the difference between durable middleware and host/Functions middleware.
- Tests cover registration ordering, context population, feature access, orchestration next-call validation, and activity short-circuiting.
- No wire protocol or protobuf changes are required.
- Entity middleware is out of scope for v1.
- Langage dominant
- Java
- Étoiles
- 29
- Forks
- 18
- Merge moyen
- 1 j 10 h
- PR mergées (30 j)
- 2
Guide de contribution
Ouvrir le guide de contribution
Par où commencer
- Lisez l'issue en entier, puis le guide de contribution du projet.
- Signalez en commentaire que vous la prenez — cela évite que deux personnes fassent le même travail.
- Forkez le dépôt et travaillez sur une branche.
- Ouvrez une pull request qui référence le numéro de l'issue.
Autres issues de microsoft/durabletask-java
-
Needs: Triage :mag:
Difficulté 4/5 3-5 jours Accessibilité débutants 48/100
microsoft/durabletask-java#303 ·
-
RetryContext.lastAttemptNumber is inflated when retriable task is awaited via ctx.anyOf(...) OuverteNeeds: Triage :mag:
Difficulté 4/5 3-5 jours Accessibilité débutants 45/100
microsoft/durabletask-java#290 · 2 commentaires ·
-
Needs: Triage :mag:
Difficulté 3/5 1-2 jours Accessibilité débutants 68/100
microsoft/durabletask-java#276 ·
-
Enhancement
microsoft/durabletask-java#274 · 1 réaction · 2 personnes assignées ·
-
Needs: Triage :mag:
Difficulté 4/5 3-5 jours Accessibilité débutants 42/100
microsoft/durabletask-java#270 ·
Toutes les issues de microsoft/durabletask-java
Issues similaires
-
awaiting triage bug Causes friction Hop Gui P1 P2 Transforms
Difficulté 2/5 1-3 heures Accessibilité débutants 75/100
-
Difficulté 2/5 1-3 heures Accessibilité débutants 75/100
apache/flink-agents#1152 ·
-
Difficulté 2/5 1-3 heures Accessibilité débutants 75/100
-
Difficulté 2/5 1-3 heures Accessibilité débutants 70/100
jenkinsci/blueocean-plugin#5417 ·
-
Difficulté 2/5 1-3 heures Accessibilité débutants 75/100
objectionary/eo-graphs#75 ·