Jobs

import { CpodClient } from '@cpod/sdk'
const sdk = CpodClient.fromEnv()
 
const job = await sdk.jobs.get('job-01HXYZ')
console.log(job.status)    // "running"
console.log(job.progress)  // 42

from cpod import CpodClient
sdk = CpodClient.from_env()
 
job = await sdk.jobs.get("job-01HXYZ")
print(job.status, job.progress)

import "github.com/cpod-ai/cpod-sdk-go/jobs"
 
client := cpod.New(os.Getenv("CPOD_API_KEY"))
 
job, err := client.Jobs.Get(ctx, "job-01HXYZ")
fmt.Println(job.Status, job.Progress)

const result = await sdk.jobs.wait('job-01HXYZ', {
  timeoutMs: 120_000,   // max wait time (default: 60s)
  pollIntervalMs: 2000, // how often to poll (default: 2s)
})
 
if (result.status === 'completed') {
  console.log(result.output)
} else {
  // status === 'failed' — wait() throws by default; use throwOnFailure: false to reach here
  console.error(result.error)
}
 
// Suppress throw on failure
const job = await sdk.jobs.wait('job-01HXYZ', { throwOnFailure: false })

result = await sdk.jobs.wait(
    "job-01HXYZ",
    timeout_ms=120_000,
    poll_interval_ms=2000,
)
 
if result.status == "completed":
    print(result.output)
else:
    print(result.error)

result, err := client.Jobs.Wait(ctx, "job-01HXYZ", jobs.WaitOptions{
    TimeoutMs:      120000,
    PollIntervalMs: 2000,
})
if err != nil {
    log.Fatal(err)  // job failed or timed out
}
fmt.Println(result.Output)

// Recent failed jobs
const failed = await sdk.jobs.list({ status: 'failed', limit: 20 })
for (const job of failed.items) {
  console.log(job.id, job.type, job.error?.message)
}
 
// All skill jobs in the last 24 hours
const skillJobs = await sdk.jobs.list({
  type: 'skill',
  since: new Date(Date.now() - 86_400_000).toISOString(),
})

from datetime import datetime, timedelta
 
failed = await sdk.jobs.list(status="failed", limit=20)
for job in failed.items:
    print(job.id, job.type, job.error)
 
since = (datetime.utcnow() - timedelta(days=1)).isoformat()
skill_jobs = await sdk.jobs.list(type="skill", since=since)

failed, err := client.Jobs.List(ctx, jobs.ListOptions{
    Status: "failed",
    Limit:  20,
})
for _, j := range failed.Items {
    fmt.Println(j.ID, j.Type)
}

await sdk.jobs.cancel('job-01HXYZ')
 
// Verify
const job = await sdk.jobs.get('job-01HXYZ')
// job.status → "cancelled"

await sdk.jobs.cancel("job-01HXYZ")

err = client.Jobs.Cancel(ctx, "job-01HXYZ")

const stream = await sdk.jobs.logs('job-01HXYZ', { follow: true })
 
for await (const line of stream) {
  console.log(`[${line.timestamp}] ${line.level}: ${line.message}`)
}

async for line in sdk.jobs.logs("job-01HXYZ", follow=True):
    print(f"[{line.timestamp}] {line.level}: {line.message}")

stream, err := client.Jobs.Logs(ctx, "job-01HXYZ", true)
defer stream.Close()
 
for stream.Next() {
    line := stream.Line()
    fmt.Printf("[%s] %s: %s\n", line.Timestamp, line.Level, line.Message)
}