Metadata-Version: 2.4
Name: PlanQ
Version: 0.3.0
Summary: Transport-agnostic async task queue using JSON-RPC 2.0
Project-URL: Homepage, https://github.com/dvazar/planq
Project-URL: Repository, https://github.com/dvazar/planq
Project-URL: Issues, https://github.com/dvazar/planq/issues
Author-email: Dmitrii Azarenko <1531255+dvazar@users.noreply.github.com>
Maintainer-email: Dmitrii Azarenko <1531255+dvazar@users.noreply.github.com>
License-Expression: Apache-2.0
License-File: LICENSE
Keywords: asyncio,distributed,jsonrpc,messaging,queue,task
Classifier: Development Status :: 4 - Beta
Classifier: Framework :: AsyncIO
Classifier: Framework :: Django
Classifier: Intended Audience :: Developers
Classifier: Operating System :: OS Independent
Classifier: Programming Language :: Python :: 3.12
Classifier: Programming Language :: Python :: 3.13
Classifier: Programming Language :: Python :: 3.14
Classifier: Topic :: System :: Distributed Computing
Requires-Python: >=3.12
Requires-Dist: pydantic<3,>=2.0
Provides-Extra: dev
Requires-Dist: ruff>=0.15.1; extra == 'dev'
Provides-Extra: django
Requires-Dist: django>=5.0; extra == 'django'
Provides-Extra: redis
Requires-Dist: redis[hiredis]>=5.0; extra == 'redis'
Provides-Extra: sqs
Requires-Dist: aiobotocore>=2.0; extra == 'sqs'
Provides-Extra: testing
Requires-Dist: dacite>=1.9; extra == 'testing'
Requires-Dist: hypothesis>=6.0; extra == 'testing'
Requires-Dist: pytest-asyncio>=1.3; extra == 'testing'
Requires-Dist: pytest-cov>=4.0; extra == 'testing'
Requires-Dist: pytest-django>=4.0; extra == 'testing'
Requires-Dist: pytest>=8.0; extra == 'testing'
Requires-Dist: time-machine>=3.2; extra == 'testing'
Description-Content-Type: text/markdown

<p align="center">
  <picture>
    <source media="(prefers-color-scheme: dark)" srcset="https://raw.githubusercontent.com/dvazar/planq/main/docs/images/logo-dark.svg">
    <source media="(prefers-color-scheme: light)" srcset="https://raw.githubusercontent.com/dvazar/planq/main/docs/images/logo-light.svg">
    <img alt="PlanQ" src="https://raw.githubusercontent.com/dvazar/planq/main/docs/images/logo-light.svg" width="400px">
  </picture>
</p>

<p align="center">
  <a href="https://github.com/dvazar/planq/actions/workflows/ci.yml"><img src="https://github.com/dvazar/planq/actions/workflows/ci.yml/badge.svg" alt="CI"></a>
  <a href="https://codecov.io/gh/dvazar/planq"><img src="https://codecov.io/gh/dvazar/planq/graph/badge.svg" alt="codecov"></a>
  <a href="https://pypi.org/project/planq/"><img src="https://img.shields.io/pypi/v/planq.svg" alt="PyPI"></a>
  <a href="https://pypi.org/project/planq/"><img src="https://img.shields.io/pypi/pyversions/planq.svg" alt="Python versions"></a>
  <a href="LICENSE"><img src="https://img.shields.io/badge/License-Apache_2.0-blue.svg" alt="License"></a>
</p>

---

**PlanQ** is a transport-agnostic async task queue for Python. Define a task
once and run it over an in-memory, Redis, or SQS broker — the wire format is
JSON-RPC 2.0, so producers and consumers stay decoupled from the transport.

## Installation

```bash
pip install planq            # in-memory only
pip install "planq[redis]"   # Redis broker
pip install "planq[sqs]"     # AWS SQS broker
```

## Example

```python
from planq import Planq
from planq.providers.memory import InMemoryBroker

app = Planq(broker=InMemoryBroker())

@app.task()
async def greet(name: str, say: str = "hi") -> None:
    print(f"{say}, {name}!")

await greet.send("world")   # enqueue
```

## License

Apache-2.0
