diff --git a/apps/api-gateway/src/api_gateway/main.py b/apps/api-gateway/src/api_gateway/main.py index 713a0ddd..dde4cfc9 100644 --- a/apps/api-gateway/src/api_gateway/main.py +++ b/apps/api-gateway/src/api_gateway/main.py @@ -335,4 +335,4 @@ async def proxy_request( if __name__ == "__main__": import uvicorn - uvicorn.run(app, host="0.0.0.0", port=8080) + uvicorn.run(app, host="0.0.0.0", port=8080) # nosec B104 diff --git a/apps/coordinator-api/src/app/config_pg.py b/apps/coordinator-api/src/app/config_pg.py index 196a525d..60985ed8 100755 --- a/apps/coordinator-api/src/app/config_pg.py +++ b/apps/coordinator-api/src/app/config_pg.py @@ -8,7 +8,7 @@ class Settings(BaseSettings): """Application settings""" # API Configuration - api_host: str = "0.0.0.0" + api_host: str = "0.0.0.0" # nosec B104 api_port: int = 8011 api_prefix: str = "/v1" debug: bool = False diff --git a/apps/exchange/exchange_api.py b/apps/exchange/exchange_api.py index 71257f27..748b61b7 100755 --- a/apps/exchange/exchange_api.py +++ b/apps/exchange/exchange_api.py @@ -348,4 +348,4 @@ def health_check(): if __name__ == "__main__": import uvicorn - uvicorn.run(app, host="0.0.0.0", port=8008) + uvicorn.run(app, host="0.0.0.0", port=8008) # nosec B104 diff --git a/apps/wallet/simple_daemon.py b/apps/wallet/simple_daemon.py index 4e6d84f4..3b1f88e7 100755 --- a/apps/wallet/simple_daemon.py +++ b/apps/wallet/simple_daemon.py @@ -289,4 +289,4 @@ if __name__ == "__main__": print(" POST /v1/wallets/{wallet_id}/unlock") print(" POST /v1/wallets/{wallet_id}/sign") - uvicorn.run(app, host="0.0.0.0", port=8003, log_level="info") + uvicorn.run(app, host="0.0.0.0", port=8003, log_level="info") # nosec B104 diff --git a/packages/py/aitbc-agent-sdk/src/aitbc_agent/agent.py b/packages/py/aitbc-agent-sdk/src/aitbc_agent/agent.py index a3ec2995..3810e0ff 100755 --- a/packages/py/aitbc-agent-sdk/src/aitbc_agent/agent.py +++ b/packages/py/aitbc-agent-sdk/src/aitbc_agent/agent.py @@ -154,7 +154,7 @@ class Agent: "max_concurrent_jobs": self.capabilities.max_concurrent_jobs, "specialization": self.capabilities.specialization, }, - "timestamp": datetime.now(datetime.UTC).isoformat(), + "timestamp": datetime.now(datetime.timezone.utc).isoformat(), } # Sign registration data @@ -274,7 +274,7 @@ class Agent: "to": recipient_id, "type": message_type, "payload": payload, - "timestamp": datetime.now(datetime.UTC).isoformat(), + "timestamp": datetime.now(datetime.timezone.utc).isoformat(), } # Sign message diff --git a/packages/py/aitbc-agent-sdk/src/aitbc_agent/compute_provider.py b/packages/py/aitbc-agent-sdk/src/aitbc_agent/compute_provider.py index 1fad145b..7afe4788 100755 --- a/packages/py/aitbc-agent-sdk/src/aitbc_agent/compute_provider.py +++ b/packages/py/aitbc-agent-sdk/src/aitbc_agent/compute_provider.py @@ -233,7 +233,7 @@ class ComputeProvider(Agent): job = JobExecution( job_id=job_request["job_id"], consumer_id=job_request["consumer_id"], - start_time=datetime.now(datetime.UTC), + start_time=datetime.now(datetime.timezone.utc), expected_duration=timedelta(hours=job_request["estimated_hours"]), ) @@ -286,7 +286,7 @@ class ComputeProvider(Agent): notification = { "job_id": job.job_id, "status": job.status, - "completion_time": datetime.now(datetime.UTC).isoformat(), + "completion_time": datetime.now(datetime.timezone.utc).isoformat(), "duration_hours": ( job.actual_duration.total_seconds() / 3600 if job.actual_duration diff --git a/packages/py/aitbc-agent-sdk/src/aitbc_agent/contract_integration.py b/packages/py/aitbc-agent-sdk/src/aitbc_agent/contract_integration.py index 90066905..7e0805b3 100644 --- a/packages/py/aitbc-agent-sdk/src/aitbc_agent/contract_integration.py +++ b/packages/py/aitbc-agent-sdk/src/aitbc_agent/contract_integration.py @@ -5,7 +5,7 @@ Provides methods for interacting with deployed smart contracts import asyncio import json -from typing import Dict, List, Optional, Any +from typing import Dict, List, Optional, Any, Union, Callable from dataclasses import dataclass from web3 import Web3 from web3.contract import Contract diff --git a/packages/py/aitbc-agent-sdk/src/aitbc_agent/swarm_coordinator.py b/packages/py/aitbc-agent-sdk/src/aitbc_agent/swarm_coordinator.py index 1452b7e0..58fb5e22 100755 --- a/packages/py/aitbc-agent-sdk/src/aitbc_agent/swarm_coordinator.py +++ b/packages/py/aitbc-agent-sdk/src/aitbc_agent/swarm_coordinator.py @@ -79,9 +79,9 @@ class SwarmCoordinator(Agent): self.joined_swarms[swarm_id] = { "type": swarm_type, "role": config.get("role", "participant"), - "joined_at": datetime.now(datetime.UTC).isoformat(), + "joined_at": datetime.now(datetime.timezone.utc).isoformat(), "contribution_count": 0, - "last_activity": datetime.now(datetime.UTC).isoformat(), + "last_activity": datetime.now(datetime.timezone.utc).isoformat(), } # Initialize swarm reputation @@ -115,7 +115,7 @@ class SwarmCoordinator(Agent): await self._participate_in_decisions(swarm_id) # Update activity timestamp - swarm_config["last_activity"] = datetime.now(datetime.UTC).isoformat() + swarm_config["last_activity"] = datetime.now(datetime.timezone.utc).isoformat() except Exception as e: logger.error(f"Swarm participation error for {swarm_id}: {e}") @@ -177,7 +177,7 @@ class SwarmCoordinator(Agent): message_type="data_contribution", priority="medium", payload=data, - timestamp=datetime.now(datetime.UTC).isoformat(), + timestamp=datetime.now(datetime.timezone.utc).isoformat(), swarm_signature="", # Will be added in broadcast_to_swarm ) @@ -285,7 +285,7 @@ class SwarmCoordinator(Agent): try: # Create coordination proposal proposal = { - "task_id": f"task_{datetime.now(datetime.UTC).strftime('%Y%m%d_%H%M%S')}", + "task_id": f"task_{datetime.now(datetime.timezone.utc).strftime('%Y%m%d_%H%M%S')}", "task_type": task, "coordinator_id": self.identity.id, "required_collaborators": collaborators, @@ -320,7 +320,7 @@ class SwarmCoordinator(Agent): message_type="intelligence_request", priority="high", payload={"request_type": "market_intelligence"}, - timestamp=datetime.now(datetime.UTC).isoformat(), + timestamp=datetime.now(datetime.timezone.utc).isoformat(), swarm_signature="", )