temporalio.contrib.gcp.cloud_run.id

Run Temporal workers on Google Cloud Run.

CloudRunIdPlugin reads Cloud Run instance metadata (from a worker pool or a service) and sets the client identity from the Cloud Run instance.

Quick start:

import asyncio

from temporalio.client import Client
from temporalio.contrib.gcp.cloud_run.id import CloudRunIdPlugin
from temporalio.worker import Worker

async def main() -> None:
    # Install the plugin on the client; it propagates to workers automatically.
    client = await Client.connect(
        "localhost:7233",
        plugins=[CloudRunIdPlugin()],
    )

    worker = Worker(
        client,
        task_queue="my-task-queue",
        workflows=[MyWorkflow],
        activities=[my_activity],
    )
    await worker.run()

asyncio.run(main())