transformers

func ExtractFunctionName ¶

func ExtractFunctionName(ctx context.Context, taskName, environment string) string

ExtractFunctionName extracts the function name from a task name. If environment is set, it strips the "environment." prefix from the task name. Otherwise, it falls back to taking the last segment after splitting on ".".

func NewProjectModel ¶ added in v2.0.8

func NewProjectModel(p *project.Project) (*models.Project, error)

NewProjectModel transforms a project proto into a project DB model.

func NewTaskModel ¶

func NewTaskModel(ctx context.Context, taskId *task.TaskIdentifier, spec *task.TaskSpec) (*models.Task, error)

func NewTriggerModel ¶ added in v2.0.12

func NewTriggerModel(
	ctx context.Context,
	id *common.TriggerIdentifier,
	spec *triggerpb.TriggerSpec,
	automationSpec *taskpb.TriggerAutomationSpec,
) (*models.Trigger, error)

NewTriggerModel builds a models.Trigger from a deploy request. The caller supplies the TriggerIdentifier (including the expected revision for optimistic locking).

func ProjectModelToProject ¶ added in v2.0.8

func ProjectModelToProject(model *models.Project, domains []*project.Domain) (*project.Project, error)

ProjectModelToProject transforms a project DB model into a project proto with injected domains.

func TaskListResultToTasksAndMetadata ¶

func TaskListResultToTasksAndMetadata(ctx context.Context, result *models.TaskListResult,
	latestRuns map[models.TaskName]*models.Action, _ interface{}, _, _ bool) ([]*task.Task, *task.ListTasksResponse_ListTasksMetadata, error)

TaskListResultToTasksAndMetadata transforms a TaskListResult into tasks and metadata. Returns nil tasks and metadata if the input is nil.

func TaskModelsToTaskDetails ¶

func TaskModelsToTaskDetails(ctx context.Context, taskModels []*models.Task) ([]*task.TaskDetails, error)

TaskModelsToTaskDetails transforms task database models to task.TaskDetails objects

func TaskModelsToTaskDetailsWithoutIdentity ¶

func TaskModelsToTaskDetailsWithoutIdentity(ctx context.Context, taskModels []*models.Task) ([]*task.TaskDetails, error)

func TaskModelsToTasks ¶

func TaskModelsToTasks(ctx context.Context, taskModels []*models.Task, latestRuns map[models.TaskName]*models.Action) ([]*task.Task, error)

TaskModelsToTasks uses the above TaskModelsToTaskDetails function to convert task models to task.TaskDetails objects, which are then simplified to task.Task objects.

func ToTaskKey ¶

func ToTaskKey(taskId *task.TaskIdentifier) models.TaskKey

NewTaskKey creates a models.TaskKey from a task.TaskIdentifier

func ToTaskName ¶

func ToTaskName(taskName *task.TaskName) models.TaskName

ToTaskName creates a models.TaskName from a task.TaskName

func ToTaskSpec ¶

func ToTaskSpec(specModel *models.TaskSpec) (*flyteWorkflow.TaskSpec, error)

ToTaskSpec converts TaskSpec model to proto TaskSpec

func ToTraceSpec ¶

func ToTraceSpec(specModel *models.TaskSpec) (*flyteWorkflow.TraceSpec, error)

ToTraceSpec converts TaskSpec model to proto TraceSpec

func ToTriggerKey ¶ added in v2.0.12

func ToTriggerKey(name *common.TriggerName) interfaces.TriggerNameKey

ToTriggerKey creates an interfaces.TriggerNameKey from a common.TriggerName proto.

func TriggerModelToTriggerDetails ¶ added in v2.0.12

func TriggerModelToTriggerDetails(ctx context.Context, m *models.Trigger) (*triggerpb.TriggerDetails, error)

TriggerModelToTriggerDetails converts a latest-state trigger row to the full proto response.

func TriggerModelsToTriggers ¶ added in v2.0.12

func TriggerModelsToTriggers(ctx context.Context, ms []*models.Trigger) ([]*triggerpb.Trigger, error)

TriggerModelsToTriggers converts latest-state trigger rows to the list-view proto.

func TriggerRevisionModelToTriggerDetails ¶ added in v2.0.12

func TriggerRevisionModelToTriggerDetails(ctx context.Context, m *models.TriggerRevision) (*triggerpb.TriggerDetails, error)

TriggerRevisionModelToTriggerDetails converts an immutable revision row to the full proto response.

func TriggerRevisionModelsToTriggerRevisions ¶ added in v2.0.12

func TriggerRevisionModelsToTriggerRevisions(_ context.Context, ms []*models.TriggerRevision) ([]*triggerpb.TriggerRevision, error)

TriggerRevisionModelsToTriggerRevisions converts revision rows to the revision-history proto.

func UnmarshalAutomationSpec ¶ added in v2.0.12

func UnmarshalAutomationSpec(specBytes []byte, automationType string) (*taskpb.TriggerAutomationSpec, error)

UnmarshalAutomationSpec deserializes stored automation spec bytes.

func VersionModelsToVersionResponses ¶

func VersionModelsToVersionResponses(versionModels []*models.TaskVersion) []*task.ListVersionsResponse_VersionResponse

VersionModelsToVersionResponses transforms version database models to task.ListVersionsResponse_VersionResponse objects.