Remove useless agent files (#22)

* Update av to version 16.0.1

- upgraded av from 10.0.0 to 16.0.1

* docs: update README with virtual environment setup

- Added section for creating a virtual environment
- Updated command for creating venv
- Added instructions for activating venv

* fix(docker): downgrade av package version

- Changed av from 16.0.1 to 10.0.0

* Remove unused data agents and files

- Deleted AdministratorAssistant class
- Removed UserAgent class
- Eliminated GroupChatManager class
- Cleared out persistence files
- Updated README installation instructions

* refactor(agent): remove WebSocketManager and models

- Delete WebSocketManager class
- Remove connection management logic
- Eliminate TaskResult and Message models
- Clean up related dependency functions

* feat(agent): remove WebSocket run endpoint

- Delete WebSocket endpoint for runs
- Remove related connection handling logic
- Eliminate message processing for runs

* chore: comment out agent imports and usage

- Comment out agent router inclusion
- Comment out manager initialization
- Comment out manager cleanup during shutdown

---------

Co-authored-by: Haihui.Wang <wanghh2000@163.com>

Author: HaiHui886

data_server/api/api_router.py

@@ -5,7 +5,7 @@
 from .endpoints import task_log
 from .endpoints import op
 from .endpoints import tool
-from .endpoints import agent
+# from .endpoints import agent
 from .endpoints import datasource
 from .endpoints import formatify
 from .endpoints import op_pic_upload
@@ -19,7 +19,7 @@
 api_router.include_router(template.router, prefix="/templates", tags=["Templates"])
 api_router.include_router(op.router, prefix="/ops", tags=["Operators"])
 api_router.include_router(tool.router, prefix="/tools", tags=["Tools"])
-api_router.include_router(agent.router, prefix="/agent", tags=["Agent"])
+# api_router.include_router(agent.router, prefix="/agent", tags=["Agent"])
 api_router.include_router(datasource.router, prefix="/datasource", tags=["Datasource"])
 api_router.include_router(formatify.router, prefix="/formatify", tags=["Formatify"])
 api_router.include_router(celery_server.router, prefix="/celery", tags=["Celery 相关接口"])

data_server/main.py

@@ -6,7 +6,7 @@
 from contextlib import asynccontextmanager
 from typing import AsyncGenerator
 from loguru import logger
-from data_server.agent.deps import init_managers, cleanup_managers
+# from data_server.agent.deps import init_managers, cleanup_managers
 from apscheduler.schedulers.background import BackgroundScheduler
 from apscheduler.triggers.interval import IntervalTrigger
 from data_celery.main import celery_app
@@ -43,8 +43,8 @@ async def lifespan(app: FastAPI) -> AsyncGenerator[None, None]:
         # logger.info("S3 storage initialized successfully")
 
         # Initialize managers (DB, Connection, Team)
-        await init_managers()
-        logger.info("Managers initialized successfully")
+        # await init_managers()
+        # logger.info("Managers initialized successfully")
 
         # _scheduler = BackgroundScheduler()
         # _scheduler.add_job(
@@ -94,7 +94,7 @@ async def lifespan(app: FastAPI) -> AsyncGenerator[None, None]:
 
 
         logger.info("Cleaning up application resources...")
-        await cleanup_managers()
+        # await cleanup_managers()
         logger.info("Application shutdown complete")
     except Exception as e:
         logger.error(f"Error during shutdown: {str(e)}")