Alex Kan
06/28/2023, 4:46 PMQueuedRunCoordinator
? Here’s some context:
• Self hosting Dagster and on 1.3.11. Using the K8sRunLauncher
+ Multiprocess Executor with the QueuedRunCoordinator
• We’re submitting multiple large backfills (in the 1000s of runs) and have noticed it takes quite awhile for jobs to be enqueued. It appears that backfills use the same Queue, and if you submit sequential backfills all jobs in earlier backfills must be enqueued before later backfills can be enqueued. This is somewhat problematic if we want to start different backfills in parallel.
• Here’s our config for `QueuedRunCoordinator`:
class: QueuedRunCoordinator
config:
dequeue_interval_seconds: 5
dequeue_num_workers: 4
dequeue_use_threads: true
max_concurrent_runs: 100
We aren’t really ever hitting max_concurrent_runs
; the issue is more about enqueue speed. Should we look into implementing our own custom RunCoordinator
?Alex Kan
06/28/2023, 4:57 PMdaniel
08/28/2023, 3:34 PMdaniel
08/28/2023, 3:35 PMAlex Kan
08/28/2023, 4:01 PMAlex Kan
08/28/2023, 4:04 PM