run-llama/llama_deploy
1
0
Fork 0
mirror of https://github.com/run-llama/llama_deploy.git synced 2026-07-25 16:15:22 -04:00
Code Issues 37 Packages Projects Releases 10 Wiki Activity

[PR #1] [MERGED] MessageQueue items #197

New Issue
Closed
opened 2026-02-16 01:16:25 -05:00 by yindo · 0 comments
yindo commented 2026-02-16 01:16:25 -05:00
Owner
Copy Link
Copy Source

📋 Pull Request Information

Original PR: https://github.com/run-llama/llama_deploy/pull/1
Author: @nerdai
Created: 6/5/2024
Status: ✅ Merged
Merged: 6/6/2024
Merged by: @nerdai

Base: main ← Head: nerdai/message-queue

📝 Commits (10+)

📊 Changes

15 files changed (+332 additions, -2 deletions)

View changed files

➕ .vscode/settings.json (+12 -0)
📝 agentfile/agent_server/types.py (+1 -1)
➕ agentfile/message_consumers/__init__.py (+0 -0)
➕ agentfile/message_consumers/base.py (+36 -0)
➕ agentfile/message_queues/__init__.py (+0 -0)
➕ agentfile/message_queues/base.py (+50 -0)
➕ agentfile/message_queues/simple.py (+103 -0)
➕ agentfile/messages/__init__.py (+0 -0)
➕ agentfile/messages/base.py (+18 -0)
📝 poetry.lock (+19 -1)
📝 pyproject.toml (+1 -0)
➕ tests/__pycache__/__init__.cpython-310.pyc (+0 -0)
➕ tests/__pycache__/test_agent_server.cpython-310-pytest-7.4.4.pyc (+0 -0)
➕ tests/message_queue_consumers/test_base.py (+0 -0)
➕ tests/message_queues/test_simple.py (+92 -0)

📄 Description

This PR adds the first working version of our MessageQueue and related absractions.

  • BaseMessageQueue, SimpleMessageQueue
  • BaseMessage
  • BaseMessageQueueConsumer

🔄 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/1 **Author:** [@nerdai](https://github.com/nerdai) **Created:** 6/5/2024 **Status:** ✅ Merged **Merged:** 6/6/2024 **Merged by:** [@nerdai](https://github.com/nerdai) **Base:** `main` ← **Head:** `nerdai/message-queue` --- ### 📝 Commits (10+) - [`64d6ac7`](https://github.com/run-llama/llama_deploy/commit/64d6ac779b796c07c9533a398ef23b35e9046bc9) scaffold - [`d68bc1c`](https://github.com/run-llama/llama_deploy/commit/d68bc1c22d85b740caffb5ba640e1cf2aba1a08f) fmt - [`307d5e6`](https://github.com/run-llama/llama_deploy/commit/307d5e6464539624bdcb1cf3498513a58c6d9cae) wip - [`b6518c1`](https://github.com/run-llama/llama_deploy/commit/b6518c15d4e4587e67547ff29f8151b4bfa86fd2) add simple - [`298b759`](https://github.com/run-llama/llama_deploy/commit/298b759c7ed9aa114c5469630cce59f3c83802e9) test for simple mq - [`1f4a683`](https://github.com/run-llama/llama_deploy/commit/1f4a68399e136d9e95e022e921bf90ccadb58f78) add different consumer type to test - [`4865581`](https://github.com/run-llama/llama_deploy/commit/486558151574c83c72e8097e8f80fecb1e44b2e0) deregister test - [`dd3b915`](https://github.com/run-llama/llama_deploy/commit/dd3b915cc2b1c54ed2561def07266a4d6ab770a9) add publish test - [`24ea6e2`](https://github.com/run-llama/llama_deploy/commit/24ea6e2f7e03e936e0e7e20b7431cacba4e0f544) infinite loop for passing messages - [`2323a0e`](https://github.com/run-llama/llama_deploy/commit/2323a0ea8e0f48ca87ad2771f648eb8475bb5c17) lock to privateattr ### 📊 Changes **15 files changed** (+332 additions, -2 deletions) <details> <summary>View changed files</summary> ➕ `.vscode/settings.json` (+12 -0) 📝 `agentfile/agent_server/types.py` (+1 -1) ➕ `agentfile/message_consumers/__init__.py` (+0 -0) ➕ `agentfile/message_consumers/base.py` (+36 -0) ➕ `agentfile/message_queues/__init__.py` (+0 -0) ➕ `agentfile/message_queues/base.py` (+50 -0) ➕ `agentfile/message_queues/simple.py` (+103 -0) ➕ `agentfile/messages/__init__.py` (+0 -0) ➕ `agentfile/messages/base.py` (+18 -0) 📝 `poetry.lock` (+19 -1) 📝 `pyproject.toml` (+1 -0) ➕ `tests/__pycache__/__init__.cpython-310.pyc` (+0 -0) ➕ `tests/__pycache__/test_agent_server.cpython-310-pytest-7.4.4.pyc` (+0 -0) ➕ `tests/message_queue_consumers/test_base.py` (+0 -0) ➕ `tests/message_queues/test_simple.py` (+92 -0) </details> ### 📄 Description This PR adds the first working version of our MessageQueue and related absractions. - `BaseMessageQueue`, `SimpleMessageQueue` - `BaseMessage` - `BaseMessageQueueConsumer` --- <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:25 -05:00
yindo closed this issue 2026-02-16 01:16:25 -05:00
Sign in to join this conversation.
No Branch/Tag Specified
Branches Tags
Labels
Clear labels
P0
P1
P2
bug
documentation
documentation
enhancement
example
good first issue
invalid
pull-request
Mirrored from GitHub Pull Request
 question
topic:CLI
topic:SDK
topic:SDK
topic:SDK
topic:apiserver
topic:control_plane
topic:message_queues
wontfix
No Label pull-request
Milestone
No items
No Milestone
Projects
Clear projects
No project
Assignees
Clear assignees
yindo
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: run-llama/llama_deploy#197
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?