highperfocused/danswer
1
0
Fork 0
mirror of https://github.com/danswer-ai/danswer.git synced 2025-07-15 07:33:35 +02:00
Code Issues Packages Projects Releases Wiki Activity

Add more logging for num workers in simple job client

Browse Source
This commit is contained in:
Weves
2024-06-27 11:48:12 -07:00
committed by Chris Weaver
parent 5764cdd469
commit 91c9b2eb42
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
backend/danswer/background/indexing/job_client.py
View File

@ -105,7 +105,9 @@ class SimpleJobClient:
"""NOTE: `pure` arg is needed so this can be a drop in replacement for Dask""" """NOTE: `pure` arg is needed so this can be a drop in replacement for Dask"""
self._cleanup_completed_jobs() self._cleanup_completed_jobs()
if len(self.jobs) >= self.n_workers: if len(self.jobs) >= self.n_workers:
logger.debug("No available workers to run job") logger.debug(
f"No available workers to run job. Currently running '{len(self.jobs)}' jobs, with a limit of '{self.n_workers}'."
)
return None return None
job_id = self.job_id_counter job_id = self.job_id_counter