[python] update queue subscribers example to use vercel.queue (#1557)

### Description

Updates Python queue subscribers example to use `vercel.queue` instead
of `vercel.workers`

### Demo URL

<!--
Provide a URL to a live deployment where we can test your PR. If a demo
isn't possible feel free to omit this section.
-->

### Type of Change

- [ ] New Example
- [x] Example updates (Bug fixes, new features, etc.)
- [ ] Other (changes to the codebase, but not to examples)

### New Example Checklist

- [ ] 🛫 `npm run new-example` was used to create the example
- [ ] 📚 The template wasn't used but I carefuly read the [Adding a new
example](https://github.com/vercel/examples#adding-a-new-example) steps
and implemented them in the example
- [ ] 📱 Is it responsive? Are mobile and tablets considered?

Author: ricardo-agz

python/queue-subscribers/README.md

@@ -10,7 +10,7 @@ https://python-queue-subscribers.labs.vercel.dev/
 
 ## How it Works
 
-The FastAPI app publishes addition and multiplication tasks with `AsyncQueueClient`. The subscriber configuration in `pyproject.toml` points to the queue client in `worker.py`, while the decorated handlers in `tasks.py` process messages from the `add` and `multiply` topics. Results are shared through a local SQLite file during development and Vercel Runtime Cache when deployed. The dashboard polls for each task until its result is available.
+The FastAPI app publishes addition and multiplication tasks with `vercel.queue.send`. The subscriber configuration in `pyproject.toml` points to `tasks.py`, where decorated handlers process messages from the `add` and `multiply` topics. Results are shared through a local SQLite file during development and Vercel Runtime Cache when deployed. The dashboard polls for each task until its result is available.
 
 ## Running Locally
 

python/queue-subscribers/main.py

@@ -5,9 +5,9 @@
 from fastapi import FastAPI, HTTPException
 from fastapi.responses import HTMLResponse
 from pydantic import BaseModel
+from vercel.queue import send
 
 from store import result_store
-from worker import queue
 
 logger = logging.getLogger("queue-subscribers")
 logger.setLevel(logging.INFO)
@@ -291,7 +291,7 @@ async def create_task(
         },
     )
     try:
-        result = await queue.send(
+        message_id = await send(
             operation,
             {
                 "task_id": task_id,
@@ -305,15 +305,22 @@ async def create_task(
             task_id,
             operation,
         )
-        await result_store.delete(task_id)
+        try:
+            await result_store.delete(task_id)
+        except Exception:
+            logger.exception(
+                "Failed to clean up pending task task_id=%s operation=%s",
+                task_id,
+                operation,
+            )
         raise
     logger.info(
         "Task enqueued task_id=%s operation=%s message_id=%s",
         task_id,
         operation,
-        result["messageId"],
+        message_id,
     )
-    return {"task_id": task_id, "message_id": result["messageId"]}
+    return {"task_id": task_id, "message_id": message_id}
 
 
 @app.post("/tasks/add", status_code=202)

python/queue-subscribers/pyproject.toml

@@ -6,12 +6,11 @@ requires-python = ">=3.12"
 dependencies = [
     "fastapi",
     "vercel-cache",
-    "vercel-workers",
+    "vercel-queue",
 ]
 
 [tool.uv]
 package = false
 
 [[tool.vercel.subscribers]]
-entrypoint = "worker:queue"
-topics = ["add", "multiply"]
+entrypoint = "tasks"

python/queue-subscribers/tasks.py

@@ -1,7 +1,7 @@
 import logging
 from typing import Any
 
-from vercel.workers import subscribe
+from vercel.queue import subscribe
 
 from store import result_store