https://dagster.io/ logo
#dagster-feedback
Title
# dagster-feedback
b

Bz Mn

12/16/2022, 8:00 AM
Many of my pipelines through the years had to limit concurrency due to limited resources such as ram, bandwidth, singletons and so on. The feature that I am currently missing the most is to limit operator concurrency WITHOUT going via dockers. Is that anywhere in the roadmap?
dagster bot responded by community 1
g

geoHeil

12/16/2022, 2:17 PM
you can simply set tags and concurrency limits for tags
b

Bz Mn

12/17/2022, 7:14 PM
Does this work for operator concurrency or for job concurrency?
g

geoHeil

12/17/2022, 8:47 PM
Job
For op you can use it too but must use the queue based deployment with limited number of consumers.
b

Bz Mn

12/17/2022, 8:49 PM
Could you please direct me to the right place in documentation?
this is for the queue-based fine-grained resource control deployment
b

Bz Mn

12/18/2022, 9:13 AM
Many thanks 🙏 Just to make sure that I understand, this requires each op to run in it’s own kubernetes job, right?
g

geoHeil

12/18/2022, 9:53 AM
indeed: to run each op in its own Kubernetes job, Dagster also allows you to use Celery to limit the number of ops that can concurrently connect to a resource across all running Dagster jobs. In
b

Bz Mn

12/22/2022, 10:33 AM
In that case, I’ll be happy for the requested feature of limiting concurrency in general in Operator level, without dockers :) Is that anywhere in the roadmap?
g

geoHeil

12/22/2022, 1:48 PM
I cannot comment on this - I am not working for dagster but @sandy should be able to tell you
🙏 1
d

daniel

12/22/2022, 11:08 PM
You can use celery for per-op concurrency today, which doesn't require docker: https://docs.dagster.io/deployment/guides/celery
b

Bz Mn

12/25/2022, 8:48 AM
Nice! many thanks!
2 Views