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 3810e0ff..070f6cb7 100755 --- a/packages/py/aitbc-agent-sdk/src/aitbc_agent/agent.py +++ b/packages/py/aitbc-agent-sdk/src/aitbc_agent/agent.py @@ -5,7 +5,7 @@ Core Agent class for AITBC network participation import asyncio import json import uuid -from datetime import datetime, UTC +from datetime import datetime, timezone from typing import Dict, List, Optional, Any from dataclasses import dataclass from cryptography.hazmat.primitives import hashes @@ -154,7 +154,7 @@ class Agent: "max_concurrent_jobs": self.capabilities.max_concurrent_jobs, "specialization": self.capabilities.specialization, }, - "timestamp": datetime.now(datetime.timezone.utc).isoformat(), + "timestamp": datetime.now(timezone.utc).isoformat(), } # Sign registration data @@ -274,7 +274,7 @@ class Agent: "to": recipient_id, "type": message_type, "payload": payload, - "timestamp": datetime.now(datetime.timezone.utc).isoformat(), + "timestamp": datetime.now(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 7afe4788..5f50c626 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 @@ -6,7 +6,7 @@ import asyncio import httpx import uuid from typing import Dict, List, Optional, Any -from datetime import datetime, UTC, timedelta +from datetime import datetime, timezone, timedelta from dataclasses import dataclass, asdict from cryptography.hazmat.primitives.asymmetric import rsa from cryptography.hazmat.primitives import serialization @@ -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.timezone.utc), + start_time=datetime.now(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.timezone.utc).isoformat(), + "completion_time": datetime.now(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/swarm_coordinator.py b/packages/py/aitbc-agent-sdk/src/aitbc_agent/swarm_coordinator.py index 58fb5e22..5229271f 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.timezone.utc).isoformat(), + "joined_at": datetime.now(timezone.utc).isoformat(), "contribution_count": 0, - "last_activity": datetime.now(datetime.timezone.utc).isoformat(), + "last_activity": datetime.now(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.timezone.utc).isoformat() + swarm_config["last_activity"] = datetime.now(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.timezone.utc).isoformat(), + timestamp=datetime.now(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.timezone.utc).strftime('%Y%m%d_%H%M%S')}", + "task_id": f"task_{datetime.now(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.timezone.utc).isoformat(), + timestamp=datetime.now(timezone.utc).isoformat(), swarm_signature="", )