[WORKFLOW SDK BUG] Activity concurrency is throttled too much

Ouverte

#897 ouverte le 27/1/2026 8 commentaires 0 réactions 0 personnes assignées Voir sur GitHub

Les mainteneurs répondent en général sous 1 jour

Personne n'a encore pris cette issue.

Évaluation

Difficulté: 4/5
Temps estimé: 3-5 jours
Accessibilité débutants: 50/100

Type d'issue: Bug
Clarté: Plutôt claire
Activité: Calme
Stack technique: python
Domaine: backend, distributed-systems

Piste de recherche

Reproduisez le problème avec un workflow qui répartit 100 activities, chacune dormant pendant 60 secondes, et comparez les horodatages de planification et d’activation dans les logs. Suivez le chemin de planification et d’activation des activities du Python workflow SDK. Le travail est considéré comme terminé lorsque la répartition n’impose pas la limite observée de 10–15 activities et que les activities peuvent s’exécuter simultanément comme prévu.

Rédigé par le modèle d'indexation à partir du texte de l'issue.

Description

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:

Langage dominant: Python
Étoiles: 272
Forks: 152
Merge moyen: 2 j 22 h
PR mergées (30 j): 7

Préparer son environnement

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

SDK Alignment of Workflow Examples
Ouverte
- Quelque chose ne va pas ?
dapr-ext-workflow good first issue kind/enhancement P2

Difficulté 2/5 1-2 jours Accessibilité débutants 72/100

dapr/python-sdk#853 · 4 commentaires · Ouverte le 21/10/2025

Les mainteneurs répondent en général sous 1 jour
[BUG] subscribe_with_handler stops silently: async task can die or be collected, sync retry path exits, handler errors reconnect the stream
Ouverte
- Quelque chose ne va pas ?
kind/bug

Difficulté 4/5 3-5 jours Accessibilité débutants 65/100

dapr/python-sdk#1233 · Ouverte le 24/9/2026

Les mainteneurs répondent en général sous 1 jour
[BUG] Configuration subscription stops permanently after the daprd sidecar restarts
Ouverte
- Quelque chose ne va pas ?
kind/bug

Difficulté 4/5 3-5 jours Accessibilité débutants 68/100

dapr/python-sdk#1232 · Ouverte le 24/9/2026

Les mainteneurs répondent en général sous 1 jour
[BUG] Streaming subscribe returns None after a reconnect, making test_streaming_subscribe_receives_published_message flaky
Ouverte
- Quelque chose ne va pas ?
kind/bug

Difficulté 4/5 3-5 jours Accessibilité débutants 45/100

dapr/python-sdk#1230 · Ouverte le 24/9/2026

Les mainteneurs répondent en général sous 1 jour
[WORKFLOW SDK BUG] Workflow constructors reject Unix-domain socket DAPR_GRPC_ENDPOINT
Ouverte
- Quelque chose ne va pas ?
dapr-ext-workflow kind/enhancement

Difficulté 3/5 1-2 jours Accessibilité débutants 78/100

dapr/python-sdk#1213 · Ouverte le 14/9/2026

Les mainteneurs répondent en général sous 1 jour

Toutes les issues de dapr/python-sdk

Issues similaires

GCP compute_firewall_ssh/rdp_access_from_the_internet_allowed miss IPv6 ::/0 source ranges, reporting a false negative
Ouverte
- Quelque chose ne va pas ?
bug status/needs-triage

Difficulté 2/5 1-3 heures Accessibilité débutants 86/100

prowler-cloud/prowler#12887 · 1 commentaire · Ouverte le 28/9/2026

Les mainteneurs répondent en général sous 1 jour
desktop: new-project row draws a second border around the focused name input
Ouverte
- Quelque chose ne va pas ?
area: desktop platform: macos priority: p3 status: ready type: enhancement

Difficulté 1/5 Moins d'une heure Accessibilité débutants 92/100

use-agent-os/agent-os#3484 · Ouverte le 28/9/2026

Les mainteneurs répondent en général sous 2 jours
opentelemetry-instrumentation-tornado: server metrics recorded twice when a handler raises, http.server.active_requests goes negative
Ouverte
- Quelque chose ne va pas ?
bug

Difficulté 2/5 1-3 heures Accessibilité débutants 86/100

open-telemetry/opentelemetry-python-contrib#5113 · 2 commentaires · 2 réactions · Ouverte le 28/9/2026

Les mainteneurs répondent en général sous 1 jour
Integration Listing: promptfirewall (PII detection + prompt injection firewall)
Ouverte
- Quelque chose ne va pas ?
external

Difficulté 2/5 1-3 heures Accessibilité débutants 68/100

langchain-ai/docs#6255 · Ouverte le 28/9/2026

Les mainteneurs répondent en général sous 1 jour
Homebrew formula installs taken without the [mcp] extra, leaving taken-mcp broken
Ouverte
- Quelque chose ne va pas ?
Difficulté 2/5 1-3 heures Accessibilité débutants 72/100

RogueAlg0/taken#172 · Ouverte le 28/9/2026

Les mainteneurs répondent en général sous 1 jour

Plus d'issues Python

[WORKFLOW SDK BUG] Activity concurrency is throttled too much

Quelque chose ne va pas ?

Évaluation

Piste de recherche

Description

Expected Behavior

Actual Behavior

Steps to Reproduce the Problem

Release Note

Préparer son environnement

Par où commencer

Autres issues de dapr/python-sdk

Quelque chose ne va pas ?

Quelque chose ne va pas ?

Quelque chose ne va pas ?

Quelque chose ne va pas ?

Quelque chose ne va pas ?

Issues similaires

Quelque chose ne va pas ?

Quelque chose ne va pas ?

Quelque chose ne va pas ?

Quelque chose ne va pas ?

Quelque chose ne va pas ?

Recevez les nouvelles issues par e-mail