mirror of
https://github.com/danswer-ai/danswer.git
synced 2025-09-21 14:12:42 +02:00
Small fix for indexing (#78)
This commit is contained in:
@@ -71,7 +71,8 @@ def run_update() -> None:
|
||||
# prevent race conditions across multiple background jobs. For now,
|
||||
# this assumes we only ever run a single background job at a time
|
||||
not_started_index_attempts = fetch_index_attempts(
|
||||
input_types=[InputType.LOAD_STATE], statuses=[IndexingStatus.NOT_STARTED]
|
||||
input_types=[InputType.LOAD_STATE, InputType.POLL],
|
||||
statuses=[IndexingStatus.NOT_STARTED],
|
||||
)
|
||||
for not_started_index_attempt in not_started_index_attempts:
|
||||
logger.info(
|
||||
@@ -115,6 +116,8 @@ def run_update() -> None:
|
||||
error_msg=error_msg,
|
||||
)
|
||||
|
||||
logger.info("Finished update")
|
||||
|
||||
|
||||
def update_loop(delay: int = 60) -> None:
|
||||
while True:
|
||||
|
Reference in New Issue
Block a user