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

Check for Credential delete before running queued index attempt (#221)

Browse Source
This commit is contained in:
Yuhong Sun
2023-07-19 23:52:48 -07:00
committed by GitHub
parent 191c166ab6
commit 0708002953
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -93,13 +93,23 @@ def run_indexing_jobs(db_session: Session) -> None:
logger.info(f"Found {len(new_indexing_attempts)} new indexing tasks.") logger.info(f"Found {len(new_indexing_attempts)} new indexing tasks.")
for attempt in new_indexing_attempts: for attempt in new_indexing_attempts:
if attempt.connector is None: if attempt.connector is None:
logger.warning(f"Skipping index task as connector has been deleted: {attempt}") logger.warning(
f"Skipping index attempt as Connector has been deleted: {attempt}"
)
mark_attempt_failed(attempt, db_session, failure_reason="Connector is null") mark_attempt_failed(attempt, db_session, failure_reason="Connector is null")
continue continue
if attempt.credential is None:
logger.warning(
f"Skipping index attempt as Credential has been deleted: {attempt}"
)
mark_attempt_failed(
attempt, db_session, failure_reason="Credential is null"
)
continue
logger.info( logger.info(
f"Starting new indexing attempt for connector: '{attempt.connector.name}', " f"Starting new indexing attempt for connector: '{attempt.connector.name}', "
f"with config: '{attempt.connector.connector_specific_config}', and " f"with config: '{attempt.connector.connector_specific_config}', and "
f"with credentials: '{[c.credential_id for c in attempt.connector.credentials]}'" f"with credentials: '{attempt.credential_id}'"
) )
mark_attempt_in_progress(attempt, db_session) mark_attempt_in_progress(attempt, db_session)