https://dagster.io/ logo
#ask-community
Title
# ask-community
o

Olivier Girardot

12/12/2022, 1:09 PM
Hello, I'd like to work on the equivalent of the
tag_concurrency_limit
available on Runs but for Ops, in order to limit only part of a Run in terms of concurrency (our use case has a DAG with DBT assets (no limit) and Python API calls that would require rate limiting in terms of concurrency) Is there any pointers on how it would be achievable or where to discuss this kind of architecture concerns ?
🤖 1
d

daniel

12/12/2022, 3:08 PM
Hi Olivier - is this something you'd be interested in sending out a PR for? That would be really great and we'd be happy to send out some code pointers
o

Olivier Girardot

12/12/2022, 3:09 PM
yes ! please do, I'm more than willing to work on it, but I think I'll need help getting started
d

daniel

12/12/2022, 3:09 PM
Absolutely - I'll add them to the relevant github issue here: https://github.com/dagster-io/dagster/issues/8525
o

Olivier Girardot

12/12/2022, 3:09 PM
perfect thx
d

daniel

12/12/2022, 3:16 PM
Commented on the issue with some links to the relevant code in the run dequeuer and step dequeuer that would now be sharing more logic - don't hesitate to reach out here or on the issue if you have any questions
o

Olivier Girardot

12/12/2022, 3:19 PM
cool thx, so the code itself will actually be in the get_steps_to_execute in a pratically similar fashion to the limit tag ?
d

daniel

12/12/2022, 3:19 PM
That's exactly right, yeah
o

Olivier Girardot

12/12/2022, 3:20 PM
thx, I'll take a look at the related tests to limit and get started from that