https://dagster.io/ logo
Title
c

Chris Evans

09/13/2021, 8:59 PM
Hi guys, I think I may be missing something re:
tag_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,
    ]