Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Cancelled asset backfill runs occupy concurrency pools with k8s run launcher #28456

Open
alexbuyn opened this issue Mar 13, 2025 · 0 comments
Open
Labels
area: concurrency Related to controlling concurrent execution deployment: k8s Related to deploying Dagster to Kubernetes type: bug Something isn't working

Comments

@alexbuyn
Copy link

What's the issue?

I have a partitioned asset with concurrency pool "test" and set concurrency limit on the pool to 1. I run Dagster in kubernetes. I trigger backfill for 4 partitions of the assets, which I expect to be run 1 by 1 due to the concurrency limit. It starts as expected - first run in progress, 3 queued. When I cancel the running partition materialization, other partitions DO NOT start running and are stuck in "queued" status.

What did you expect to happen?

After I cancelled the partition materialization run, I expect the next partition materialization to start.

How to reproduce?

  • Create dagster helm chart deployment on kubernetes
  • Create a partitioned asset with concurrency pool
  • Set up pool limit to be 1
  • Start a backfill with 2+ materializations
  • Cancel first that's in progress
  • Verify that other materialization do not start and cancelled materialization is still occupying the concurrency slot.

Dagster version

1.10.1

Deployment type

Dagster Helm chart

Deployment details

No response

Additional information

No response

Message from the maintainers

Impacted by this issue? Give it a 👍! We factor engagement into prioritization.

@alexbuyn alexbuyn added the type: bug Something isn't working label Mar 13, 2025
@alexbuyn alexbuyn changed the title Cancelled runs occupy concurrency pools with k8s run launcher Cancelled asset backfill runs occupy concurrency pools with k8s run launcher Mar 13, 2025
@garethbrickman garethbrickman added area: concurrency Related to controlling concurrent execution deployment: k8s Related to deploying Dagster to Kubernetes labels Mar 14, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
area: concurrency Related to controlling concurrent execution deployment: k8s Related to deploying Dagster to Kubernetes type: bug Something isn't working
Projects
None yet
Development

No branches or pull requests

2 participants