transformers

func PopulateTaskRunDataRowToV1TaskSummary(task *v1.TaskWithPayloads, workflowName *string) gen.V1TaskSummary

func StatusToTaskRunMetrics(metrics *[]v1.TaskRunMetric) gen.V1TaskRunMetrics

func TaskRunDataRowToWorkflowRunsMany(
	tasks []*v1.TaskWithPayloads,
	taskIdToWorkflowName map[int64]string,
	total int, limit, offset int64,
) gen.V1TaskSummaryList

func ToCancelledOrReplayedTaskResponse(ids []string) gen.V1ReplayedTasks

func ToDagChildren(
	tasks []*v1.TaskWithPayloads,
	taskIdToDagExternalId map[int64]uuid.UUID,
) []gen.V1DagChildren

func ToSlotState(slots []*sqlcv1.ListSemaphoreSlotsWithStateForWorkerRow, remainingSlots int) *[]gen.SemaphoreSlots

func ToTask(taskWithData *v1.TaskWithPayloads, workflowRunExternalId uuid.UUID, workflowVersion *sqlcv1.GetWorkflowVersionByIdRow) gen.V1TaskSummary

func ToTaskRunEventMany(
	events []*sqlcv1.ListTaskEventsRow,
	taskExternalId uuid.UUID,
) gen.V1TaskEventList

func ToTaskSummary(task *v1.TaskWithPayloads) gen.V1TaskSummary

func ToTaskSummaryMany(
	tasks []*v1.TaskWithPayloads,
	total int, limit, offset int64,
) gen.V1TaskSummaryList

func ToTaskSummaryRows(
	tasks []*v1.TaskWithPayloads,
) []gen.V1TaskSummary

func ToTaskTimings(
	timings []*sqlcv1.PopulateTaskRunDataRow,
	idsToDepth map[uuid.UUID]int32,
) []gen.V1TaskTiming

func ToV1CELDebugResponse(success bool, output *bool, err *string) gen.V1CELDebugResponse

func ToV1Event(event *v1.EventWithPayload) gen.V1Event

func ToV1EventList(events []*v1.EventWithPayload, limit, offset, total int64) gen.V1EventList

func ToV1Filter(filter *sqlcv1.V1Filter) gen.V1Filter

func ToV1FilterList(filters []*sqlcv1.V1Filter, total, limit, offset int64) gen.V1FilterList

func ToV1LogLine(log *v1.ListLogLineRow) *gen.V1LogLine

func ToV1OtelSpan(spans []*repository.OtelSpanRow) []gen.OtelSpan

func ToV1OtelSpanList(spans []*repository.OtelSpanRow, retryCounts []int32, limit, offset, total int64) gen.OtelSpanList

func ToV1Webhook(webhook *sqlcv1.V1IncomingWebhook) gen.V1Webhook

func ToV1WebhookList(webhooks []*sqlcv1.V1IncomingWebhook) gen.V1WebhookList

func ToV1WebhookResponse(message, challenge *string, event *sqlcv1.Event) (*gen.V1WebhookResponse, error)

func ToWorkerRuntimeInfo(worker *sqlcv1.Worker) *gen.WorkerRuntimeInfo

func ToWorkerSqlc(worker *sqlcv1.Worker, slotConfig map[string]gen.WorkerSlotConfig, actions []string, workflows *[]*sqlcv1.Workflow, labels []*sqlcv1.ListWorkerLabelsRow) *gen.Worker

func ToWorkflowRunDetails(
	taskRunEvents []*v1.TaskEventWithPayloads,
	workflowRun *v1.WorkflowRunData,
	shape []*sqlcv1.GetWorkflowShapeRow,
	tasks []*v1.TaskWithPayloads,
	stepIdToTaskExternalId map[uuid.UUID]uuid.UUID,
	workflowVersion *sqlcv1.GetWorkflowVersionByIdRow,
) (gen.V1WorkflowRunDetails, error)

func ToWorkflowRunDisplayNamesList(
	displayNames []*sqlcv1.ListWorkflowRunDisplayNamesRow,
) gen.V1WorkflowRunDisplayNameList

func ToWorkflowRunMany(
	tasks []*v1.WorkflowRunData,
	dagExternalIdToChildren map[uuid.UUID][]gen.V1TaskSummary,
	taskIdToActionId map[int64]string,
	workflowIdsToNames map[uuid.UUID]string,
	total int, limit, offset int64,
) gen.V1TaskSummaryList

func ToWorkflowRunTaskRunEventsMany(
	events []*v1.TaskEventWithPayloads,
) gen.V1TaskEventList

func WorkflowRunDataToV1TaskSummary(task *v1.WorkflowRunData, workflowIdsToNames map[uuid.UUID]string, actionId string) gen.V1TaskSummary