Metadata-Version: 2.4
Name: task-hub-sdk-pg
Version: 2.0.0
Summary: Task Bus SDK for Python (PGMQ / PostgreSQL broker)
Author-email: Xinyi <smilingxinyi@gmail.com>
Requires-Python: >=3.10
Requires-Dist: psycopg[binary,pool]>=3.2.0
Requires-Dist: task-hub-sdk
Description-Content-Type: text/markdown

# task-hub-sdk-pg

PGMQ provider for the Task Bus Python SDK.

## Usage

```python
from task_hub_sdk_pg import BaseWorker, PgProvider, start_worker
from task_hub_sdk import ProviderConfig

class MyWorker(BaseWorker):
    def process_task(self, msg_id, body) -> bool:
        return True

# Convenience helper
start_worker(MyWorker(queue_name="transcribe"))

# Explicit provider
start_worker(MyWorker(), PgProvider(), ProviderConfig(queue_name="transcribe"))
```

## Environment

| Variable | Description |
|----------|-------------|
| `TASK_BUS_URL` | Task Bus server for status reporting |
| `TASK_BUS_PROVIDER` | Provider type: `pgmq` |
| `DATABASE_URL` | Postgres connection URL |
| `TASK_BUS_QUEUE` | Queue name (auto-prefixed to `task_*`) |
