From 54374bd7be7ebd4706eda9b2bc5fbc26e9e748ed Mon Sep 17 00:00:00 2001 From: "DESKTOP-RTLN3BA\\$punk" Date: Tue, 12 Aug 2025 15:33:17 -0700 Subject: [PATCH] ruff format --- .../app/tasks/connector_indexers/clickup_indexer.py | 4 +--- .../app/tasks/connector_indexers/discord_indexer.py | 11 +++++++---- .../app/tasks/connector_indexers/github_indexer.py | 4 +--- .../app/tasks/document_processors/base.py | 1 - 4 files changed, 9 insertions(+), 11 deletions(-) diff --git a/surfsense_backend/app/tasks/connector_indexers/clickup_indexer.py b/surfsense_backend/app/tasks/connector_indexers/clickup_indexer.py index 2bad6f8..54197ee 100644 --- a/surfsense_backend/app/tasks/connector_indexers/clickup_indexer.py +++ b/surfsense_backend/app/tasks/connector_indexers/clickup_indexer.py @@ -195,9 +195,7 @@ async def index_clickup_tasks( assignee.get("username", "Unknown") for assignee in task_assignees ] - content_parts.append( - f"Assignees: {', '.join(assignee_names)}" - ) + content_parts.append(f"Assignees: {', '.join(assignee_names)}") if task_due_date: content_parts.append(f"Due Date: {task_due_date}") diff --git a/surfsense_backend/app/tasks/connector_indexers/discord_indexer.py b/surfsense_backend/app/tasks/connector_indexers/discord_indexer.py index 37c3405..602cce4 100644 --- a/surfsense_backend/app/tasks/connector_indexers/discord_indexer.py +++ b/surfsense_backend/app/tasks/connector_indexers/discord_indexer.py @@ -163,7 +163,6 @@ async def index_discord_messages( f"Indexing Discord messages from {start_date_iso} to {end_date_iso}" ) - try: await task_logger.log_task_progress( log_entry, @@ -220,7 +219,9 @@ async def index_discord_messages( try: channels = await discord_client.get_text_channels(guild_id) if not channels: - logger.info(f"No channels found in guild {guild_name}. Skipping.") + logger.info( + f"No channels found in guild {guild_name}. Skipping." + ) skipped_channels.append(f"{guild_name} (no channels)") documents_skipped += 1 continue @@ -310,8 +311,10 @@ async def index_discord_messages( ) # Skip duplicates by hash - existing_document_by_hash = await check_duplicate_document_by_hash( - session, content_hash + existing_document_by_hash = ( + await check_duplicate_document_by_hash( + session, content_hash + ) ) if existing_document_by_hash: logger.info( diff --git a/surfsense_backend/app/tasks/connector_indexers/github_indexer.py b/surfsense_backend/app/tasks/connector_indexers/github_indexer.py index 3300440..b9dd3ec 100644 --- a/surfsense_backend/app/tasks/connector_indexers/github_indexer.py +++ b/surfsense_backend/app/tasks/connector_indexers/github_indexer.py @@ -217,9 +217,7 @@ async def index_github_repos( # Chunk the content try: - chunks_data = [ - await create_document_chunks(file_content) - ][0] + chunks_data = [await create_document_chunks(file_content)][0] # Use code chunker if available, otherwise regular chunker if hasattr(config, "code_chunker_instance"): diff --git a/surfsense_backend/app/tasks/document_processors/base.py b/surfsense_backend/app/tasks/document_processors/base.py index 2b2e3ab..fa0a5ae 100644 --- a/surfsense_backend/app/tasks/document_processors/base.py +++ b/surfsense_backend/app/tasks/document_processors/base.py @@ -2,7 +2,6 @@ Base functionality and shared imports for document processors. """ - from langchain_community.document_transformers import MarkdownifyTransformer from sqlalchemy.ext.asyncio import AsyncSession from sqlalchemy.future import select