Qwame
04/03/2023, 6:06 PMprod
deployment in dagster cloud
run_queue:
max_concurrent_runs: 10
tag_concurrency_limits: []
run_monitoring:
start_timeout_seconds: 1200
run_retries:
max_retries: 0
sso_default_role: VIEWER
non_isolated_runs:
max_concurrent_non_isolated_runs: 1
I run a job locally and it executed 10 of them concurrently but in prod, I am only seeing 2 concurrent tasks. We have a hybrid deployment -- GCP. Am I missing anything?daniel
04/03/2023, 6:07 PMdaniel
04/03/2023, 6:07 PMQwame
04/03/2023, 6:07 PMQwame
04/03/2023, 6:09 PMdagster dev
but in prod I only see 2 concurrent tasks. the job uses DynamicOut
daniel
04/03/2023, 6:11 PMmax_concurrent
config field to set the maximum number of ops within a single run to execute: https://docs.dagster.io/concepts/ops-jobs-graphs/job-execution#default-job-executor - the default value is determined based on the number of CPUs on your machine which is likely why its smaller in prodQwame
04/03/2023, 6:12 PMdaniel
04/03/2023, 6:13 PMdaniel
04/03/2023, 6:15 PMdefs = Definitions(
assets=[the_asset], jobs=[asset_job, op_job], executor=multiprocess_executor.configured({"max_concurrent": 10})
)
Qwame
04/03/2023, 6:16 PMQwame
04/03/2023, 6:22 PMQwame
04/04/2023, 6:40 PM