[WORKFLOW SDK BUG] Activity concurrency is throttled too much

Aberta

#897 aberta em 27/1/2026 9 comentários 0 reações 0 responsáveis Ver no GitHub

Mantenedores costumam responder em até 7 dias

Ninguém assumiu esta issue ainda.

Avaliação

Dificuldade: 4/5
Tempo estimado: 3-5 dias
Facilidade para iniciantes: 50/100

Tipo de issue: Bug
Clareza: Razoavelmente clara
Status de atividade: Pouca atividade
Stack de tecnologia: python
Domínio: backend, distributed-systems

Direção de pesquisa

Reproduza o problema com um workflow que faça fan-out de 100 activities, cada uma aguardando por 60 segundos, e compare os timestamps de agendamento e ativação nos logs. Rastreie o caminho de agendamento e ativação de activities do Python workflow SDK. Considera-se concluído quando o fan-out não impõe o limite observado de 10–15 activities e as activities podem ser executadas simultaneamente conforme esperado.

Escrita pelo modelo de indexação a partir do texto da issue.

Descrição

dapr-ext-workflow kind/enhancement stale

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:

Linguagem predominante: Python
Estrelas: 274
Forks: 157
Merge médio: 9d 5h
PRs com merge (30d): 30

Preparar o ambiente

Abrir no Codespaces

Inicia o contêiner de desenvolvimento do projeto no navegador, com a sua própria conta do GitHub.

Sem Dockerfile nem arquivo Docker Compose
Tem um modelo de pull request
Ler o guia de contribuição

Primeiros passos

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

Mais de dapr/python-sdk

Report the http(s):// gRPC endpoint deprecation as a DeprecationWarning, not a UserWarning on every client
Talvez já em andamento @kocaemre assumiu há 2 dias. Aberta
- Algo errado?
good first issue

Dificuldade 2/5 1-3 horas Facilidade para iniciantes 85/100

dapr/python-sdk#1275 · Aberta em 13/10/2026

Mantenedores costumam responder em até 7 dias
SDK Alignment of Workflow Examples
Talvez livre de novo Um pull request para esta issue foi fechado sem ser mesclado. Aberta
- Algo errado?
dapr-ext-workflow good first issue kind/enhancement P2

Dificuldade 2/5 1-2 dias Facilidade para iniciantes 72/100

dapr/python-sdk#853 · 4 comentários · Aberta em 21/10/2025

Mantenedores costumam responder em até 7 dias
[WORKFLOW SDK FEATURE REQUEST] Retry WaitForInstanceCompletion/Start on a server-sent CANCELLED
Aberta
- Algo errado?
dapr-ext-workflow kind/enhancement

Dificuldade 4/5 3-5 dias Facilidade para iniciantes 55/100

dapr/python-sdk#1246 · Aberta em 28/9/2026

Mantenedores costumam responder em até 7 dias
[BUG] subscribe_with_handler stops silently: async task can die or be collected, sync retry path exits, handler errors reconnect the stream
Talvez já em andamento @CasperGN assumiu há 21 dias. Aberta
- Algo errado?
kind/bug

Dificuldade 4/5 3-5 dias Facilidade para iniciantes 65/100

dapr/python-sdk#1233 · Aberta em 24/9/2026

Mantenedores costumam responder em até 7 dias
[BUG] Configuration subscription stops permanently after the daprd sidecar restarts
Talvez já em andamento @CasperGN assumiu há 17 dias. Aberta
- Algo errado?
kind/bug

Dificuldade 4/5 3-5 dias Facilidade para iniciantes 68/100

dapr/python-sdk#1232 · Aberta em 24/9/2026

Mantenedores costumam responder em até 7 dias

Todas as issues de dapr/python-sdk

Issues semelhantes

mermaid_extract.py silently discards single-line state-diagram notes; sequence notes are kept
Aberta
- Algo errado?
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 82/100

cathrynlavery/diagram-design#441 · Aberta em 15/10/2026

Mantenedores costumam responder em até 2 dias
[Cleanup] Include the public header in work_split.cpp
Talvez já em andamento @blozano-tt assumiu hoje. Aberta
- Algo errado?
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 82/100

tenstorrent/tt-metal#60850 · Aberta em 15/10/2026

Mantenedores costumam responder em até 1 dia
test(mcp): pin that the cold fallback keeps the scan-size guard
Aberta
- Algo errado?
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 78/100

hslee16/Archy#502 · Aberta em 15/10/2026

Mantenedores costumam responder em até 1 dia
[BUG]: DYN_DEBUG_PERF=1 fails every request on the SGLang chat processor: perf_instrumentation module was removed
Aberta
- Algo errado?
backend::sglang bug language::python observability

Dificuldade 2/5 Meio dia Facilidade para iniciantes 65/100

ai-dynamo/dynamo#16572 · Aberta em 15/10/2026

Mantenedores costumam responder em até 1 dia
In release 4.01 bug in /usr/lib/python3/dist-packages/openshot_qt/launch.py
Aberta
- Algo errado?
Dificuldade 1/5 Menos de uma hora Facilidade para iniciantes 75/100

OpenShot/openshot-qt#6202 · Aberta em 15/10/2026

Mantenedores costumam responder em até 1 dia

Mais issues de Python

[WORKFLOW SDK BUG] Activity concurrency is throttled too much

Algo errado?

Avaliação

Direção de pesquisa

Descrição

Expected Behavior

Actual Behavior

Steps to Reproduce the Problem

Release Note

Preparar o ambiente

Primeiros passos

Mais de dapr/python-sdk

Algo errado?

Algo errado?

Algo errado?

Algo errado?

Algo errado?

Issues semelhantes

Algo errado?

Algo errado?

Algo errado?

Algo errado?

Algo errado?

Receba novas issues na sua caixa de entrada