We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 444c5fa commit 0923340Copy full SHA for 0923340
1 file changed
src/dstack/_internal/server/background/scheduled_tasks/running_jobs.py
@@ -102,6 +102,8 @@
102
JOB_DISCONNECTED_RETRY_TIMEOUT = timedelta(minutes=2)
103
104
105
+# NOTE: This scheduled task is going to be deprecated in favor of `JobRunningPipeline`.
106
+# If this logic changes before removal, keep `pipeline_tasks/jobs_running.py` in sync.
107
async def process_running_jobs(batch_size: int = 1):
108
tasks = []
109
for _ in range(batch_size):
0 commit comments