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

[PR #146] [CLOSED] [Feature] Add KafkaMessageQueue #292

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

📋 Pull Request Information

Original PR: https://github.com/run-llama/llama_deploy/pull/146
Author: @nerdai
Created: 7/20/2024
Status: ❌ Closed

Base: main ← Head: 144-add-apache-kafka-as-messagequeue

📝 Commits (10+)

📊 Changes

20 files changed (+2923 additions, -0 deletions)

View changed files

📝 examples/kafka/README.md (+2 -0)
➕ examples/kafka/pig-latin-translation/.gitignore (+11 -0)
➕ examples/kafka/pig-latin-translation/Dockerfile (+49 -0)
➕ examples/kafka/pig-latin-translation/README.md (+0 -0)
➕ examples/kafka/pig-latin-translation/docker-compose.yml (+125 -0)
➕ examples/kafka/pig-latin-translation/logging.ini (+18 -0)
➕ examples/kafka/pig-latin-translation/pig_latin_translation/__init__.py (+0 -0)
➕ examples/kafka/pig-latin-translation/pig_latin_translation/additional_services/__init__.py (+0 -0)
➕ examples/kafka/pig-latin-translation/pig_latin_translation/additional_services/human_consumer.py (+46 -0)
➕ examples/kafka/pig-latin-translation/pig_latin_translation/additional_services/task_result.py (+77 -0)
➕ examples/kafka/pig-latin-translation/pig_latin_translation/agent_services/__init__.py (+0 -0)
➕ examples/kafka/pig-latin-translation/pig_latin_translation/agent_services/correct_first_character_agent.py (+106 -0)
➕ examples/kafka/pig-latin-translation/pig_latin_translation/agent_services/decorators.py (+69 -0)
➕ examples/kafka/pig-latin-translation/pig_latin_translation/agent_services/remove_ay_agent.py (+115 -0)
➕ examples/kafka/pig-latin-translation/pig_latin_translation/core_services/__init__.py (+0 -0)
➕ examples/kafka/pig-latin-translation/pig_latin_translation/core_services/control_plane.py (+71 -0)
➕ examples/kafka/pig-latin-translation/pig_latin_translation/core_services/message_queue.py (+10 -0)
➕ examples/kafka/pig-latin-translation/pig_latin_translation/utils.py (+9 -0)
➕ examples/kafka/pig-latin-translation/poetry.lock (+2199 -0)
➕ examples/kafka/pig-latin-translation/pyproject.toml (+16 -0)

📄 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/146 **Author:** [@nerdai](https://github.com/nerdai) **Created:** 7/20/2024 **Status:** ❌ Closed **Base:** `main` ← **Head:** `144-add-apache-kafka-as-messagequeue` --- ### 📝 Commits (10+) - [`de0d2d8`](https://github.com/run-llama/llama_deploy/commit/de0d2d81b0a2d08f5c0589843e42023cf08e21f0) Initial commit - [`567c50f`](https://github.com/run-llama/llama_deploy/commit/567c50f2a514829712baf4b533e5708467ccbdea) initial commit - [`5b4361a`](https://github.com/run-llama/llama_deploy/commit/5b4361a670fff47f0eb8418c433f13e87e638e43) initial commit - [`997cb59`](https://github.com/run-llama/llama_deploy/commit/997cb594df9c5bd19f5eec283d2bbf549d7b627a) add cicd - [`aca0210`](https://github.com/run-llama/llama_deploy/commit/aca0210164d4fb436170dc1718a75488c8706996) add tests - [`6935072`](https://github.com/run-llama/llama_deploy/commit/6935072303b79f7cb2392ce39868a78ba396ce29) renmame, add control plane base - [`e82c1df`](https://github.com/run-llama/llama_deploy/commit/e82c1df839c6434e0d6c4381a7b3378b1401fbab) MessageQueue items (#1) - [`586fcaf`](https://github.com/run-llama/llama_deploy/commit/586fcaf92ba49e0f165bcd25abb66e53e7594e38) refactor base message (#2) - [`6ee50d1`](https://github.com/run-llama/llama_deploy/commit/6ee50d1c7956c7f60681efa5379957fc6b5fca14) WIP init control plane (#5) - [`05e7271`](https://github.com/run-llama/llama_deploy/commit/05e72716de28ede5f949be9b8b376487600910c7) Add unit test for queue consumer (#3) ### 📊 Changes **20 files changed** (+2923 additions, -0 deletions) <details> <summary>View changed files</summary> 📝 `examples/kafka/README.md` (+2 -0) ➕ `examples/kafka/pig-latin-translation/.gitignore` (+11 -0) ➕ `examples/kafka/pig-latin-translation/Dockerfile` (+49 -0) ➕ `examples/kafka/pig-latin-translation/README.md` (+0 -0) ➕ `examples/kafka/pig-latin-translation/docker-compose.yml` (+125 -0) ➕ `examples/kafka/pig-latin-translation/logging.ini` (+18 -0) ➕ `examples/kafka/pig-latin-translation/pig_latin_translation/__init__.py` (+0 -0) ➕ `examples/kafka/pig-latin-translation/pig_latin_translation/additional_services/__init__.py` (+0 -0) ➕ `examples/kafka/pig-latin-translation/pig_latin_translation/additional_services/human_consumer.py` (+46 -0) ➕ `examples/kafka/pig-latin-translation/pig_latin_translation/additional_services/task_result.py` (+77 -0) ➕ `examples/kafka/pig-latin-translation/pig_latin_translation/agent_services/__init__.py` (+0 -0) ➕ `examples/kafka/pig-latin-translation/pig_latin_translation/agent_services/correct_first_character_agent.py` (+106 -0) ➕ `examples/kafka/pig-latin-translation/pig_latin_translation/agent_services/decorators.py` (+69 -0) ➕ `examples/kafka/pig-latin-translation/pig_latin_translation/agent_services/remove_ay_agent.py` (+115 -0) ➕ `examples/kafka/pig-latin-translation/pig_latin_translation/core_services/__init__.py` (+0 -0) ➕ `examples/kafka/pig-latin-translation/pig_latin_translation/core_services/control_plane.py` (+71 -0) ➕ `examples/kafka/pig-latin-translation/pig_latin_translation/core_services/message_queue.py` (+10 -0) ➕ `examples/kafka/pig-latin-translation/pig_latin_translation/utils.py` (+9 -0) ➕ `examples/kafka/pig-latin-translation/poetry.lock` (+2199 -0) ➕ `examples/kafka/pig-latin-translation/pyproject.toml` (+16 -0) </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:46 -05:00
yindo closed this issue 2026-02-16 01:16:46 -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#292
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?