diff --git a/apps/coordinator-api/src/app/services/agent_service.py b/apps/coordinator-api/src/app/services/agent_service.py index 4456bd6f..3df63be6 100755 --- a/apps/coordinator-api/src/app/services/agent_service.py +++ b/apps/coordinator-api/src/app/services/agent_service.py @@ -4,11 +4,12 @@ Implements core orchestration logic and state management for AI agent workflows """ import asyncio -import logging from datetime import datetime, timedelta from typing import Any -logger = logging.getLogger(__name__) +from aitbc import get_logger + +logger = get_logger(__name__) from sqlmodel import Session, select, update diff --git a/apps/coordinator-api/src/app/services/regulatory_reporting.py b/apps/coordinator-api/src/app/services/regulatory_reporting.py index 29512049..168fb5cd 100755 --- a/apps/coordinator-api/src/app/services/regulatory_reporting.py +++ b/apps/coordinator-api/src/app/services/regulatory_reporting.py @@ -8,15 +8,14 @@ import asyncio import csv import io import json -import logging from dataclasses import dataclass, field from datetime import datetime, timedelta from enum import StrEnum from typing import Any -# Setup logging -logging.basicConfig(level=logging.INFO) -logger = logging.getLogger(__name__) +from aitbc import get_logger + +logger = get_logger(__name__) class ReportType(StrEnum): diff --git a/apps/coordinator-api/src/app/services/reputation_service.py b/apps/coordinator-api/src/app/services/reputation_service.py index 582b8afd..2992dacc 100755 --- a/apps/coordinator-api/src/app/services/reputation_service.py +++ b/apps/coordinator-api/src/app/services/reputation_service.py @@ -3,11 +3,12 @@ Agent Reputation and Trust Service Implements reputation management, trust score calculations, and economic profiling """ -import logging from datetime import datetime, timedelta from typing import Any -logger = logging.getLogger(__name__) +from aitbc import get_logger + +logger = get_logger(__name__) from sqlmodel import Session, and_, func, select diff --git a/apps/coordinator-api/src/app/services/reward_service.py b/apps/coordinator-api/src/app/services/reward_service.py index 576ac063..3d09c885 100755 --- a/apps/coordinator-api/src/app/services/reward_service.py +++ b/apps/coordinator-api/src/app/services/reward_service.py @@ -3,12 +3,13 @@ Agent Reward Engine Service Implements performance-based reward calculations, distributions, and tier management """ -import logging from datetime import datetime, timedelta from typing import Any from uuid import uuid4 -logger = logging.getLogger(__name__) +from aitbc import get_logger + +logger = get_logger(__name__) from sqlmodel import Session, and_, select diff --git a/apps/coordinator-api/src/app/services/trading_service.py b/apps/coordinator-api/src/app/services/trading_service.py index 30a9bc08..5d7238da 100755 --- a/apps/coordinator-api/src/app/services/trading_service.py +++ b/apps/coordinator-api/src/app/services/trading_service.py @@ -3,12 +3,13 @@ Agent-to-Agent Trading Protocol Service Implements P2P trading, matching, negotiation, and settlement systems """ -import logging from datetime import datetime, timedelta from typing import Any from uuid import uuid4 -logger = logging.getLogger(__name__) +from aitbc import get_logger + +logger = get_logger(__name__) from sqlmodel import Session, or_, select diff --git a/apps/coordinator-api/src/app/services/websocket_stream_manager.py b/apps/coordinator-api/src/app/services/websocket_stream_manager.py index 6d31b0bb..542ba6bc 100755 --- a/apps/coordinator-api/src/app/services/websocket_stream_manager.py +++ b/apps/coordinator-api/src/app/services/websocket_stream_manager.py @@ -7,7 +7,6 @@ bounded queues, and event loop protection for multi-modal fusion. import asyncio import json -import logging import time import uuid import weakref @@ -19,7 +18,9 @@ from typing import Any from websockets.exceptions import ConnectionClosed from websockets.server import WebSocketServerProtocol -logger = logging.getLogger(__name__) +from aitbc import get_logger + +logger = get_logger(__name__) class StreamStatus(Enum): diff --git a/apps/coordinator-api/src/app/services/zk_memory_verification.py b/apps/coordinator-api/src/app/services/zk_memory_verification.py index b5f8f34a..9182f594 100755 --- a/apps/coordinator-api/src/app/services/zk_memory_verification.py +++ b/apps/coordinator-api/src/app/services/zk_memory_verification.py @@ -10,15 +10,15 @@ from __future__ import annotations import hashlib import json -import logging from fastapi import HTTPException from sqlmodel import Session +from aitbc import get_logger from ..blockchain.contract_interactions import ContractInteractionService from ..domain.decentralized_memory import AgentMemoryNode -logger = logging.getLogger(__name__) +logger = get_logger(__name__) class ZKMemoryVerificationService: