transformers

func PopulateTaskRunDataRowToV1TaskSummary(task *sqlcv1.PopulateTaskRunDataRow, workflowName *string) gen.V1TaskSummary

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

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

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

func ToTask(taskWithData *sqlcv1.PopulateSingleTaskRunDataRow, workflowRunExternalId *pgtype.UUID) gen.V1TaskSummary

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

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

func ToTaskSummary(task *sqlcv1.PopulateTaskRunDataRow) gen.V1TaskSummary

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

func ToTaskSummaryRows(
	tasks []*sqlcv1.PopulateTaskRunDataRow,
) []gen.V1TaskSummary

func ToV1LogLine(log *sqlcv1.V1LogLine) *gen.V1LogLine

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

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

func ToWorkflowRunDetails(
	taskRunEvents []*sqlcv1.ListTaskEventsForWorkflowRunRow,
	workflowRun *v1.WorkflowRunData,
	shape []*dbsqlc.GetWorkflowRunShapeRow,
	tasks []*sqlcv1.PopulateTaskRunDataRow,
	stepIdToTaskExternalId map[pgtype.UUID]pgtype.UUID,
) (gen.V1WorkflowRunDetails, error)

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

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

func ToWorkflowRunTaskRunEventsMany(
	events []*sqlcv1.ListTaskEventsForWorkflowRunRow,
) gen.V1TaskEventList

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