diff --git a/backend/danswer/background/celery/tasks/shared/tasks.py b/backend/danswer/background/celery/tasks/shared/tasks.py index 116e7e1ff7e..3cee42ad7fb 100644 --- a/backend/danswer/background/celery/tasks/shared/tasks.py +++ b/backend/danswer/background/celery/tasks/shared/tasks.py @@ -59,7 +59,7 @@ def document_by_cc_pair_cleanup_task( connector / credential pair from the access list (6) delete all relevant entries from postgres """ - task_logger.info(f"tenant={tenant_id} doc={document_id}") + task_logger.debug(f"Task start: tenant={tenant_id} doc={document_id}") try: with get_session_with_tenant(tenant_id) as db_session: @@ -141,7 +141,9 @@ def document_by_cc_pair_cleanup_task( return False except Exception as ex: if isinstance(ex, RetryError): - task_logger.info(f"Retry failed: {ex.last_attempt.attempt_number}") + task_logger.warning( + f"Tenacity retry failed: num_attempts={ex.last_attempt.attempt_number}" + ) # only set the inner exception if it is of type Exception e_temp = ex.last_attempt.exception() @@ -171,8 +173,8 @@ def document_by_cc_pair_cleanup_task( else: # This is the last attempt! mark the document as dirty in the db so that it # eventually gets fixed out of band via stale document reconciliation - task_logger.info( - f"Max retries reached. Marking doc as dirty for reconciliation: " + task_logger.warning( + f"Max celery task retries reached. Marking doc as dirty for reconciliation: " f"tenant={tenant_id} doc={document_id}" ) with get_session_with_tenant(tenant_id): diff --git a/backend/danswer/background/celery/tasks/vespa/tasks.py b/backend/danswer/background/celery/tasks/vespa/tasks.py index 00676d7b117..a085a4f03be 100644 --- a/backend/danswer/background/celery/tasks/vespa/tasks.py +++ b/backend/danswer/background/celery/tasks/vespa/tasks.py @@ -869,7 +869,9 @@ def vespa_metadata_sync_task( ) except Exception as ex: if isinstance(ex, RetryError): - task_logger.warning(f"Retry failed: {ex.last_attempt.attempt_number}") + task_logger.warning( + f"Tenacity retry failed: num_attempts={ex.last_attempt.attempt_number}" + ) # only set the inner exception if it is of type Exception e_temp = ex.last_attempt.exception() diff --git a/backend/danswer/db/document.py b/backend/danswer/db/document.py index 1797a68bf73..32efbf511be 100644 --- a/backend/danswer/db/document.py +++ b/backend/danswer/db/document.py @@ -505,7 +505,6 @@ def delete_documents_complete__no_commit( db_session: Session, document_ids: list[str] ) -> None: """This completely deletes the documents from the db, including all foreign key relationships""" - logger.info(f"Deleting {len(document_ids)} documents from the DB") delete_documents_by_connector_credential_pair__no_commit(db_session, document_ids) delete_document_feedback_for_documents__no_commit( document_ids=document_ids, db_session=db_session