[WORKFLOW SDK BUG] Activity concurrency is throttled too much

Đang mở

#897 mở ngày 27/1/2026 8 bình luận 0 reaction 0 người được giao Xem trên GitHub

Chưa có ai nhận issue này.

Đánh giá

Độ khó: 4/5
Thời gian dự kiến: 3-5 ngày
Mức phù hợp với người mới: 50/100

Loại issue: Lỗi
Độ rõ ràng: Khá rõ ràng
Mức độ hoạt động: Ít trao đổi
Công nghệ: python
Lĩnh vực: backend, distributed-systems

Hướng nghiên cứu

Tái hiện vấn đề bằng một workflow fan-out 100 activities, mỗi activity sleep trong 60 giây, và so sánh các timestamp scheduled với activated trong log. Theo dõi đường đi lập lịch và kích hoạt activity của Python workflow SDK. Được coi là hoàn tất khi fan-out không áp đặt giới hạn 10–15 activity đã quan sát và các activity có thể chạy đồng thời như mong đợi.

Do mô hình lập chỉ mục viết ra từ nội dung của issue.

Mô tả

dapr-ext-workflow kind/enhancement

runtime
1.17.rc2

SDK
dapr>=1.17.0rc2
dapr-ext-workflow>=1.17.0rc2

Expected Behavior

Activities are allowed to run concurrently

Actual Behavior

The SDK is throttling how many activities can be ran at any one point time

Steps to Reproduce the Problem

Create a workflow, fan out 100 instances of Activities, have each activity sleep for 60 seconds before completing.

Look at the logs and notice that there are at most 10-15 activities running at the same time. Despite all Activities being scheduled at the same time, Activities won't Activate untill previous activities have finished.

Look at the timestamps in the logs below

note : When comparing this exact same workflow authored in dotnet, dotnet allows all activities to run concurrently.

2026-01-27 12:49:47


2026-01-27 12:49:47,810 - hello_world_app.workflows.fan_out_workflow - INFO - Starting fan-out workflow with 100 iterations
2026-01-27 12:49:47


2026-01-27 12:49:47.812 durabletask-worker INFO: 0-312: Orchestrator yielded with 100 task(s) and 0 event(s) outstanding.
2026-01-27 12:49:47


2026-01-27 12:49:47,812 - hello_world_app.workflows.fan_out_workflow - INFO - Waiting for 100 activities to complete
2026-01-27 12:49:47


2026-01-27 12:49:47,812 - durabletask-worker - INFO - 0-312: Orchestrator yielded with 100 task(s) and 0 event(s) outstanding.
2026-01-27 12:49:47


2026-01-27 12:49:47,824 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #0 - scheduled=12:49:47 activated=12:49:47
2026-01-27 12:49:47


2026-01-27 12:49:47,826 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #1 - scheduled=12:49:47 activated=12:49:47
2026-01-27 12:49:47


2026-01-27 12:49:47,826 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #2 - scheduled=12:49:47 activated=12:49:47
2026-01-27 12:49:47


2026-01-27 12:49:47,828 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #3 - scheduled=12:49:47 activated=12:49:47
2026-01-27 12:49:47


2026-01-27 12:49:47,829 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #4 - scheduled=12:49:47 activated=12:49:47
2026-01-27 12:49:47


2026-01-27 12:49:47,833 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #5 - scheduled=12:49:47 activated=12:49:47
2026-01-27 12:49:47


2026-01-27 12:49:47,835 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #6 - scheduled=12:49:47 activated=12:49:47
2026-01-27 12:49:47


2026-01-27 12:49:47,846 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #7 - scheduled=12:49:47 activated=12:49:47
2026-01-27 12:49:47


2026-01-27 12:49:47,855 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #8 - scheduled=12:49:47 activated=12:49:47
2026-01-27 12:49:47


2026-01-27 12:49:47,865 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #9 - scheduled=12:49:47 activated=12:49:47
2026-01-27 12:49:47


2026-01-27 12:49:47,866 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #10 - scheduled=12:49:47 activated=12:49:47
2026-01-27 12:49:47


2026-01-27 12:49:47,869 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #11 - scheduled=12:49:47 activated=12:49:47
2026-01-27 12:49:47


2026-01-27 12:49:47,870 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #12 - scheduled=12:49:47 activated=12:49:47
2026-01-27 12:49:47


2026-01-27 12:49:47,872 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #13 - scheduled=12:49:47 activated=12:49:47
2026-01-27 12:49:47


INFO:     172.20.0.11:53174 - "POST /fanout-workflow HTTP/1.1" 200 OK
2026-01-27 12:50:47


