apunkt/SurfSense
1
0
Fork 0
mirror of https://github.com/MODSetter/SurfSense.git synced 2026-06-10 20:35:17 +02:00
Code Issues Projects Releases Packages Wiki Activity

chore: ran backend linting

Browse source
This commit is contained in:
Anish Sarkar 2026-01-14 13:28:50 +05:30
parent 1ea0475f73
commit 7023223213
6 changed files with 25 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

4
surfsense_backend/app/routes/search_source_connectors_routes.py
View file

@ -1086,7 +1086,9 @@ async def _run_indexing_with_notifications(
)
else:
# Success - just no new documents to index (all skipped/unchanged)
logger.info("Indexing completed: No new documents to process (all up to date)")
logger.info(
"Indexing completed: No new documents to process (all up to date)"
)
# Still update timestamp so ElectricSQL syncs and clears "Syncing" UI
if update_timestamp_func:
await update_timestamp_func(session, connector_id)

5
surfsense_backend/app/tasks/connector_indexers/discord_indexer.py
View file

@ -549,7 +549,10 @@ async def index_discord_messages(
logger.info(
f"Discord indexing completed: {documents_indexed} new messages, {documents_skipped} skipped"
)
return documents_indexed, None # Return None on success (result_message is for logging only)
return (
documents_indexed,
None,
) # Return None on success (result_message is for logging only)
except SQLAlchemyError as db_error:
await session.rollback()

5
surfsense_backend/app/tasks/connector_indexers/notion_indexer.py
View file

@ -464,7 +464,10 @@ async def index_notion_pages(
# Clean up the async client
await notion_client.close()
return total_processed, None # Return None on success (result_message is for logging only)
return (
total_processed,
None,
) # Return None on success (result_message is for logging only)
except SQLAlchemyError as db_error:
await session.rollback()

5
surfsense_backend/app/tasks/connector_indexers/slack_indexer.py
View file

@ -413,7 +413,10 @@ async def index_slack_messages(
logger.info(
f"Slack indexing completed: {documents_indexed} new channels, {documents_skipped} skipped"
)
return total_processed, None # Return None on success (result_message is for logging only)
return (
total_processed,
None,
) # Return None on success (result_message is for logging only)
except SQLAlchemyError as db_error:
await session.rollback()

5
surfsense_backend/app/tasks/connector_indexers/teams_indexer.py
View file

@ -460,7 +460,10 @@ async def index_teams_messages(
documents_indexed,
documents_skipped,
)
return total_processed, None # Return None on success (result_message is for logging only)
return (
total_processed,
None,
) # Return None on success (result_message is for logging only)
except SQLAlchemyError as db_error:
await session.rollback()

12
surfsense_backend/app/tasks/connector_indexers/webcrawler_indexer.py
View file

@ -371,17 +371,14 @@ async def index_crawled_urls(
)
await session.commit()
# Build result message
result_message = None
# Log failed URLs if any (for debugging purposes)
if failed_urls:
failed_summary = "; ".join(
[f"{url}: {error}" for url, error in failed_urls[:5]]
)
if len(failed_urls) > 5:
failed_summary += f" (and {len(failed_urls) - 5} more)"
result_message = (
f"Completed with {len(failed_urls)} failures: {failed_summary}"
)
logger.warning(f"Some URLs failed to index: {failed_summary}")
await task_logger.log_task_success(
log_entry,
@ -400,7 +397,10 @@ async def index_crawled_urls(
f"{documents_updated} updated, {documents_skipped} skipped, "
f"{len(failed_urls)} failed"
)
return total_processed, None # Return None on success (result_message is for logging only)
return (
total_processed,
None,
) # Return None on success (result_message is for logging only)
except SQLAlchemyError as db_error:
await session.rollback()