Metadata-Version: 2.4
Name: pgtask
Version: 0.1.3
Classifier: Development Status :: 2 - Pre-Alpha
Classifier: Programming Language :: Python :: 3 :: Only
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: Programming Language :: Python :: 3.13
Classifier: Programming Language :: Python :: 3.14
Classifier: Programming Language :: Rust
Requires-Dist: opentelemetry-api>=1.30
Requires-Dist: psycopg>=3.2
Summary: PostgreSQL-native durable tasks and workflows
License-Expression: MIT
Requires-Python: >=3.10
Description-Content-Type: text/markdown; charset=UTF-8; variant=GFM

# `pgtask`

```python
from __future__ import annotations

import asyncio
import os

from pgtask import Client, EnqueueRequest


async def main() -> None:
    client = await Client.connect(os.environ["PGTASK_DATABASE_URL"])
    task = await client.enqueue(EnqueueRequest("reports.render", {"report_id": "report-123"}))
    print(await task.result(timeout=30.0))


asyncio.run(main())
```

This package provides the Python producer client and worker runtime for `pgtask`. See the
[Python SDK documentation](https://github.com/Kludex/pgtask/blob/main/docs/sdk/python.md) for workers, transactions,
durable execution, signals, cancellation, and OpenTelemetry propagation.

