runs

Overview ¶

Package runs provides utilities for StoryRun and StepRun management.

This package contains subpackages that provide specialized functionality for run lifecycle management, including identity, inputs, status patching, and validation.

Subpackages ¶

childrun: Child StepRun spec generation and management

spec := childrun.BuildSpec(storyRun, step, index)

identity: ServiceAccount identity management for engram runners

runner := identity.NewEngramRunner(storyRunName)
saName := runner.ServiceAccountName()
subject := runner.Subject(namespace)

inputs: Input resolution and parsing for StoryRuns

inputs, err := inputs.Parse(storyRun.Spec.Inputs)

list: StepRun listing and filtering utilities

stepRuns, err := list.StepRunsForStoryRun(ctx, client, storyRun)

status: Status patching for StoryRun and StepRun

status.PatchStoryRunPhase(ctx, client, storyRun, enums.PhaseSucceeded, "", "Completed")
status.PatchStepRunPhase(ctx, client, stepRun, enums.PhaseRunning, "", "Running")

validation: Downstream target validation for streaming

err := validation.ValidateDownstreamTargets(targets)
err := validation.ValidateGRPCEndpoint(endpoint)