fix: export_service import, UTC import in backup_service
This commit is contained in:
@@ -33,6 +33,7 @@ from app.schemas.contact import (
|
||||
)
|
||||
from app.services import contact_service
|
||||
from app.services import dedup_service
|
||||
from app.services import export_service
|
||||
|
||||
router = APIRouter(prefix="/api/v1/contacts", tags=["contacts"])
|
||||
|
||||
|
||||
@@ -6,7 +6,7 @@ import asyncio
|
||||
import logging
|
||||
import os
|
||||
import uuid
|
||||
from datetime import datetime
|
||||
from datetime import datetime, timezone
|
||||
from pathlib import Path
|
||||
|
||||
from sqlalchemy import select
|
||||
@@ -97,7 +97,7 @@ async def create_backup(
|
||||
"""
|
||||
_ensure_backup_dir()
|
||||
|
||||
timestamp = datetime.now(UTC).strftime("%Y%m%d_%H%M%S")
|
||||
timestamp = datetime.now(timezone.utc).strftime("%Y%m%d_%H%M%S")
|
||||
filename = f"leocrm_backup_{tenant_id}_{timestamp}.dump"
|
||||
filepath = BACKUP_DIR / filename
|
||||
|
||||
@@ -232,7 +232,7 @@ async def restore_backup(
|
||||
raise RuntimeError(f"pg_restore failed: {result.stderr[:200]}")
|
||||
|
||||
backup.status = "restored"
|
||||
backup.restored_at = datetime.now(UTC)
|
||||
backup.restored_at = datetime.now(timezone.utc)
|
||||
await db.commit()
|
||||
logger.info("Backup %s restored successfully", backup_id)
|
||||
return backup
|
||||
|
||||
Reference in New Issue
Block a user