Ship background jobs
without the infra.

from relay import Relay, JobConfig

relay = Relay(api_key="rly_live_...")

@relay.job(
    id="generate-report",
    queue="analytics",
    retries=3,
    timeout="5m",
)
async def generate_report(payload: ReportPayload) -> None:
    data = await fetch_report_data(payload.report_id)
    file = await render_report(data, payload.format)

    await storage.upload(
        f"reports/{payload.report_id}.{payload.format}", file
    )
    await notify.email(
        template="report-ready",
        data={"report_id": payload.report_id},
    )


# Enqueue from your FastAPI route
@app.post("/reports")
async def create_report(body: CreateReportRequest):
    job = await generate_report.enqueue(
        ReportPayload(report_id=body.id, format="pdf")
    )
    return {"job_id": job.id, "status": "queued"}

package main

import (
    "context"
    relay "github.com/relay-run/relay-go"
)

type ReportPayload struct {
    ReportID string `json:"reportId"`
    Format   string `json:"format"`
}

var generateReport = relay.DefineJob[ReportPayload](relay.JobConfig{
    ID:      "generate-report",
    Queue:   "analytics",
    Retries: 3,
    Timeout: "5m",
    Handler: func(ctx context.Context, p ReportPayload) error {
        data, err := fetchReportData(ctx, p.ReportID)
        if err != nil {
            return err
        }
        file, err := renderReport(data, p.Format)
        if err != nil {
            return err
        }
        return storage.Upload(ctx, "reports/"+p.ReportID+"."+p.Format, file)
    },
})

// Enqueue from your HTTP handler
func createReportHandler(w http.ResponseWriter, r *http.Request) {
    job, err := generateReport.Enqueue(r.Context(), ReportPayload{
        ReportID: r.FormValue("id"),
        Format:   "pdf",
    })
    // job.ID → "job_2n4kx7p"
}

# Enqueue a job via the REST API
curl -X POST https://api.relay.run/v1/jobs/enqueue \
  -H "Authorization: Bearer rly_live_sk_..." \
  -H "Content-Type: application/json" \
  -d '{
    "jobId": "generate-report",
    "queue": "analytics",
    "payload": {
      "reportId": "rpt_abc123",
      "format": "pdf"
    },
    "options": {
      "retries": 3,
      "timeout": "5m"
    }
  }'

# Response
# {
#   "id": "job_2n4kx7p",
#   "status": "queued",
#   "region": "eu-west-1",
#   "enqueuedAt": "2026-06-21T14:32:00.000Z"
# }