()
| 45 | return args |
| 46 | |
| 47 | async def main(): |
| 48 | args = parse_args() |
| 49 | |
| 50 | config.init_config(args.config, args) |
| 51 | logger.init_logger(config) |
| 52 | logger.info(f"| Config: {config.pretty_text}") |
| 53 | |
| 54 | await model_manager.init_models(use_local_proxy=config.use_local_proxy) |
| 55 | logger.info(f"| Models: {model_manager.list_models()}") |
| 56 | |
| 57 | memory_manager = MemoryManager(**config.memory) |
| 58 | logger.info(f"| Memory Manager: {memory_manager}") |
| 59 | |
| 60 | session_id = "test_session" |
| 61 | await memory_manager.start_session(session_id) |
| 62 | |
| 63 | for i in range(10): |
| 64 | await memory_manager.add_event(step_number=i, |
| 65 | event_type=EventType.ACTION_STEP, |
| 66 | data = dict( |
| 67 | test_data = f"test_data_{i}" |
| 68 | ), |
| 69 | agent_name="test_agent", |
| 70 | task_id="test_task", |
| 71 | session_id=session_id) |
| 72 | |
| 73 | state = await memory_manager.get_state(session_id, n=5) |
| 74 | logger.info(f"| State: {state}") |
| 75 | |
| 76 | if __name__ == "__main__": |
| 77 | asyncio.run(main()) |
no test coverage detected