[PR #159] [CLOSED] Update SQS MessageQueue integration #296

New Issue

2026-02-16T01:16:46-05:00

yindo commented

2026-02-16 01:16:46 -05:00

📋 Pull Request Information

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

Base: main ← Head: MartinRistov/main

📝 Commits (6)

be52f7b initial push, working with a restart
3fde847 deps and move test file to examples
232a9ad add typing packages
103d293 lint
3bc93c6 refactor to custom types
9b7354f refactor to custom types

📊 Changes

9 files changed (+956 additions, -1 deletions)

View changed files

➕ examples/awssqs/simple-scripts/local_launcher_human_single.py (+62 -0)
➕ examples/awssqs/simple-scripts/local_launcher_router_component_single.py (+67 -0)
➕ llama_agents/message_queues/aws_sqs/__init__.py (+4 -0)
➕ llama_agents/message_queues/aws_sqs/aws_sqs.py (+212 -0)
➕ llama_agents/message_queues/aws_sqs/base.py (+5 -0)
➕ llama_agents/message_queues/aws_sqs/policies.py (+33 -0)
➕ llama_agents/message_queues/aws_sqs/types.py (+18 -0)
📝 poetry.lock (+550 -1)
📝 pyproject.toml (+5 -0)

📄 Description

Use SNS + SQS in order to get publish to topics and have competing consumer pattern (i.e., only one consumer/agent processes a task)
Update pyproject.toml to add aiobotocore as optional and add extras
Move and rename sqs_test to examples/aws_sqs/simple-scripts/

_{🔄 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/159 **Author:** [@nerdai](https://github.com/nerdai) **Created:** 7/27/2024 **Status:** ❌ Closed **Base:** `main` ← **Head:** `MartinRistov/main` --- ### 📝 Commits (6) - [`be52f7b`](https://github.com/run-llama/llama_deploy/commit/be52f7b7b76eb166c79bd48d896f9293f4974b40) initial push, working with a restart - [`3fde847`](https://github.com/run-llama/llama_deploy/commit/3fde84746acca4d7952af281424d1fe3715d1644) deps and move test file to examples - [`232a9ad`](https://github.com/run-llama/llama_deploy/commit/232a9adb71064eaaff33c2a5116eedcc709af036) add typing packages - [`103d293`](https://github.com/run-llama/llama_deploy/commit/103d293e0750d39aed74178d5779363f8bc48801) lint - [`3bc93c6`](https://github.com/run-llama/llama_deploy/commit/3bc93c6a42a5938f01f88da76a49bf92dca71786) refactor to custom types - [`9b7354f`](https://github.com/run-llama/llama_deploy/commit/9b7354f760bb307f8be2b219f35de63b203905d7) refactor to custom types ### 📊 Changes **9 files changed** (+956 additions, -1 deletions) <details> <summary>View changed files</summary> ➕ `examples/awssqs/simple-scripts/local_launcher_human_single.py` (+62 -0) ➕ `examples/awssqs/simple-scripts/local_launcher_router_component_single.py` (+67 -0) ➕ `llama_agents/message_queues/aws_sqs/__init__.py` (+4 -0) ➕ `llama_agents/message_queues/aws_sqs/aws_sqs.py` (+212 -0) ➕ `llama_agents/message_queues/aws_sqs/base.py` (+5 -0) ➕ `llama_agents/message_queues/aws_sqs/policies.py` (+33 -0) ➕ `llama_agents/message_queues/aws_sqs/types.py` (+18 -0) 📝 `poetry.lock` (+550 -1) 📝 `pyproject.toml` (+5 -0) </details> ### 📄 Description - Use SNS + SQS in order to get publish to topics and have competing consumer pattern (i.e., only one consumer/agent processes a task) - Update pyproject.toml to add aiobotocore as optional and add extras - Move and rename `sqs_test` to `examples/aws_sqs/simple-scripts`/ --- <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.

1 Participants

Notifications

Due Date

No due date set.

Dependencies

No dependencies set.

Reference: run-llama/llama_deploy#296