11import logging
22import uuid
33from typing import Dict , Any
4- from datetime import datetime
54from app .agents .devrel .agent import DevRelAgent
6- # TODO: Implement GitHub agent
7- # from app.agents.github.agent import GitHubAgent
85from app .agents .state import AgentState
96from app .core .orchestration .queue_manager import AsyncQueueManager
107from app .agents .devrel .nodes .summarization import store_summary_to_database
@@ -18,18 +15,14 @@ class AgentCoordinator:
1815 def __init__ (self , queue_manager : AsyncQueueManager ):
1916 self .queue_manager = queue_manager
2017 self .devrel_agent = DevRelAgent ()
21- # self.github_agent = GitHubAgent()
2218 self .active_sessions : Dict [str , AgentState ] = {}
2319
24- # Register handlers
2520 self ._register_handlers ()
2621
2722 def _register_handlers (self ):
2823 """Register message handlers"""
2924 self .queue_manager .register_handler ("devrel_request" , self ._handle_devrel_request )
3025 self .queue_manager .register_handler ("clear_thread_memory" , self ._handle_clear_memory_request )
31- # TODO: Register GitHub agent handler after implementation
32- # self.queue_manager.register_handler("github_request", self._handle_github_request)
3326
3427 @traceable (name = "devrel_request_coordination" , run_type = "chain" )
3528 async def _handle_devrel_request (self , message_data : Dict [str , Any ]):
@@ -129,6 +122,3 @@ async def _send_response_to_platform(self, original_message: Dict[str, Any], res
129122 async def _send_error_response (self , original_message : Dict [str , Any ], error_message : str ):
130123 """Send error response to platform"""
131124 await self ._send_response_to_platform (original_message , error_message )
132-
133- # TODO: Implement GitHub agent
134- # async def _handle_github_request(self, message_data: Dict[str, Any]):
0 commit comments