workflowctl

type JobItem struct {
	TaskData swf.TaskData
	swf.JobSummary
}

type StartJob struct {
	TenantId     string                 `json:"tenantId"`
	JobID        string                 `json:"job_id,omitempty"`
	RecipeName   string                 `json:"recipe"`
	Inputs       map[string]interface{} `json:"inputs,omitempty"`
	Artifacts    []swf.Artifact         `json:"-"`
	ArtifactRefs []recipeartifacts.Ref  `json:"artifact_refs,omitempty"`
	JobContext   contextual.JobContext  `json:"context,omitempty"`
	GitRef       string                 `json:"git,omitempty"`
	SubmittedAt  *time.Time             `json:"submitted_at,omitempty"`
	InputHash    string                 `json:"input_hash,omitempty"`
}

type TaskHandle = swf.TaskHandle

type WorkflowControl interface {
	StartJob(ctx context.Context, req StartJob) (swf.JobKey, error)
	Cancel(ctx context.Context, jobKey swf.JobKey) error
	ListJobs(ctx context.Context, request swf.ListJobsRequest) (jobs []JobItem, nextPage string, err error)
	CompleteTask(ctx context.Context, jobKey swf.JobKey, taskOrdinal int64, hash string, data any) error
	GetWaitingTask(ctx context.Context, jobKey swf.JobKey) (TaskHandle, error)
	GetArtifactLazy(ctx context.Context, tenantId string, key swf.ArtifactKey) swf.Artifact
	JobResult(ctx context.Context, key swf.JobKey) (swf.JobData, error)
}