transformers

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

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 pgtype.UUID, workflowVersion *sqlcv1.GetWorkflowVersionByIdRow) gen.V1TaskSummary

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

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

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[string]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 *sqlcv1.V1LogLine) *gen.V1LogLine

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

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

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

func ToWorkerSqlc(worker *sqlcv1.Worker, remainingSlots *int, webhookUrl *string, actions []string, workflows *[]*sqlcv1.Workflow) *gen.Worker

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

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

func ToWorkflowRunExternalIds(
	externalIds []pgtype.UUID,
) gen.V1WorkflowRunExternalIdList

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

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

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