Add Durable Task middleware support
Chưa có ai nhận issue này.
Đánh giá
- Độ khó
- 5/5
- Thời gian dự kiến
- Hơn một tuần
- Mức phù hợp với người mới
- 32/100
- Loại issue
- Tính năng
- Độ rõ ràng
- Khá rõ ràng
- Mức độ hoạt động
- Ít trao đổi
- Công nghệ
- python
- Lĩnh vực
- backend-api-design, distributed-systems
Hướng nghiên cứu
Bắt đầu bằng cách so sánh .NET cross-SDK middleware specification và user guide được tham chiếu, sau đó xác định các Python durable worker/app registration entry points. Xác định các orchestration và activity APIs, contexts, feature access, ordering, validation và short-circuit behavior, đồng thời thêm các acceptance-criteria tests và documentation; entity middleware và wire changes nằm ngoài phạm vi.
Do mô hình lập chỉ mục viết ra từ nội dung của issue.
Mô tả
Summary
Track adding SDK-level Durable Task middleware support to the Python 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 Python 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.
@app.orchestration_middleware
async def orchestration_middleware(ctx, next):
if not ctx.is_replaying:
ctx.logger.info("starting orchestration", extra={"instance_id": ctx.instance_id})
await next(ctx)
@app.activity_middleware
async def activity_middleware(ctx, next):
cached = await cache.try_get(ctx.name, ctx.input)
if cached is not None:
ctx.set_result(cached)
return
await next(ctx)
Design points to cover
- Decorator and/or builder registration APIs that are scoped to a worker/app instance.
- Registration ordering: first registered middleware runs outermost and unwinds last.
- Dataclass/protocol-style contexts 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 using type keys or well-known keys when runtime type identity is not the right Python abstraction.
- Orchestration middleware determinism guidance for replay, including replay-safe logging and avoiding
datetime.now,uuid.uuid4,random, file/network I/O, arbitraryasyncioawaits, and mutable process state. - Activity middleware short-circuiting through an explicit
set_resultAPI. - 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/app level.
- Middleware executes in registration order and unwinds in reverse order.
- Orchestration middleware must call
next(ctx)exactly once when completing successfully; missing or duplicate calls are rejected where feasible. - Activity middleware can call
next(ctx)once or short-circuit only throughctx.set_result(...); 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.
- Ngôn ngữ chính
- Python
- Star
- 40
- Fork
- 33
- Merge trung bình
- 2 ngày 2 giờ
- Pull request đã merge (30 ngày)
- 6
Hướng dẫn đóng góp
Bắt đầu từ đâu
- Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
- Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
- Fork repository và làm thay đổi trên một nhánh.
- Mở pull request có tham chiếu số hiệu của issue.
Issue khác của microsoft/durabletask-python
-
Độ khó 5/5 Hơn một tuần Mức phù hợp với người mới 45/100
microsoft/durabletask-python#268 ·
-
Độ khó 3/5 1-2 ngày Mức phù hợp với người mới 72/100
microsoft/durabletask-python#266 ·
-
Độ khó 5/5 Hơn một tuần Mức phù hợp với người mới 38/100
microsoft/durabletask-python#249 ·
-
bug Functions Parity
Độ khó 5/5 Hơn một tuần Mức phù hợp với người mới 35/100
microsoft/durabletask-python#241 · 2 bình luận ·
-
Độ khó 5/5 Hơn một tuần Mức phù hợp với người mới 30/100
microsoft/durabletask-python#234 ·
Tất cả issue của microsoft/durabletask-python
Issue tương tự
-
Add: hunch Đang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 74/100
AbdelStark/awesome-typesafe#104 ·
-
enhancement
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 72/100
-
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 68/100
DiamondLightSource/dodal#2211 ·
-
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 88/100
openml/openml-python#1749 ·
-
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 88/100
sipyourdrink-ltd/bernstein#6191 ·