[PR #22] [MERGED] Introduce the message queue as a server #217

Closed
opened 2026-02-16 01:16:31 -05:00 by yindo · 0 comments
Owner

📋 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: mainHead: logan/message_queue_server


📝 Commits (4)

📊 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.

## 📋 Pull Request Information **Original PR:** https://github.com/run-llama/llama_deploy/pull/22 **Author:** [@logan-markewich](https://github.com/logan-markewich) **Created:** 6/21/2024 **Status:** ✅ Merged **Merged:** 6/21/2024 **Merged by:** [@logan-markewich](https://github.com/logan-markewich) **Base:** `main` ← **Head:** `logan/message_queue_server` --- ### 📝 Commits (4) - [`55d4745`](https://github.com/run-llama/llama_deploy/commit/55d4745165657b565a50834a9d3f070a8939cb72) go back to async launch_local - [`d10a2a5`](https://github.com/run-llama/llama_deploy/commit/d10a2a5d1409a48730fb588859accce04797769c) use create task - [`309a759`](https://github.com/run-llama/llama_deploy/commit/309a759bedbe8643675b8f1cc030ed87ef2a926d) make the local launcher return - [`2f970e9`](https://github.com/run-llama/llama_deploy/commit/2f970e9e06f2083d1edc8a2d4b01b48fa04dfded) better types ### 📊 Changes **23 files changed** (+312 additions, -123 deletions) <details> <summary>View changed files</summary> 📝 `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_ </details> ### 📄 Description _No description provided_ --- <sub>🔄 This issue represents a GitHub Pull Request. It cannot be merged through Gitea due to API limitations.</sub>
yindo added the pull-request label 2026-02-16 01:16:31 -05:00
yindo closed this issue 2026-02-16 01:16:31 -05:00
Sign in to join this conversation.
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: run-llama/llama_deploy#217