Adjust pipelines params

Author: r4victor

src/dstack/_internal/server/background/pipeline_tasks/jobs_running.py

@@ -114,7 +114,7 @@ class JobRunningPipelineItem(PipelineItem):
 class JobRunningPipeline(Pipeline[JobRunningPipelineItem]):
     def __init__(
         self,
-        workers_num: int = 10,
+        workers_num: int = 20,
         queue_lower_limit_factor: float = 0.5,
         queue_upper_limit_factor: float = 2.0,
         min_processing_interval: timedelta = timedelta(seconds=10),

src/dstack/_internal/server/background/pipeline_tasks/jobs_submitted.py

@@ -151,12 +151,12 @@ class JobSubmittedPipelineItem(PipelineItem):
 class JobSubmittedPipeline(Pipeline[JobSubmittedPipelineItem]):
     def __init__(
         self,
-        workers_num: int = 20,
+        workers_num: int = 40,
         queue_lower_limit_factor: float = 0.5,
         queue_upper_limit_factor: float = 2.0,
         min_processing_interval: timedelta = timedelta(seconds=4),
-        lock_timeout: timedelta = timedelta(seconds=30),
-        heartbeat_trigger: timedelta = timedelta(seconds=15),
+        lock_timeout: timedelta = timedelta(seconds=40),
+        heartbeat_trigger: timedelta = timedelta(seconds=20),
     ) -> None:
         super().__init__(
             workers_num=workers_num,

src/dstack/_internal/server/background/pipeline_tasks/jobs_terminating.py

@@ -84,7 +84,7 @@ class JobTerminatingPipelineItem(PipelineItem):
 class JobTerminatingPipeline(Pipeline[JobTerminatingPipelineItem]):
     def __init__(
         self,
-        workers_num: int = 10,
+        workers_num: int = 20,
         queue_lower_limit_factor: float = 0.5,
         queue_upper_limit_factor: float = 2.0,
         min_processing_interval: timedelta = timedelta(seconds=5),