From a8d1c351fcd96ea46b6a4f52ae91f01cfa1733b4 Mon Sep 17 00:00:00 2001 From: Samir Boulahtit Date: Fri, 12 Dec 2025 23:21:43 +0100 Subject: [PATCH] chore: remove unused root tasks/ folder MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Delete the root tasks/ folder which contained placeholder files and an outdated copy of marketplace_import.py. The active background tasks are in app/tasks/ which is the standard location. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 --- tasks/__init__.py | 1 - tasks/analytics_tasks.py | 1 - tasks/backup_tasks.py | 1 - tasks/cleanup_tasks.py | 1 - tasks/email_tasks.py | 1 - tasks/marketplace_import.py | 101 ------------------------------------ tasks/media_processing.py | 1 - tasks/search_indexing.py | 1 - tasks/task_manager.py | 1 - 9 files changed, 109 deletions(-) delete mode 100644 tasks/__init__.py delete mode 100644 tasks/analytics_tasks.py delete mode 100644 tasks/backup_tasks.py delete mode 100644 tasks/cleanup_tasks.py delete mode 100644 tasks/email_tasks.py delete mode 100644 tasks/marketplace_import.py delete mode 100644 tasks/media_processing.py delete mode 100644 tasks/search_indexing.py delete mode 100644 tasks/task_manager.py diff --git a/tasks/__init__.py b/tasks/__init__.py deleted file mode 100644 index 8b137891..00000000 --- a/tasks/__init__.py +++ /dev/null @@ -1 +0,0 @@ - diff --git a/tasks/analytics_tasks.py b/tasks/analytics_tasks.py deleted file mode 100644 index 7882ffad..00000000 --- a/tasks/analytics_tasks.py +++ /dev/null @@ -1 +0,0 @@ -# Analytics and reporting tasks diff --git a/tasks/backup_tasks.py b/tasks/backup_tasks.py deleted file mode 100644 index 13c5b701..00000000 --- a/tasks/backup_tasks.py +++ /dev/null @@ -1 +0,0 @@ -# Backup and recovery tasks diff --git a/tasks/cleanup_tasks.py b/tasks/cleanup_tasks.py deleted file mode 100644 index da7c9643..00000000 --- a/tasks/cleanup_tasks.py +++ /dev/null @@ -1 +0,0 @@ -# Data cleanup and maintenance tasks diff --git a/tasks/email_tasks.py b/tasks/email_tasks.py deleted file mode 100644 index 3576fcb6..00000000 --- a/tasks/email_tasks.py +++ /dev/null @@ -1 +0,0 @@ -# Email sending tasks diff --git a/tasks/marketplace_import.py b/tasks/marketplace_import.py deleted file mode 100644 index 35e02b7c..00000000 --- a/tasks/marketplace_import.py +++ /dev/null @@ -1,101 +0,0 @@ -# Marketplace CSV import tasks -# app/tasks/background_tasks.py -import logging -from datetime import UTC, datetime - -from app.core.database import SessionLocal -from app.utils.csv_processor import CSVProcessor -from models.database.marketplace_import_job import MarketplaceImportJob -from models.database.vendor import Vendor - -logger = logging.getLogger(__name__) - - -async def process_marketplace_import( - job_id: int, - url: str, - marketplace: str, - vendor_id: int, # FIXED: Changed from vendor_name to vendor_id - batch_size: int = 1000, -): - """Background task to process marketplace CSV import.""" - db = SessionLocal() - csv_processor = CSVProcessor() - job = None - - try: - # Get the import job - job = ( - db.query(MarketplaceImportJob) - .filter(MarketplaceImportJob.id == job_id) - .first() - ) - if not job: - logger.error(f"Import job {job_id} not found") - return - - # Get vendor information - vendor = db.query(Vendor).filter(Vendor.id == vendor_id).first() - if not vendor: - logger.error(f"Vendor {vendor_id} not found for import job {job_id}") - job.status = "failed" - job.error_message = f"Vendor {vendor_id} not found" - job.completed_at = datetime.now(UTC) - db.commit() - return - - # Update job status - job.status = "processing" - job.started_at = datetime.now(UTC) - db.commit() - - logger.info( - f"Processing import: Job {job_id}, Marketplace: {marketplace}, " - f"Vendor: {vendor.name} ({vendor.vendor_code})" - ) - - # Process CSV with vendor_id - result = await csv_processor.process_marketplace_csv_from_url( - url, - marketplace, - vendor_id, # FIXED: Pass vendor_id instead of vendor_name - batch_size, - db, - ) - - # Update job with results - job.status = "completed" - job.completed_at = datetime.now(UTC) - job.imported_count = result["imported"] - job.updated_count = result["updated"] - job.error_count = result.get("errors", 0) - job.total_processed = result["total_processed"] - - if result.get("errors", 0) > 0: - job.status = "completed_with_errors" - job.error_message = f"{result['errors']} rows had errors" - - db.commit() - logger.info( - f"Import job {job_id} completed: " - f"imported={result['imported']}, updated={result['updated']}, " - f"errors={result.get('errors', 0)}" - ) - - except Exception as e: - logger.error(f"Import job {job_id} failed: {e}", exc_info=True) - if job is not None: - try: - job.status = "failed" - job.error_message = str(e) - job.completed_at = datetime.now(UTC) - db.commit() - except Exception as commit_error: - logger.error(f"Failed to update job status: {commit_error}") - db.rollback() - finally: - if hasattr(db, "close") and callable(db.close): - try: - db.close() - except Exception as close_error: - logger.error(f"Error closing database session: {close_error}") diff --git a/tasks/media_processing.py b/tasks/media_processing.py deleted file mode 100644 index f2e05cc6..00000000 --- a/tasks/media_processing.py +++ /dev/null @@ -1 +0,0 @@ -# Image processing and optimization tasks diff --git a/tasks/search_indexing.py b/tasks/search_indexing.py deleted file mode 100644 index c73a2b86..00000000 --- a/tasks/search_indexing.py +++ /dev/null @@ -1 +0,0 @@ -# Search index maintenance tasks diff --git a/tasks/task_manager.py b/tasks/task_manager.py deleted file mode 100644 index 655b273c..00000000 --- a/tasks/task_manager.py +++ /dev/null @@ -1 +0,0 @@ -# Celery configuration and task management