chore: remove unused root tasks/ folder

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 <noreply@anthropic.com>

tasks/__init__.py

@@ -1 +0,0 @@
-

tasks/analytics_tasks.py

@@ -1 +0,0 @@
-# Analytics and reporting tasks

tasks/backup_tasks.py

@@ -1 +0,0 @@
-# Backup and recovery tasks

tasks/cleanup_tasks.py

@@ -1 +0,0 @@
-# Data cleanup and maintenance tasks

tasks/email_tasks.py

@@ -1 +0,0 @@
-# Email sending tasks

tasks/marketplace_import.py

@@ -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}")

tasks/media_processing.py

@@ -1 +0,0 @@
-# Image processing and optimization tasks

tasks/search_indexing.py

@@ -1 +0,0 @@
-# Search index maintenance tasks

tasks/task_manager.py

@@ -1 +0,0 @@
-# Celery configuration and task management