2026-01-27 12:50:47,827 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #0 - scheduled=12:49:47 activated=12:49:47 finished=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,831 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #1 - scheduled=12:49:47 activated=12:49:47 finished=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,832 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #3 - scheduled=12:49:47 activated=12:49:47 finished=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,832 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #2 - scheduled=12:49:47 activated=12:49:47 finished=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,833 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #4 - scheduled=12:49:47 activated=12:49:47 finished=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,834 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #5 - scheduled=12:49:47 activated=12:49:47 finished=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,836 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #6 - scheduled=12:49:47 activated=12:49:47 finished=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,845 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #14 - scheduled=12:49:47 activated=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,845 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #15 - scheduled=12:49:47 activated=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,846 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #16 - scheduled=12:49:47 activated=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,847 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #17 - scheduled=12:49:47 activated=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,847 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #18 - scheduled=12:49:47 activated=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,848 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #19 - scheduled=12:49:47 activated=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,849 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #7 - scheduled=12:49:47 activated=12:49:47 finished=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,850 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #20 - scheduled=12:49:47 activated=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,852 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #21 - scheduled=12:49:47 activated=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,857 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #8 - scheduled=12:49:47 activated=12:49:47 finished=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,859 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #22 - scheduled=12:49:47 activated=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,867 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #9 - scheduled=12:49:47 activated=12:49:47 finished=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,868 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #10 - scheduled=12:49:47 activated=12:49:47 finished=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,870 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #23 - scheduled=12:49:47 activated=12:50:47
2026-01-27 12:50:47


2026-01-27 12:50:47,870 - hello_world_app.activities.super_slow_activity - INFO - 0-312 - super_slow_activity (1) #24 - scheduled=12:49:47 activated=12:50:47

Release Note

RELEASE NOTE:

Ngôn ngữ chính: Python
Star: 272
Fork: 152
Merge trung bình: 3 ngày 21 giờ
Pull request đã merge (30 ngày): 5

Hướng dẫn đóng góp

Mở 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 dapr/python-sdk

SDK Alignment of Workflow Examples Đang mở

dapr-ext-workflow good first issue kind/enhancement P2

Độ khó 2/5 1-2 ngày Mức phù hợp với người mới 72/100

dapr/python-sdk#853 · 4 bình luận · Mở ngày 21/10/2025
[BUG] Streaming subscribe returns None after a reconnect, making test_streaming_subscribe_receives_published_message flaky Đang mở

kind/bug

Độ khó 4/5 3-5 ngày Mức phù hợp với người mới 45/100

dapr/python-sdk#1230 · Mở ngày 24/9/2026
Bulk publish: per-message metadata in publish_events Đang mở

feature-request

Độ khó 3/5 1-2 ngày Mức phù hợp với người mới 76/100

dapr/python-sdk#1214 · 1 người được giao · Mở ngày 15/9/2026
[WORKFLOW SDK BUG] Workflow constructors reject Unix-domain socket DAPR_GRPC_ENDPOINT Đang mở

dapr-ext-workflow kind/enhancement

Độ khó 3/5 1-2 ngày Mức phù hợp với người mới 78/100

dapr/python-sdk#1213 · Mở ngày 14/9/2026
[FEATURE REQUEST] Expose read consistency in DaprClient.get_state Đang mở

Độ khó 3/5 1-2 ngày Mức phù hợp với người mới 76/100

dapr/python-sdk#1200 · Mở ngày 7/9/2026

Tất cả issue của dapr/python-sdk

Issue tương tự

PATCH /interviews/{id} 的 goal 字段没有任何长度上限，500KB 字符串直接落库且每次 GET detail 都全量带回 Đang mở

bug

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 75/100

xinnan-tech/xiaozhi-fde-talk#263 · Mở ngày 24/9/2026
rules: REQ-0480 'left fold' jargon is redundant with its own plain restatement Đang mở

rules

Độ khó 1/5 Dưới một giờ Mức phù hợp với người mới 90/100

elong0527/yamaa#978 · Mở ngày 24/9/2026
Validation discards output from runners that report on stderr (jest, unittest) Đang mở

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 70/100

huggingface/Repo2RLEnv#163 · 1 bình luận · Mở ngày 24/9/2026
Source link in quantize_embeddings have shifted code highlights Đang mở

Độ khó 1/5 Dưới một giờ Mức phù hợp với người mới 95/100

huggingface/sentence-transformers#4074 · Mở ngày 24/9/2026
Queue insertion button ("插入排队消息") missing in api_server sessions — canInsert allowlist only covers cli/global_agent Đang mở

comp/dashboard invalid P3

Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 70/100

NousResearch/hermes-agent#121143 · Mở ngày 24/9/2026

Thêm issue về Python