workflow

func (*SWFWorkflowControl) CachedTaskOutput ¶ added in v0.0.55

func (s *SWFWorkflowControl) CachedTaskOutput(ctx context.Context, key jobdb.JobKey, taskType string, ordinal int64, inputHash string) (jobdb.TaskData, error)

CachedTaskOutput reads a successful historical task without rerunning it. Coordinates and input hash must match the runtime's mismatch report exactly.

func (*SWFWorkflowControl) Cancel ¶

func (s *SWFWorkflowControl) Cancel(ctx context.Context, jobKey jobdb.JobKey) error

func (*SWFWorkflowControl) CompleteTask ¶

func (s *SWFWorkflowControl) CompleteTask(ctx context.Context, jobKey jobdb.JobKey, taskOrdinal int64, hash string, outType any) error

func (*SWFWorkflowControl) GetArtifactLazy ¶

func (s *SWFWorkflowControl) GetArtifactLazy(ctx context.Context, tenantId string, key jobdb.ArtifactKey) jobdb.Artifact

func (*SWFWorkflowControl) GetJobRun ¶ added in v0.0.72

func (s *SWFWorkflowControl) GetJobRun(ctx context.Context, req jobdb.GetJobRunRequest) (jobdb.GetJobRunResponse, error)

func (*SWFWorkflowControl) GetWaitingTask ¶

func (s *SWFWorkflowControl) GetWaitingTask(ctx context.Context, jobKey jobdb.JobKey) (workflowctl.TaskHandle, error)

func (*SWFWorkflowControl) InspectJob ¶ added in v0.0.24

func (s *SWFWorkflowControl) InspectJob(ctx context.Context, key jobdb.JobKey) (workflowctl.JobInspection, error)

func (*SWFWorkflowControl) JobResult ¶

func (s *SWFWorkflowControl) JobResult(ctx context.Context, key jobdb.JobKey) (jobdb.JobData, error)

func (*SWFWorkflowControl) ListJobs ¶

func (s *SWFWorkflowControl) ListJobs(ctx context.Context, request jobdb.ListJobsRequest) (jobs []workflowctl.JobItem, nextPage string, err error)

func (*SWFWorkflowControl) StartJob ¶

func (s *SWFWorkflowControl) StartJob(ctx context.Context, req workflowctl.StartJob) (jobdb.JobKey, error)