Runs

import { RunsClient, createConfig } from '@sylphx/sdk'

const config = createConfig({
  secretKey: process.env.SYLPHX_SECRET_KEY!,
  ref: process.env.SYLPHX_PROJECT_REF!,
})

// Single run — wait for completion
const result = await RunsClient.createAndWait(config, {
  image: 'registry.sylphx.com/myorg/trainer:abc123',
  command: ['python', 'train.py', '--fold', '0'],
  resources: { requests: { cpu: '4', memory: '8Gi' } },
  timeoutSeconds: 3600,
})

if (result.exitCode !== 0) {
  throw new Error(`Training failed: ${result.stderr}`)
}
console.log('Accuracy:', JSON.parse(result.stdout).accuracy)

import { RunsClient, createConfig } from '@sylphx/sdk'

const config = createConfig({ secretKey: process.env.SYLPHX_SECRET_KEY! })

const folds = [0, 1, 2, 3, 4, 5, 6, 7, 8]

// Spawn all runs in parallel
const handles = await Promise.all(
  folds.map((fold) =>
    RunsClient.create(config, {
      image: 'registry.sylphx.com/myorg/trainer:abc123def',
      command: ['python', 'train.py', '--fold', String(fold)],
      env: { FOLD_ID: String(fold), DATABASE_URL: process.env.DATABASE_URL! },
      resources: { requests: { cpu: '4', memory: '8Gi' } },
      // Shared feature cache volume (ReadWriteMany — concurrent access OK)
      volumeMounts: [{ volumeId: process.env.CACHE_VOLUME_ID!, mountPath: '/cache' }],
      timeoutSeconds: 7200,
    }),
  ),
)

// Wait for all to complete
const results = await Promise.all(handles.map((h) => h.wait()))
const failures = results.filter((r) => r.exitCode !== 0)
if (failures.length > 0) {
  console.error(`${failures.length}/${folds.length} folds failed`)
}
const avgAccuracy = results
  .filter((r) => r.exitCode === 0)
  .map((r) => JSON.parse(r.stdout).accuracy)
  .reduce((a, b) => a + b, 0) / folds.length
console.log('Average accuracy:', avgAccuracy)