taskferry-cloudtasks

Run Taskferry tasks on Google Cloud Tasks — push-based, serverless, no worker process.

sequenceDiagram
    participant App
    participant TP as Taskferry
    participant CT as Cloud Tasks
    participant SVC as your service

    App->>TP: tasks.submit("myapp:send_email", 42)
    TP->>CT: create_task(http_request)
    CT->>SVC: POST /_taskferry/execute
    SVC->>SVC: handle_request(body)

Cloud Tasks is architecturally the opposite of Procrastinate — nothing polls, no worker exists, Google pushes an HTTP request at your service. The application code does not change:

runtime.tasks.submit("myapp.tasks:send_email", 42, queue="email")

Install

pip install 'taskferry-cloudtasks[gcp]'

Configure

runtime = Taskferry.from_mapping(
    {
        "backends": {
            "push": {
                "factory": "cloudtasks",
                "project": "my-project",
                "location": "europe-west1",
                "url": "https://my-service.run.app/_taskferry/execute",
                "service_account_email": "runner@my-project.iam.gserviceaccount.com",
            }
        },
        "defaults": {"task": "push"},
    }
)

Receive

handle_request takes bytes, so it works with any framework:

# Django
from taskferry import FunctionRegistry
from taskferry_cloudtasks import handle_request

REGISTRY = FunctionRegistry(allowed_modules=["myapp"])


def taskferry_execute(request):
    handle_request(request.body, dict(request.headers), registry=REGISTRY)
    return HttpResponse(status=204)

# FastAPI
@app.post("/_taskferry/execute")
async def execute(request: Request):
    handle_request(await request.body(), dict(request.headers), registry=REGISTRY)
    return Response(status_code=204)

Authenticate the endpoint. Verify the OIDC token Cloud Tasks sends, or put the service behind IAM. Taskferry never sees your framework's request object — that is what makes it portable, and it is why this part is yours.

Be idempotent. Cloud Tasks delivery is at-least-once.

Capabilities

A handle refuses status() here instead of returning a plausible UNKNOWN forever. Record what you need in your own database, where it is actually true.

License

Apache-2.0.