Skip to content

Feature: add database backed queues#135

Merged
krishan711 merged 4 commits into
mainfrom
dbqueues
Jul 16, 2026
Merged

Feature: add database backed queues#135
krishan711 merged 4 commits into
mainfrom
dbqueues

Conversation

@krishan711

Copy link
Copy Markdown
Contributor

Description

Screenshots:

Checklist:

  • I have updated the CHANGELOG with a summary of my changes

Copilot AI review requested due to automatic review settings July 16, 2026 14:05

Copilot AI left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Pull request overview

Adds database-backed queue implementations to core.queues, introducing SQL- and CosmosDB-based MessageQueue adapters and a deduplication mechanism carried through the queue message model.

Changes:

  • Added SqlMessageQueue (SQLAlchemy-backed) and CosmosMessageQueue (Azure CosmosDB-backed) queue implementations.
  • Introduced deduplicationId on Message and added a default content-based deduplication hash in MessageContent.
  • Bumped several dependency minimum versions and added a Cosmos queue extra; updated the changelog.

Reviewed changes

Copilot reviewed 7 out of 8 changed files in this pull request and generated 4 comments.

Show a summary per file
File Description
pyproject.toml Updates dependency minimums; adds queue-cosmos extra.
core/queues/model.py Adds deduplicationId and default content-hash deduplication behavior.
core/queues/sqs.py Propagates deduplicationId when decoding SQS messages.
core/queues/aqs.py Propagates deduplicationId when decoding Azure Queue Storage messages.
core/queues/sql.py Introduces SQL-backed queue table + SqlMessageQueue implementation.
core/queues/cosmos.py Introduces CosmosDB-backed CosmosMessageQueue implementation.
CHANGELOG.md Notes the new database-backed queue implementations.

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

Comment thread core/queues/cosmos.py
Comment thread core/queues/sql.py
Comment thread core/queues/sql.py Outdated
Comment thread core/queues/sql.py Outdated

Copilot AI left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Pull request overview

Copilot reviewed 7 out of 8 changed files in this pull request and generated 3 comments.

Comment thread core/queues/model.py
Comment thread core/queues/sql.py
Comment thread core/queues/cosmos.py
@krishan711
krishan711 merged commit 455ff89 into main Jul 16, 2026
5 checks passed
@krishan711
krishan711 deleted the dbqueues branch July 16, 2026 15:07
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants