mirror of
https://github.com/run-llama/llama_deploy.git
synced 2026-08-25 10:39:36 -04:00
[PR #22] [MERGED] Introduce the message queue as a server #217
Reference in New Issue
Block a user
Delete Branch "%!s()"
Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?
📋 Pull Request Information
Original PR: https://github.com/run-llama/llama_deploy/pull/22
Author: @logan-markewich
Created: 6/21/2024
Status: ✅ Merged
Merged: 6/21/2024
Merged by: @logan-markewich
Base:
main← Head:logan/message_queue_server📝 Commits (4)
55d4745go back to async launch_locald10a2a5use create task309a759make the local launcher return2f970e9better types📊 Changes
23 files changed (+312 additions, -123 deletions)
View changed files
📝
agentfile/control_plane/fastapi.py(+9 -9)📝
agentfile/launchers/local.py(+19 -9)📝
agentfile/message_consumers/base.py(+4 -3)➕
agentfile/message_consumers/remote.py(+29 -0)📝
agentfile/message_queues/base.py(+17 -1)📝
agentfile/message_queues/simple.py(+91 -16)📝
agentfile/messages/base.py(+1 -1)📝
agentfile/orchestrators/agent.py(+4 -4)📝
agentfile/orchestrators/pipeline.py(+3 -3)📝
agentfile/services/agent.py(+64 -39)📝
agentfile/services/base.py(+4 -5)📝
agentfile/services/tool.py(+27 -7)📝
agentfile/services/types.py(+1 -1)📝
agentfile/tools/meta_service_tool.py(+4 -3)📝
agentfile/types.py(+4 -4)📝
example_scripts/agentic_local_single.py(+3 -1)📝
example_scripts/agentic_toolservice_local_single.py(+3 -1)📝
example_scripts/pipeline_local_single.py(+3 -1)📝
tests/message_queue_consumers/test_base.py(+3 -2)📝
tests/message_queues/test_simple.py(+3 -2)...and 3 more files
📄 Description
No description provided
🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.