Chris Evans
09/13/2021, 8:59 PMtag_concurrency_limits
. I am trying to control concurrency of runs via tags. I have setup a test locally w/ the docker run launcher where I have been manually triggering the below pipeline at approx the same time via Dagit. While I expect them to run one a time, each run immediately starts. Do I have this test setup correctly?
dagster.yaml
run_coordinator:
module: dagster.core.run_coordinator
class: QueuedRunCoordinator
config:
tag_concurrency_limits:
- key: test
value: value
limit: 1
repo.py
@solid
def sleep():
time.sleep(60)
@pipeline(tags={'test': 'value'})
def sleep_graph():
sleep()
@repository
def repository() -> List[Any]:
return [
sleep_graph,
]