Merge pull request #200 from jabdoa2/do_not_crash_when_deleting_source

catch crash when deleting a datasource
This commit is contained in:
Yuhong Sun
2023-07-19 23:46:14 -07:00
committed by GitHub

View File

@@ -92,6 +92,10 @@ def run_indexing_jobs(db_session: Session) -> None:
new_indexing_attempts = get_not_started_index_attempts(db_session)
logger.info(f"Found {len(new_indexing_attempts)} new indexing tasks.")
for attempt in new_indexing_attempts:
if attempt.connector is None:
logger.warning(f"Skipping index task as connector has been deleted: {attempt}")
mark_attempt_failed(attempt, db_session, failure_reason="Connector is null")
continue
logger.info(
f"Starting new indexing attempt for connector: '{attempt.connector.name}', "
f"with config: '{attempt.connector.connector_specific_config}', and "