Migrate remaining coordinator-api files to centralized aitbc package utilities

- Migrate main.py, main_minimal.py, main_enhanced.py (logging)
- Migrate utils/ files: metrics.py, cache_management.py, circuit_breaker.py, alerting.py, cache.py
- Migrate storage/ files: db_pg.py, db.py
- Migrate settlement/hooks.py
- Migrate sdk/enterprise_client.py
- Migrate reputation/ files: engine.py, aggregator.py
- Migrate agent_identity/ files: wallet_adapter_enhanced.py, wallet_adapter.py, registry.py, core.py, manager.py, sdk/communication.py
- Migrate services/ files: performance_monitoring.py, multi_modal_websocket_fusion.py, multi_modal_fusion.py
- Remove duplicate logging imports
- Add missing aitbc imports for get_logger
This commit is contained in:
aitbc
2026-04-25 07:20:21 +02:00
parent 4a649ac631
commit e9eea6fb22
23 changed files with 55 additions and 43 deletions

View File

@@ -1,12 +1,13 @@
import json
import logging
import os
from collections import deque
from datetime import datetime, timedelta
from typing import Any
from urllib import error, request
logger = logging.getLogger(__name__)
from aitbc import get_logger
logger = get_logger(__name__)
class AlertDispatcher:

View File

@@ -3,12 +3,13 @@ Caching strategy for expensive queries
"""
import hashlib
import logging
from datetime import datetime, timedelta
from functools import wraps
from typing import Any
logger = logging.getLogger(__name__)
from aitbc import get_logger
logger = get_logger(__name__)
class CacheManager:

View File

@@ -2,11 +2,11 @@
Cache management utilities for endpoints
"""
import logging
from aitbc import get_logger
from ..utils.cache import cache_manager, cleanup_expired_cache
logger = logging.getLogger(__name__)
logger = get_logger(__name__)
def invalidate_cache_pattern(pattern: str):

View File

@@ -3,14 +3,15 @@ Circuit breaker pattern for external services
"""
import asyncio
import logging
from collections.abc import Callable
from datetime import datetime, timedelta
from enum import Enum
from functools import wraps
from typing import Any
logger = logging.getLogger(__name__)
from aitbc import get_logger
logger = get_logger(__name__)
class CircuitState(Enum):

View File

@@ -3,13 +3,14 @@ Basic Metrics Collection Module
Collects and tracks system and application metrics for monitoring
"""
import logging
import os
import resource
from datetime import datetime
from typing import Any
logger = logging.getLogger(__name__)
from aitbc import get_logger
logger = get_logger(__name__)
class MetricsCollector: