highperfocused/danswer
1
0
Fork 0
mirror of https://github.com/danswer-ai/danswer.git synced 2025-04-09 20:39:29 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fix jobs erroring while waiting on queue

Browse Source
This commit is contained in:
Weves 2023-10-28 22:46:38 -07:00 committed by Chris Weaver
parent 57ecab0098
commit 815c30c9d0
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
backend/danswer/background/update.py
View File

@ -385,6 +385,7 @@ def _run_indexing_entrypoint(index_attempt_id: int) -> None:
f"with config: '{attempt.connector.connector_specific_config}', and "
f"with credentials: '{attempt.credential_id}'"
)
mark_attempt_in_progress(attempt, db_session)
update_connector_credential_pair(
db_session=db_session,
connector_id=attempt.connector.id,
@ -435,12 +436,14 @@ def kickoff_indexing_jobs(
)
continue
if attempt.id in existing_jobs:
continue
logger.info(
f"Kicking off indexing attempt for connector: '{attempt.connector.name}', "
f"with config: '{attempt.connector.connector_specific_config}', and "
f"with credentials: '{attempt.credential_id}'"
)
mark_attempt_in_progress(attempt, db_session)
run = client.submit(_run_indexing_entrypoint, attempt.id, pure=False)
existing_jobs_copy[attempt.id] = run