flyteadmin

type APIClient struct {
	AdminServiceApi *AdminServiceApiService
	// contains filtered or unexported fields
}

type APIKey struct {
	Key    string
	Prefix string
}

type APIResponse struct {
	*http.Response `json:"-"`
	Message        string `json:"message,omitempty"`
	// Operation is the name of the swagger operation.
	Operation string `json:"operation,omitempty"`
	// RequestURL is the request URL. This value is always available, even if the
	// embedded *http.Response is nil.
	RequestURL string `json:"url,omitempty"`
	// Method is the HTTP method used for the request.  This value is always
	// available, even if the embedded *http.Response is nil.
	Method string `json:"method,omitempty"`
	// Payload holds the contents of the response body (which may be nil or empty).
	// This is provided here as the raw response.Body() reader will have already
	// been drained.
	Payload []byte `json:"-"`
}

type AdminAbortMetadata struct {
	// In the case of a user-specified abort, this will pass along the user-supplied cause.
	Cause     string `json:"cause,omitempty"`
	Principal string `json:"principal,omitempty"`
}

type AdminAnnotations struct {
	// Map of custom annotations to be applied to the execution resource.
	Values map[string]string `json:"values,omitempty"`
}

type AdminAuth struct {
	// Defines an optional iam role which will be used for tasks run in executions created with this launch plan.
	AssumableIamRole string `json:"assumable_iam_role,omitempty"`
	// Defines an optional kubernetes service account which will be used for tasks run in executions created with this launch plan.
	KubernetesServiceAccount string `json:"kubernetes_service_account,omitempty"`
}

type AdminAuthRole struct {
	// Defines an optional iam role which will be used for tasks run in executions created with this launch plan.
	AssumableIamRole string `json:"assumable_iam_role,omitempty"`
	// Defines an optional kubernetes service account which will be used for tasks run in executions created with this launch plan.
	KubernetesServiceAccount string `json:"kubernetes_service_account,omitempty"`
}

type AdminClusterAssignment struct {
	ClusterPoolName string `json:"cluster_pool_name,omitempty"`
}

type AdminClusterResourceAttributes struct {
	// Custom resource attributes which will be applied in cluster resource creation (e.g. quotas). Map keys are the *case-sensitive* names of variables in templatized resource files. Map values should be the custom values which get substituted during resource creation.
	Attributes map[string]string `json:"attributes,omitempty"`
}

type AdminCronSchedule struct {
	Schedule string `json:"schedule,omitempty"`
	Offset   string `json:"offset,omitempty"`
}

type AdminDescription struct {
	Value    string                  `json:"value,omitempty"`
	Uri      string                  `json:"uri,omitempty"`
	Format   *AdminDescriptionFormat `json:"format,omitempty"`
	IconLink string                  `json:"icon_link,omitempty"`
}

type AdminDescriptionEntity struct {
	// id represents the unique identifier of the description entity.
	Id *CoreIdentifier `json:"id,omitempty"`
	// One-liner overview of the entity.
	ShortDescription string `json:"short_description,omitempty"`
	// Full user description with formatting preserved.
	LongDescription *AdminDescription `json:"long_description,omitempty"`
	// Optional link to source code used to define this entity.
	SourceCode *AdminSourceCode `json:"source_code,omitempty"`
	// User-specified tags. These are arbitrary and can be used for searching filtering and discovering tasks.
	Tags []string `json:"tags,omitempty"`
}

type AdminDescriptionEntityList struct {
	// A list of DescriptionEntities returned based on the request.
	DescriptionEntities []AdminDescriptionEntity `json:"descriptionEntities,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page in a query. If there are no more results, this value will be empty.
	Token string `json:"token,omitempty"`
}

type AdminDescriptionFormat string

type AdminDomain struct {
	// Globally unique domain name.
	Id string `json:"id,omitempty"`
	// Display name.
	Name string `json:"name,omitempty"`
}

type AdminEmailNotification struct {
	RecipientsEmail []string `json:"recipients_email,omitempty"`
}

type AdminEnvs struct {
	// Map of custom environment variables to be applied to the execution resource.
	Values []CoreKeyValuePair `json:"values,omitempty"`
}

type AdminExecution struct {
	// Unique identifier of the workflow execution.
	Id *CoreWorkflowExecutionIdentifier `json:"id,omitempty"`
	// User-provided configuration and inputs for launching the execution.
	Spec *AdminExecutionSpec `json:"spec,omitempty"`
	// Execution results.
	Closure *AdminExecutionClosure `json:"closure,omitempty"`
}

type AdminExecutionClosure struct {
	// Output URI in the case of a successful execution. DEPRECATED. Use GetExecutionData to fetch output data instead.
	Outputs *AdminLiteralMapBlob `json:"outputs,omitempty"`
	// Error information in the case of a failed execution.
	Error_ *CoreExecutionError `json:"error,omitempty"`
	// In the case of a user-specified abort, this will pass along the user-supplied cause.
	AbortCause string `json:"abort_cause,omitempty"`
	// In the case of a user-specified abort, this will pass along the user and their supplied cause.
	AbortMetadata *AdminAbortMetadata `json:"abort_metadata,omitempty"`
	// Raw output data produced by this execution. DEPRECATED. Use GetExecutionData to fetch output data instead.
	OutputData     *CoreLiteralMap `json:"output_data,omitempty"`
	ComputedInputs *CoreLiteralMap `json:"computed_inputs,omitempty"`
	// Most recent recorded phase for the execution.
	Phase *CoreWorkflowExecutionPhase `json:"phase,omitempty"`
	// Reported time at which the execution began running.
	StartedAt time.Time `json:"started_at,omitempty"`
	// The amount of time the execution spent running.
	Duration string `json:"duration,omitempty"`
	// Reported time at which the execution was created.
	CreatedAt time.Time `json:"created_at,omitempty"`
	// Reported time at which the execution was last updated.
	UpdatedAt time.Time `json:"updated_at,omitempty"`
	// The notification settings to use after merging the CreateExecutionRequest and the launch plan notification settings. An execution launched with notifications will always prefer that definition to notifications defined statically in a launch plan.
	Notifications []AdminNotification `json:"notifications,omitempty"`
	// Identifies the workflow definition for this execution.
	WorkflowId         *CoreIdentifier                   `json:"workflow_id,omitempty"`
	StateChangeDetails *AdminExecutionStateChangeDetails `json:"state_change_details,omitempty"`
}

type AdminExecutionClusterLabel struct {
	Value string `json:"value,omitempty"`
}

type AdminExecutionCreateRequest struct {
	Project string              `json:"project,omitempty"`
	Domain  string              `json:"domain,omitempty"`
	Name    string              `json:"name,omitempty"`
	Spec    *AdminExecutionSpec `json:"spec,omitempty"`
	Inputs  *CoreLiteralMap     `json:"inputs,omitempty"`
}

type AdminExecutionCreateResponse struct {
	Id *CoreWorkflowExecutionIdentifier `json:"id,omitempty"`
}

type AdminExecutionList struct {
	Executions []AdminExecution `json:"executions,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page in a query. If there are no more results, this value will be empty.
	Token string `json:"token,omitempty"`
}

type AdminExecutionMetadata struct {
	Mode *ExecutionMetadataExecutionMode `json:"mode,omitempty"`
	// Identifier of the entity that triggered this execution. For systems using back-end authentication any value set here will be discarded in favor of the authenticated user context.
	Principal string `json:"principal,omitempty"`
	// Indicates the nestedness of this execution. If a user launches a workflow execution, the default nesting is 0. If this execution further launches a workflow (child workflow), the nesting level is incremented by 0 => 1 Generally, if workflow at nesting level k launches a workflow then the child workflow will have nesting = k + 1.
	Nesting int64 `json:"nesting,omitempty"`
	// For scheduled executions, the requested time for execution for this specific schedule invocation.
	ScheduledAt         time.Time                    `json:"scheduled_at,omitempty"`
	ParentNodeExecution *CoreNodeExecutionIdentifier `json:"parent_node_execution,omitempty"`
	// Optional, a reference workflow execution related to this execution. In the case of a relaunch, this references the original workflow execution.
	ReferenceExecution *CoreWorkflowExecutionIdentifier `json:"reference_execution,omitempty"`
	// Optional, platform-specific metadata about the execution. In this the future this may be gated behind an ACL or some sort of authorization.
	SystemMetadata *AdminSystemMetadata `json:"system_metadata,omitempty"`
}

type AdminExecutionQueueAttributes struct {
	// Tags used for assigning execution queues for tasks defined within this project.
	Tags []string `json:"tags,omitempty"`
}

type AdminExecutionRecoverRequest struct {
	// Identifier of the workflow execution to recover.
	Id   *CoreWorkflowExecutionIdentifier `json:"id,omitempty"`
	Name string                           `json:"name,omitempty"`
	// Additional metadata which will be used to overwrite any metadata in the reference execution when triggering a recovery execution.
	Metadata *AdminExecutionMetadata `json:"metadata,omitempty"`
}

type AdminExecutionRelaunchRequest struct {
	Id   *CoreWorkflowExecutionIdentifier `json:"id,omitempty"`
	Name string                           `json:"name,omitempty"`
	// Allows for all cached values of a workflow and its tasks to be overwritten for a single execution. If enabled, all calculations are performed even if cached results would be available, overwriting the stored data once execution finishes successfully.
	OverwriteCache bool `json:"overwrite_cache,omitempty"`
}

type AdminExecutionSpec struct {
	LaunchPlan *CoreIdentifier         `json:"launch_plan,omitempty"`
	Inputs     *CoreLiteralMap         `json:"inputs,omitempty"`
	Metadata   *AdminExecutionMetadata `json:"metadata,omitempty"`
	// List of notifications based on Execution status transitions When this list is not empty it is used rather than any notifications defined in the referenced launch plan. When this list is empty, the notifications defined for the launch plan will be applied.
	Notifications *AdminNotificationList `json:"notifications,omitempty"`
	// This should be set to true if all notifications are intended to be disabled for this execution.
	DisableAll bool `json:"disable_all,omitempty"`
	// Labels to apply to the execution resource.
	Labels *AdminLabels `json:"labels,omitempty"`
	// Annotations to apply to the execution resource.
	Annotations *AdminAnnotations `json:"annotations,omitempty"`
	// Optional: security context override to apply this execution.
	SecurityContext *CoreSecurityContext `json:"security_context,omitempty"`
	// Optional: auth override to apply this execution.
	AuthRole *AdminAuthRole `json:"auth_role,omitempty"`
	// Indicates the runtime priority of the execution.
	QualityOfService *CoreQualityOfService `json:"quality_of_service,omitempty"`
	// Controls the maximum number of task nodes that can be run in parallel for the entire workflow. This is useful to achieve fairness. Note: MapTasks are regarded as one unit, and parallelism/concurrency of MapTasks is independent from this.
	MaxParallelism      int32                     `json:"max_parallelism,omitempty"`
	RawOutputDataConfig *AdminRawOutputDataConfig `json:"raw_output_data_config,omitempty"`
	// Controls how to select an available cluster on which this execution should run.
	ClusterAssignment *AdminClusterAssignment `json:"cluster_assignment,omitempty"`
	// Allows for the interruptible flag of a workflow to be overwritten for a single execution. Omitting this field uses the workflow's value as a default. As we need to distinguish between the field not being provided and its default value false, we have to use a wrapper around the bool field.
	Interruptible bool `json:"interruptible,omitempty"`
	// Allows for all cached values of a workflow and its tasks to be overwritten for a single execution. If enabled, all calculations are performed even if cached results would be available, overwriting the stored data once execution finishes successfully.
	OverwriteCache bool `json:"overwrite_cache,omitempty"`
	// Environment variables to be set for the execution.
	Envs *AdminEnvs `json:"envs,omitempty"`
	// Tags to be set for the execution.
	Tags []string `json:"tags,omitempty"`
}

type AdminExecutionState string

type AdminExecutionStateChangeDetails struct {
	// The state of the execution is used to control its visibility in the UI/CLI.
	State *AdminExecutionState `json:"state,omitempty"`
	// This timestamp represents when the state changed.
	OccurredAt time.Time `json:"occurred_at,omitempty"`
	Principal  string    `json:"principal,omitempty"`
}

type AdminExecutionTerminateRequest struct {
	// Uniquely identifies the individual workflow execution to be terminated.
	Id *CoreWorkflowExecutionIdentifier `json:"id,omitempty"`
	// Optional reason for aborting.
	Cause string `json:"cause,omitempty"`
}

type AdminExecutionTerminateResponse struct {
}

type AdminExecutionUpdateRequest struct {
	Id    *CoreWorkflowExecutionIdentifier `json:"id,omitempty"`
	State *AdminExecutionState             `json:"state,omitempty"`
}

type AdminExecutionUpdateResponse struct {
}

type AdminFixedRate struct {
	Value int64               `json:"value,omitempty"`
	Unit  *AdminFixedRateUnit `json:"unit,omitempty"`
}

type AdminFixedRateUnit string

type AdminFlyteUrLs struct {
	Inputs  string `json:"inputs,omitempty"`
	Outputs string `json:"outputs,omitempty"`
	Deck    string `json:"deck,omitempty"`
}

type AdminGetVersionResponse struct {
	ControlPlaneVersion *AdminVersion `json:"control_plane_version,omitempty"`
}

type AdminLabels struct {
	// Map of custom labels to be applied to the execution resource.
	Values map[string]string `json:"values,omitempty"`
}

type AdminLaunchPlan struct {
	// Uniquely identifies a launch plan entity.
	Id *CoreIdentifier `json:"id,omitempty"`
	// User-provided launch plan details, including reference workflow, inputs and other metadata.
	Spec *AdminLaunchPlanSpec `json:"spec,omitempty"`
	// Values computed by the flyte platform after launch plan registration.
	Closure *AdminLaunchPlanClosure `json:"closure,omitempty"`
}

type AdminLaunchPlanClosure struct {
	// Indicate the Launch plan state.
	State           *AdminLaunchPlanState `json:"state,omitempty"`
	ExpectedInputs  *CoreParameterMap     `json:"expected_inputs,omitempty"`
	ExpectedOutputs *CoreVariableMap      `json:"expected_outputs,omitempty"`
	// Time at which the launch plan was created.
	CreatedAt time.Time `json:"created_at,omitempty"`
	// Time at which the launch plan was last updated.
	UpdatedAt time.Time `json:"updated_at,omitempty"`
}

type AdminLaunchPlanCreateRequest struct {
	// Uniquely identifies a launch plan entity.
	Id *CoreIdentifier `json:"id,omitempty"`
	// User-provided launch plan details, including reference workflow, inputs and other metadata.
	Spec *AdminLaunchPlanSpec `json:"spec,omitempty"`
}

type AdminLaunchPlanCreateResponse struct {
}

type AdminLaunchPlanList struct {
	LaunchPlans []AdminLaunchPlan `json:"launch_plans,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page in a query. If there are no more results, this value will be empty.
	Token string `json:"token,omitempty"`
}

type AdminLaunchPlanMetadata struct {
	Schedule      *AdminSchedule      `json:"schedule,omitempty"`
	Notifications []AdminNotification `json:"notifications,omitempty"`
}

type AdminLaunchPlanSpec struct {
	WorkflowId     *CoreIdentifier          `json:"workflow_id,omitempty"`
	EntityMetadata *AdminLaunchPlanMetadata `json:"entity_metadata,omitempty"`
	// Input values to be passed for the execution. These can be overriden when an execution is created with this launch plan.
	DefaultInputs *CoreParameterMap `json:"default_inputs,omitempty"`
	// Fixed, non-overridable inputs for the Launch Plan. These can not be overriden when an execution is created with this launch plan.
	FixedInputs *CoreLiteralMap `json:"fixed_inputs,omitempty"`
	Role        string          `json:"role,omitempty"`
	// Custom labels to be applied to the execution resource.
	Labels *AdminLabels `json:"labels,omitempty"`
	// Custom annotations to be applied to the execution resource.
	Annotations *AdminAnnotations `json:"annotations,omitempty"`
	// Indicates the permission associated with workflow executions triggered with this launch plan.
	Auth            *AdminAuth           `json:"auth,omitempty"`
	AuthRole        *AdminAuthRole       `json:"auth_role,omitempty"`
	SecurityContext *CoreSecurityContext `json:"security_context,omitempty"`
	// Indicates the runtime priority of the execution.
	QualityOfService *CoreQualityOfService `json:"quality_of_service,omitempty"`
	// Encapsulates user settings pertaining to offloaded data (i.e. Blobs, Schema, query data, etc.).
	RawOutputDataConfig *AdminRawOutputDataConfig `json:"raw_output_data_config,omitempty"`
	// Controls the maximum number of tasknodes that can be run in parallel for the entire workflow. This is useful to achieve fairness. Note: MapTasks are regarded as one unit, and parallelism/concurrency of MapTasks is independent from this.
	MaxParallelism int32 `json:"max_parallelism,omitempty"`
	// Allows for the interruptible flag of a workflow to be overwritten for a single execution. Omitting this field uses the workflow's value as a default. As we need to distinguish between the field not being provided and its default value false, we have to use a wrapper around the bool field.
	Interruptible bool `json:"interruptible,omitempty"`
	// Allows for all cached values of a workflow and its tasks to be overwritten for a single execution. If enabled, all calculations are performed even if cached results would be available, overwriting the stored data once execution finishes successfully.
	OverwriteCache bool `json:"overwrite_cache,omitempty"`
	// Environment variables to be set for the execution.
	Envs *AdminEnvs `json:"envs,omitempty"`
}

type AdminLaunchPlanState string

type AdminLaunchPlanUpdateRequest struct {
	// Identifier of launch plan for which to change state. +required.
	Id *CoreIdentifier `json:"id,omitempty"`
	// Desired state to apply to the launch plan. +required.
	State *AdminLaunchPlanState `json:"state,omitempty"`
}

type AdminLaunchPlanUpdateResponse struct {
}

type AdminListMatchableAttributesResponse struct {
	Configurations []AdminMatchableAttributesConfiguration `json:"configurations,omitempty"`
}

type AdminLiteralMapBlob struct {
	Values *CoreLiteralMap `json:"values,omitempty"`
	Uri    string          `json:"uri,omitempty"`
}

type AdminMatchableAttributesConfiguration struct {
	Attributes *AdminMatchingAttributes `json:"attributes,omitempty"`
	Domain     string                   `json:"domain,omitempty"`
	Project    string                   `json:"project,omitempty"`
	Workflow   string                   `json:"workflow,omitempty"`
	LaunchPlan string                   `json:"launch_plan,omitempty"`
}

type AdminMatchableResource string

type AdminMatchingAttributes struct {
	TaskResourceAttributes    *AdminTaskResourceAttributes    `json:"task_resource_attributes,omitempty"`
	ClusterResourceAttributes *AdminClusterResourceAttributes `json:"cluster_resource_attributes,omitempty"`
	ExecutionQueueAttributes  *AdminExecutionQueueAttributes  `json:"execution_queue_attributes,omitempty"`
	ExecutionClusterLabel     *AdminExecutionClusterLabel     `json:"execution_cluster_label,omitempty"`
	QualityOfService          *CoreQualityOfService           `json:"quality_of_service,omitempty"`
	PluginOverrides           *AdminPluginOverrides           `json:"plugin_overrides,omitempty"`
	WorkflowExecutionConfig   *AdminWorkflowExecutionConfig   `json:"workflow_execution_config,omitempty"`
	ClusterAssignment         *AdminClusterAssignment         `json:"cluster_assignment,omitempty"`
}

type AdminNamedEntity struct {
	// Resource type of the named entity. One of Task, Workflow or LaunchPlan.
	ResourceType *CoreResourceType           `json:"resource_type,omitempty"`
	Id           *AdminNamedEntityIdentifier `json:"id,omitempty"`
	// Additional metadata around a named entity.
	Metadata *AdminNamedEntityMetadata `json:"metadata,omitempty"`
}

type AdminNamedEntityIdentifier struct {
	// Name of the project the resource belongs to.
	Project string `json:"project,omitempty"`
	// Name of the domain the resource belongs to. A domain can be considered as a subset within a specific project.
	Domain string `json:"domain,omitempty"`
	Name   string `json:"name,omitempty"`
}

type AdminNamedEntityIdentifierList struct {
	// A list of identifiers.
	Entities []AdminNamedEntityIdentifier `json:"entities,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page in a query. If there are no more results, this value will be empty.
	Token string `json:"token,omitempty"`
}

type AdminNamedEntityList struct {
	Entities []AdminNamedEntity `json:"entities,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page in a query. If there are no more results, this value will be empty.
	Token string `json:"token,omitempty"`
}

type AdminNamedEntityMetadata struct {
	Description string `json:"description,omitempty"`
	// Shared state across all version of the entity At this point in time, only workflow entities can have their state archived.
	State *AdminNamedEntityState `json:"state,omitempty"`
}

type AdminNamedEntityState string

type AdminNamedEntityUpdateRequest struct {
	ResourceType *CoreResourceType           `json:"resource_type,omitempty"`
	Id           *AdminNamedEntityIdentifier `json:"id,omitempty"`
	Metadata     *AdminNamedEntityMetadata   `json:"metadata,omitempty"`
}

type AdminNamedEntityUpdateResponse struct {
}

type AdminNodeExecutionClosure struct {
	// Links to a remotely stored, serialized core.LiteralMap of node execution outputs. DEPRECATED. Use GetNodeExecutionData to fetch output data instead.
	OutputUri string              `json:"output_uri,omitempty"`
	Error_    *CoreExecutionError `json:"error,omitempty"`
	// Raw output data produced by this node execution. DEPRECATED. Use GetNodeExecutionData to fetch output data instead.
	OutputData *CoreLiteralMap `json:"output_data,omitempty"`
	// The last recorded phase for this node execution.
	Phase *CoreNodeExecutionPhase `json:"phase,omitempty"`
	// Time at which the node execution began running.
	StartedAt time.Time `json:"started_at,omitempty"`
	// The amount of time the node execution spent running.
	Duration string `json:"duration,omitempty"`
	// Time at which the node execution was created.
	CreatedAt time.Time `json:"created_at,omitempty"`
	// Time at which the node execution was last updated.
	UpdatedAt            time.Time                          `json:"updated_at,omitempty"`
	WorkflowNodeMetadata *FlyteidladminWorkflowNodeMetadata `json:"workflow_node_metadata,omitempty"`
	TaskNodeMetadata     *FlyteidladminTaskNodeMetadata     `json:"task_node_metadata,omitempty"`
	DeckUri              string                             `json:"deck_uri,omitempty"`
	// dynamic_job_spec_uri is the location of the DynamicJobSpec proto message for a DynamicWorkflow. This is required to correctly recover partially completed executions where the subworkflow has already been compiled.
	DynamicJobSpecUri string `json:"dynamic_job_spec_uri,omitempty"`
}

type AdminNodeExecutionEventRequest struct {
	RequestId string `json:"request_id,omitempty"`
	// Details about the event that occurred.
	Event *EventNodeExecutionEvent `json:"event,omitempty"`
}

type AdminNodeExecutionEventResponse struct {
}

type AdminNodeExecutionGetDataResponse struct {
	// Signed url to fetch a core.LiteralMap of node execution inputs. Deprecated: Please use full_inputs instead.
	Inputs *AdminUrlBlob `json:"inputs,omitempty"`
	// Signed url to fetch a core.LiteralMap of node execution outputs. Deprecated: Please use full_outputs instead.
	Outputs *AdminUrlBlob `json:"outputs,omitempty"`
	// Full_inputs will only be populated if they are under a configured size threshold.
	FullInputs *CoreLiteralMap `json:"full_inputs,omitempty"`
	// Full_outputs will only be populated if they are under a configured size threshold.
	FullOutputs *CoreLiteralMap `json:"full_outputs,omitempty"`
	// Optional Workflow closure for a dynamically generated workflow, in the case this node yields a dynamic workflow we return its structure here.
	DynamicWorkflow *FlyteidladminDynamicWorkflowNodeMetadata `json:"dynamic_workflow,omitempty"`
	FlyteUrls       *AdminFlyteUrLs                           `json:"flyte_urls,omitempty"`
}

type AdminNodeExecutionList struct {
	NodeExecutions []FlyteidladminNodeExecution `json:"node_executions,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page in a query. If there are no more results, this value will be empty.
	Token string `json:"token,omitempty"`
}

type AdminNodeExecutionMetaData struct {
	// Node executions are grouped depending on retries of the parent Retry group is unique within the context of a parent node.
	RetryGroup string `json:"retry_group,omitempty"`
	// Boolean flag indicating if the node has child nodes under it This can be true when a node contains a dynamic workflow which then produces child nodes.
	IsParentNode bool   `json:"is_parent_node,omitempty"`
	SpecNodeId   string `json:"spec_node_id,omitempty"`
	// Boolean flag indicating if the node has contains a dynamic workflow which then produces child nodes. This is to distinguish between subworkflows and dynamic workflows which can both have is_parent_node as true.
	IsDynamic bool `json:"is_dynamic,omitempty"`
}

type AdminNotification struct {
	Phases    []CoreWorkflowExecutionPhase `json:"phases,omitempty"`
	Email     *AdminEmailNotification      `json:"email,omitempty"`
	PagerDuty *AdminPagerDutyNotification  `json:"pager_duty,omitempty"`
	Slack     *AdminSlackNotification      `json:"slack,omitempty"`
}

type AdminNotificationList struct {
	Notifications []AdminNotification `json:"notifications,omitempty"`
}

type AdminPagerDutyNotification struct {
	RecipientsEmail []string `json:"recipients_email,omitempty"`
}

type AdminPluginOverride struct {
	// A predefined yet extensible Task type identifier.
	TaskType string `json:"task_type,omitempty"`
	// A set of plugin ids which should handle tasks of this type instead of the default registered plugin. The list will be tried in order until a plugin is found with that id.
	PluginId []string `json:"plugin_id,omitempty"`
	// Defines the behavior when no plugin from the plugin_id list is not found.
	MissingPluginBehavior *PluginOverrideMissingPluginBehavior `json:"missing_plugin_behavior,omitempty"`
}

type AdminPluginOverrides struct {
	Overrides []AdminPluginOverride `json:"overrides,omitempty"`
}

type AdminProject struct {
	// Globally unique project name.
	Id string `json:"id,omitempty"`
	// Display name.
	Name        string        `json:"name,omitempty"`
	Domains     []AdminDomain `json:"domains,omitempty"`
	Description string        `json:"description,omitempty"`
	// Leverage Labels from flyteidl.admin.common.proto to tag projects with ownership information.
	Labels *AdminLabels         `json:"labels,omitempty"`
	State  *ProjectProjectState `json:"state,omitempty"`
}

type AdminProjectAttributes struct {
	// Unique project id for which this set of attributes will be applied.
	Project            string                   `json:"project,omitempty"`
	MatchingAttributes *AdminMatchingAttributes `json:"matching_attributes,omitempty"`
}

type AdminProjectAttributesDeleteRequest struct {
	Project      string                  `json:"project,omitempty"`
	ResourceType *AdminMatchableResource `json:"resource_type,omitempty"`
}

type AdminProjectAttributesDeleteResponse struct {
}

type AdminProjectAttributesGetResponse struct {
	Attributes *AdminProjectAttributes `json:"attributes,omitempty"`
}

type AdminProjectAttributesUpdateRequest struct {
	Attributes *AdminProjectAttributes `json:"attributes,omitempty"`
}

type AdminProjectAttributesUpdateResponse struct {
}

type AdminProjectDomainAttributes struct {
	// Unique project id for which this set of attributes will be applied.
	Project string `json:"project,omitempty"`
	// Unique domain id for which this set of attributes will be applied.
	Domain             string                   `json:"domain,omitempty"`
	MatchingAttributes *AdminMatchingAttributes `json:"matching_attributes,omitempty"`
}

type AdminProjectDomainAttributesDeleteRequest struct {
	Project      string                  `json:"project,omitempty"`
	Domain       string                  `json:"domain,omitempty"`
	ResourceType *AdminMatchableResource `json:"resource_type,omitempty"`
}

type AdminProjectDomainAttributesDeleteResponse struct {
}

type AdminProjectDomainAttributesGetResponse struct {
	Attributes *AdminProjectDomainAttributes `json:"attributes,omitempty"`
}

type AdminProjectDomainAttributesUpdateRequest struct {
	Attributes *AdminProjectDomainAttributes `json:"attributes,omitempty"`
}

type AdminProjectDomainAttributesUpdateResponse struct {
}

type AdminProjectRegisterRequest struct {
	Project *AdminProject `json:"project,omitempty"`
}

type AdminProjectRegisterResponse struct {
}

type AdminProjectUpdateResponse struct {
}

type AdminProjects struct {
	Projects []AdminProject `json:"projects,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page in a query. If there are no more results, this value will be empty.
	Token string `json:"token,omitempty"`
}

type AdminRawOutputDataConfig struct {
	OutputLocationPrefix string `json:"output_location_prefix,omitempty"`
}

type AdminReason struct {
	// occurred_at is the timestamp indicating the instant that this reason happened.
	OccurredAt time.Time `json:"occurred_at,omitempty"`
	// message is the explanation for the most recent phase transition or status update.
	Message string `json:"message,omitempty"`
}

type AdminSchedule struct {
	CronExpression string             `json:"cron_expression,omitempty"`
	Rate           *AdminFixedRate    `json:"rate,omitempty"`
	CronSchedule   *AdminCronSchedule `json:"cron_schedule,omitempty"`
	// Name of the input variable that the kickoff time will be supplied to when the workflow is kicked off.
	KickoffTimeInputArg string `json:"kickoff_time_input_arg,omitempty"`
}

type AdminServiceApiService service

type AdminSlackNotification struct {
	RecipientsEmail []string `json:"recipients_email,omitempty"`
}

type AdminSort struct {
	Key       string         `json:"key,omitempty"`
	Direction *SortDirection `json:"direction,omitempty"`
}

type AdminSourceCode struct {
	Link string `json:"link,omitempty"`
}

type AdminSystemMetadata struct {
	// Which execution cluster this execution ran on.
	ExecutionCluster string `json:"execution_cluster,omitempty"`
	// Which kubernetes namespace the execution ran under.
	Namespace string `json:"namespace,omitempty"`
}

type AdminTask struct {
	// id represents the unique identifier of the task.
	Id *CoreIdentifier `json:"id,omitempty"`
	// closure encapsulates all the fields that maps to a compiled version of the task.
	Closure *AdminTaskClosure `json:"closure,omitempty"`
	// One-liner overview of the entity.
	ShortDescription string `json:"short_description,omitempty"`
}

type AdminTaskClosure struct {
	// Represents the compiled representation of the task from the specification provided.
	CompiledTask *CoreCompiledTask `json:"compiled_task,omitempty"`
	// Time at which the task was created.
	CreatedAt time.Time `json:"created_at,omitempty"`
}

type AdminTaskExecutionClosure struct {
	// Path to remote data store where output blob is stored if the execution succeeded (and produced outputs). DEPRECATED. Use GetTaskExecutionData to fetch output data instead.
	OutputUri string `json:"output_uri,omitempty"`
	// Error information for the task execution. Populated if the execution failed.
	Error_ *CoreExecutionError `json:"error,omitempty"`
	// Raw output data produced by this task execution. DEPRECATED. Use GetTaskExecutionData to fetch output data instead.
	OutputData *CoreLiteralMap `json:"output_data,omitempty"`
	// The last recorded phase for this task execution.
	Phase *CoreTaskExecutionPhase `json:"phase,omitempty"`
	// Detailed log information output by the task execution.
	Logs []CoreTaskLog `json:"logs,omitempty"`
	// Time at which the task execution began running.
	StartedAt time.Time `json:"started_at,omitempty"`
	// The amount of time the task execution spent running.
	Duration string `json:"duration,omitempty"`
	// Time at which the task execution was created.
	CreatedAt time.Time `json:"created_at,omitempty"`
	// Time at which the task execution was last updated.
	UpdatedAt time.Time `json:"updated_at,omitempty"`
	// Custom data specific to the task plugin.
	CustomInfo *ProtobufStruct `json:"custom_info,omitempty"`
	// If there is an explanation for the most recent phase transition, the reason will capture it.
	Reason string `json:"reason,omitempty"`
	// A predefined yet extensible Task type identifier.
	TaskType string `json:"task_type,omitempty"`
	// Metadata around how a task was executed.
	Metadata *FlyteidleventTaskExecutionMetadata `json:"metadata,omitempty"`
	// The event version is used to indicate versioned changes in how data is maintained using this proto message. For example, event_verison > 0 means that maps tasks logs use the TaskExecutionMetadata ExternalResourceInfo fields for each subtask rather than the TaskLog in this message.
	EventVersion int32 `json:"event_version,omitempty"`
	// A time-series of the phase transition or update explanations. This, when compared to storing a singular reason as previously done, is much more valuable in visualizing and understanding historical evaluations.
	Reasons []AdminReason `json:"reasons,omitempty"`
}

type AdminTaskExecutionEventRequest struct {
	RequestId string `json:"request_id,omitempty"`
	// Details about the event that occurred.
	Event *EventTaskExecutionEvent `json:"event,omitempty"`
}

type AdminTaskExecutionEventResponse struct {
}

type AdminTaskExecutionGetDataResponse struct {
	// Signed url to fetch a core.LiteralMap of task execution inputs. Deprecated: Please use full_inputs instead.
	Inputs *AdminUrlBlob `json:"inputs,omitempty"`
	// Signed url to fetch a core.LiteralMap of task execution outputs. Deprecated: Please use full_outputs instead.
	Outputs *AdminUrlBlob `json:"outputs,omitempty"`
	// Full_inputs will only be populated if they are under a configured size threshold.
	FullInputs *CoreLiteralMap `json:"full_inputs,omitempty"`
	// Full_outputs will only be populated if they are under a configured size threshold.
	FullOutputs *CoreLiteralMap `json:"full_outputs,omitempty"`
	FlyteUrls   *AdminFlyteUrLs `json:"flyte_urls,omitempty"`
}

type AdminTaskExecutionList struct {
	TaskExecutions []FlyteidladminTaskExecution `json:"task_executions,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page in a query. If there are no more results, this value will be empty.
	Token string `json:"token,omitempty"`
}

type AdminTaskList struct {
	// A list of tasks returned based on the request.
	Tasks []AdminTask `json:"tasks,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page in a query. If there are no more results, this value will be empty.
	Token string `json:"token,omitempty"`
}

type AdminTaskResourceAttributes struct {
	Defaults *AdminTaskResourceSpec `json:"defaults,omitempty"`
	Limits   *AdminTaskResourceSpec `json:"limits,omitempty"`
}

type AdminTaskResourceSpec struct {
	Cpu              string `json:"cpu,omitempty"`
	Gpu              string `json:"gpu,omitempty"`
	Memory           string `json:"memory,omitempty"`
	Storage          string `json:"storage,omitempty"`
	EphemeralStorage string `json:"ephemeral_storage,omitempty"`
}

type AdminTaskSpec struct {
	// Template of the task that encapsulates all the metadata of the task.
	Template *CoreTaskTemplate `json:"template,omitempty"`
	// Represents the specification for description entity.
	Description *AdminDescriptionEntity `json:"description,omitempty"`
}

type AdminUrlBlob struct {
	// Actual url value.
	Url string `json:"url,omitempty"`
	// Represents the size of the file accessible at the above url.
	Bytes string `json:"bytes,omitempty"`
}

type AdminVersion struct {
	Build     string `json:"Build,omitempty"`
	Version   string `json:"Version,omitempty"`
	BuildTime string `json:"BuildTime,omitempty"`
}

type AdminWorkflow struct {
	// id represents the unique identifier of the workflow.
	Id *CoreIdentifier `json:"id,omitempty"`
	// closure encapsulates all the fields that maps to a compiled version of the workflow.
	Closure *AdminWorkflowClosure `json:"closure,omitempty"`
	// One-liner overview of the entity.
	ShortDescription string `json:"short_description,omitempty"`
}

type AdminWorkflowAttributes struct {
	// Unique project id for which this set of attributes will be applied.
	Project string `json:"project,omitempty"`
	// Unique domain id for which this set of attributes will be applied.
	Domain string `json:"domain,omitempty"`
	// Workflow name for which this set of attributes will be applied.
	Workflow           string                   `json:"workflow,omitempty"`
	MatchingAttributes *AdminMatchingAttributes `json:"matching_attributes,omitempty"`
}

type AdminWorkflowAttributesDeleteRequest struct {
	Project      string                  `json:"project,omitempty"`
	Domain       string                  `json:"domain,omitempty"`
	Workflow     string                  `json:"workflow,omitempty"`
	ResourceType *AdminMatchableResource `json:"resource_type,omitempty"`
}

type AdminWorkflowAttributesDeleteResponse struct {
}

type AdminWorkflowAttributesGetResponse struct {
	Attributes *AdminWorkflowAttributes `json:"attributes,omitempty"`
}

type AdminWorkflowAttributesUpdateRequest struct {
	Attributes *AdminWorkflowAttributes `json:"attributes,omitempty"`
}

type AdminWorkflowAttributesUpdateResponse struct {
}

type AdminWorkflowClosure struct {
	// Represents the compiled representation of the workflow from the specification provided.
	CompiledWorkflow *CoreCompiledWorkflowClosure `json:"compiled_workflow,omitempty"`
	// Time at which the workflow was created.
	CreatedAt time.Time `json:"created_at,omitempty"`
}

type AdminWorkflowCreateRequest struct {
	Id   *CoreIdentifier    `json:"id,omitempty"`
	Spec *AdminWorkflowSpec `json:"spec,omitempty"`
}

type AdminWorkflowCreateResponse struct {
}

type AdminWorkflowExecutionConfig struct {
	// Can be used to control the number of parallel nodes to run within the workflow. This is useful to achieve fairness.
	MaxParallelism int32 `json:"max_parallelism,omitempty"`
	// Indicates security context permissions for executions triggered with this matchable attribute.
	SecurityContext *CoreSecurityContext `json:"security_context,omitempty"`
	// Encapsulates user settings pertaining to offloaded data (i.e. Blobs, Schema, query data, etc.).
	RawOutputDataConfig *AdminRawOutputDataConfig `json:"raw_output_data_config,omitempty"`
	// Custom labels to be applied to a triggered execution resource.
	Labels *AdminLabels `json:"labels,omitempty"`
	// Custom annotations to be applied to a triggered execution resource.
	Annotations *AdminAnnotations `json:"annotations,omitempty"`
	// Allows for the interruptible flag of a workflow to be overwritten for a single execution. Omitting this field uses the workflow's value as a default. As we need to distinguish between the field not being provided and its default value false, we have to use a wrapper around the bool field.
	Interruptible bool `json:"interruptible,omitempty"`
	// Allows for all cached values of a workflow and its tasks to be overwritten for a single execution. If enabled, all calculations are performed even if cached results would be available, overwriting the stored data once execution finishes successfully.
	OverwriteCache bool `json:"overwrite_cache,omitempty"`
	// Environment variables to be set for the execution.
	Envs *AdminEnvs `json:"envs,omitempty"`
}

type AdminWorkflowExecutionEventRequest struct {
	RequestId string `json:"request_id,omitempty"`
	// Details about the event that occurred.
	Event *EventWorkflowExecutionEvent `json:"event,omitempty"`
}

type AdminWorkflowExecutionEventResponse struct {
}

type AdminWorkflowExecutionGetDataResponse struct {
	// Signed url to fetch a core.LiteralMap of execution outputs. Deprecated: Please use full_outputs instead.
	Outputs *AdminUrlBlob `json:"outputs,omitempty"`
	// Signed url to fetch a core.LiteralMap of execution inputs. Deprecated: Please use full_inputs instead.
	Inputs *AdminUrlBlob `json:"inputs,omitempty"`
	// Full_inputs will only be populated if they are under a configured size threshold.
	FullInputs *CoreLiteralMap `json:"full_inputs,omitempty"`
	// Full_outputs will only be populated if they are under a configured size threshold.
	FullOutputs *CoreLiteralMap `json:"full_outputs,omitempty"`
}

type AdminWorkflowExecutionGetMetricsResponse struct {
	// Span defines the top-level breakdown of the workflows execution. More precise information is nested in a hierarchical structure using Flyte entity references.
	Span *CoreSpan `json:"span,omitempty"`
}

type AdminWorkflowList struct {
	// A list of workflows returned based on the request.
	Workflows []AdminWorkflow `json:"workflows,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page in a query. If there are no more results, this value will be empty.
	Token string `json:"token,omitempty"`
}

type AdminWorkflowSpec struct {
	// Template of the task that encapsulates all the metadata of the workflow.
	Template *CoreWorkflowTemplate `json:"template,omitempty"`
	// Workflows that are embedded into other workflows need to be passed alongside the parent workflow to the propeller compiler (since the compiler doesn't have any knowledge of other workflows - ie, it doesn't reach out to Admin to see other registered workflows).  In fact, subworkflows do not even need to be registered.
	SubWorkflows []CoreWorkflowTemplate `json:"sub_workflows,omitempty"`
	// Represents the specification for description entity.
	Description *AdminDescriptionEntity `json:"description,omitempty"`
}

type BasicAuth struct {
	UserName string `json:"userName,omitempty"`
	Password string `json:"password,omitempty"`
}

type BlobTypeBlobDimensionality string

type CatalogReservationStatus string

type ComparisonExpressionOperator string

type Configuration struct {
	BasePath      string            `json:"basePath,omitempty"`
	Host          string            `json:"host,omitempty"`
	Scheme        string            `json:"scheme,omitempty"`
	DefaultHeader map[string]string `json:"defaultHeader,omitempty"`
	UserAgent     string            `json:"userAgent,omitempty"`
	HTTPClient    *http.Client
}

type ConjunctionExpressionLogicalOperator string

type ConnectionSetIdList struct {
	Ids []string `json:"ids,omitempty"`
}

type ContainerArchitecture string

type CoreAlias struct {
	// Must match one of the output variable names on a node.
	Var_ string `json:"var,omitempty"`
	// A workflow-level unique alias that downstream nodes can refer to in their input.
	Alias string `json:"alias,omitempty"`
}

type CoreApproveCondition struct {
	// A unique identifier for the requested boolean signal.
	SignalId string `json:"signal_id,omitempty"`
}

type CoreArrayNode struct {
	// node is the sub-node that will be executed for each element in the array.
	Node *CoreNode `json:"node,omitempty"`
	// parallelism defines the minimum number of instances to bring up concurrently at any given point. Note that this is an optimistic restriction and that, due to network partitioning or other failures, the actual number of currently running instances might be more. This has to be a positive number if assigned. Default value is size.
	Parallelism int64 `json:"parallelism,omitempty"`
	// min_successes is an absolute number of the minimum number of successful completions of sub-nodes. As soon as this criteria is met, the ArrayNode will be marked as successful and outputs will be computed. This has to be a non-negative number if assigned. Default value is size (if specified).
	MinSuccesses int64 `json:"min_successes,omitempty"`
	// If the array job size is not known beforehand, the min_success_ratio can instead be used to determine when an ArrayNode can be marked successful.
	MinSuccessRatio float32 `json:"min_success_ratio,omitempty"`
}

type CoreBinary struct {
	Value string `json:"value,omitempty"`
	Tag   string `json:"tag,omitempty"`
}

type CoreBinding struct {
	// Variable name must match an input/output variable of the node.
	Var_ string `json:"var,omitempty"`
	// Data to use to bind this variable.
	Binding *CoreBindingData `json:"binding,omitempty"`
}

type CoreBindingData struct {
	// A simple scalar value.
	Scalar *CoreScalar `json:"scalar,omitempty"`
	// A collection of binding data. This allows nesting of binding data to any number of levels.
	Collection *CoreBindingDataCollection `json:"collection,omitempty"`
	// References an output promised by another node.
	Promise *CoreOutputReference `json:"promise,omitempty"`
	// A map of bindings. The key is always a string.
	Map_  *CoreBindingDataMap `json:"map,omitempty"`
	Union *CoreUnionInfo      `json:"union,omitempty"`
}

type CoreBindingDataCollection struct {
	Bindings []CoreBindingData `json:"bindings,omitempty"`
}

type CoreBindingDataMap struct {
	Bindings map[string]CoreBindingData `json:"bindings,omitempty"`
}

type CoreBlob struct {
	Metadata *CoreBlobMetadata `json:"metadata,omitempty"`
	Uri      string            `json:"uri,omitempty"`
}

type CoreBlobMetadata struct {
	Type_ *CoreBlobType `json:"type,omitempty"`
}

type CoreBlobType struct {
	Format         string                      `json:"format,omitempty"`
	Dimensionality *BlobTypeBlobDimensionality `json:"dimensionality,omitempty"`
}

type CoreBooleanExpression struct {
	Conjunction *CoreConjunctionExpression `json:"conjunction,omitempty"`
	Comparison  *CoreComparisonExpression  `json:"comparison,omitempty"`
}

type CoreBranchNode struct {
	IfElse *CoreIfElseBlock `json:"if_else,omitempty"`
}

type CoreCatalogArtifactTag struct {
	ArtifactId string `json:"artifact_id,omitempty"`
	Name       string `json:"name,omitempty"`
}

type CoreCatalogCacheStatus string

type CoreCatalogMetadata struct {
	DatasetId           *CoreIdentifier              `json:"dataset_id,omitempty"`
	ArtifactTag         *CoreCatalogArtifactTag      `json:"artifact_tag,omitempty"`
	SourceTaskExecution *CoreTaskExecutionIdentifier `json:"source_task_execution,omitempty"`
}

type CoreComparisonExpression struct {
	Operator   *ComparisonExpressionOperator `json:"operator,omitempty"`
	LeftValue  *CoreOperand                  `json:"left_value,omitempty"`
	RightValue *CoreOperand                  `json:"right_value,omitempty"`
}

type CoreCompiledTask struct {
	Template *CoreTaskTemplate `json:"template,omitempty"`
}

type CoreCompiledWorkflow struct {
	Template *CoreWorkflowTemplate `json:"template,omitempty"`
	// For internal use only! This field is used by the system and must not be filled in. Any values set will be ignored.
	Connections *CoreConnectionSet `json:"connections,omitempty"`
}

type CoreCompiledWorkflowClosure struct {
	Primary      *CoreCompiledWorkflow  `json:"primary,omitempty"`
	SubWorkflows []CoreCompiledWorkflow `json:"sub_workflows,omitempty"`
	Tasks        []CoreCompiledTask     `json:"tasks,omitempty"`
}

type CoreConjunctionExpression struct {
	Operator        *ConjunctionExpressionLogicalOperator `json:"operator,omitempty"`
	LeftExpression  *CoreBooleanExpression                `json:"left_expression,omitempty"`
	RightExpression *CoreBooleanExpression                `json:"right_expression,omitempty"`
}

type CoreConnectionSet struct {
	Downstream map[string]ConnectionSetIdList `json:"downstream,omitempty"`
	Upstream   map[string]ConnectionSetIdList `json:"upstream,omitempty"`
}

type CoreContainer struct {
	Image string `json:"image,omitempty"`
	// Command to be executed, if not provided, the default entrypoint in the container image will be used.
	Command []string `json:"command,omitempty"`
	// These will default to Flyte given paths. If provided, the system will not append known paths. If the task still needs flyte's inputs and outputs path, add $(FLYTE_INPUT_FILE), $(FLYTE_OUTPUT_FILE) wherever makes sense and the system will populate these before executing the container.
	Args []string `json:"args,omitempty"`
	// Container resources requirement as specified by the container engine.
	Resources *CoreResources `json:"resources,omitempty"`
	// Environment variables will be set as the container is starting up.
	Env []CoreKeyValuePair `json:"env,omitempty"`
	// Allows extra configs to be available for the container. TODO: elaborate on how configs will become available. Deprecated, please use TaskTemplate.config instead.
	Config       []CoreKeyValuePair     `json:"config,omitempty"`
	Ports        []CoreContainerPort    `json:"ports,omitempty"`
	DataConfig   *CoreDataLoadingConfig `json:"data_config,omitempty"`
	Architecture *ContainerArchitecture `json:"architecture,omitempty"`
}

type CoreContainerPort struct {
	// Number of port to expose on the pod's IP address. This must be a valid port number, 0 < x < 65536.
	ContainerPort int64 `json:"container_port,omitempty"`
}

type CoreDataLoadingConfig struct {
	Enabled    bool                               `json:"enabled,omitempty"`
	InputPath  string                             `json:"input_path,omitempty"`
	OutputPath string                             `json:"output_path,omitempty"`
	Format     *DataLoadingConfigLiteralMapFormat `json:"format,omitempty"`
	IoStrategy *CoreIoStrategy                    `json:"io_strategy,omitempty"`
}

type CoreEnumType struct {
	// Predefined set of enum values.
	Values []string `json:"values,omitempty"`
}

type CoreError struct {
	// The node id that threw the error.
	FailedNodeId string `json:"failed_node_id,omitempty"`
	// Error message thrown.
	Message string `json:"message,omitempty"`
}

type CoreExecutionError struct {
	Code string `json:"code,omitempty"`
	// Detailed description of the error - including stack trace.
	Message  string                   `json:"message,omitempty"`
	ErrorUri string                   `json:"error_uri,omitempty"`
	Kind     *ExecutionErrorErrorKind `json:"kind,omitempty"`
}

type CoreGateNode struct {
	// ApproveCondition represents a dependency on an external approval provided by a boolean signal.
	Approve *CoreApproveCondition `json:"approve,omitempty"`
	// SignalCondition represents a dependency on an signal.
	Signal *CoreSignalCondition `json:"signal,omitempty"`
	// SleepCondition represents a dependency on waiting for the specified duration.
	Sleep *CoreSleepCondition `json:"sleep,omitempty"`
}

type CoreIdentifier struct {
	// Identifies the specific type of resource that this identifier corresponds to.
	ResourceType *CoreResourceType `json:"resource_type,omitempty"`
	// Name of the project the resource belongs to.
	Project string `json:"project,omitempty"`
	// Name of the domain the resource belongs to. A domain can be considered as a subset within a specific project.
	Domain string `json:"domain,omitempty"`
	// User provided value for the resource.
	Name string `json:"name,omitempty"`
	// Specific version of the resource.
	Version string `json:"version,omitempty"`
}

type CoreIdentity struct {
	// iam_role references the fully qualified name of Identity & Access Management role to impersonate.
	IamRole string `json:"iam_role,omitempty"`
	// k8s_service_account references a kubernetes service account to impersonate.
	K8sServiceAccount string `json:"k8s_service_account,omitempty"`
	// oauth2_client references an oauth2 client. Backend plugins can use this information to impersonate the client when making external calls.
	Oauth2Client      *CoreOAuth2Client `json:"oauth2_client,omitempty"`
	ExecutionIdentity string            `json:"execution_identity,omitempty"`
}

type CoreIfBlock struct {
	Condition *CoreBooleanExpression `json:"condition,omitempty"`
	ThenNode  *CoreNode              `json:"then_node,omitempty"`
}

type CoreIfElseBlock struct {
	// +required. First condition to evaluate.
	Case_ *CoreIfBlock `json:"case,omitempty"`
	// +optional. Additional branches to evaluate.
	Other []CoreIfBlock `json:"other,omitempty"`
	// The node to execute in case none of the branches were taken.
	ElseNode *CoreNode `json:"else_node,omitempty"`
	// An error to throw in case none of the branches were taken.
	Error_ *CoreError `json:"error,omitempty"`
}

type CoreIoStrategy struct {
	DownloadMode *IoStrategyDownloadMode `json:"download_mode,omitempty"`
	UploadMode   *IoStrategyUploadMode   `json:"upload_mode,omitempty"`
}

type CoreK8sObjectMetadata struct {
	// Optional labels to add to the pod definition.
	Labels map[string]string `json:"labels,omitempty"`
	// Optional annotations to add to the pod definition.
	Annotations map[string]string `json:"annotations,omitempty"`
}

type CoreK8sPod struct {
	// Contains additional metadata for building a kubernetes pod.
	Metadata   *CoreK8sObjectMetadata `json:"metadata,omitempty"`
	PodSpec    *ProtobufStruct        `json:"pod_spec,omitempty"`
	DataConfig *CoreDataLoadingConfig `json:"data_config,omitempty"`
}

type CoreKeyValuePair struct {
	// required.
	Key string `json:"key,omitempty"`
	// +optional.
	Value string `json:"value,omitempty"`
}

type CoreLiteral struct {
	// A simple value.
	Scalar *CoreScalar `json:"scalar,omitempty"`
	// A collection of literals to allow nesting.
	Collection *CoreLiteralCollection `json:"collection,omitempty"`
	// A map of strings to literals.
	Map_ *CoreLiteralMap `json:"map,omitempty"`
	Hash string          `json:"hash,omitempty"`
}

type CoreLiteralCollection struct {
	Literals []CoreLiteral `json:"literals,omitempty"`
}

type CoreLiteralMap struct {
	Literals map[string]CoreLiteral `json:"literals,omitempty"`
}

type CoreLiteralType struct {
	// A simple type that can be compared one-to-one with another.
	Simple *CoreSimpleType `json:"simple,omitempty"`
	// A complex type that requires matching of inner fields.
	Schema *CoreSchemaType `json:"schema,omitempty"`
	// Defines the type of the value of a collection. Only homogeneous collections are allowed.
	CollectionType *CoreLiteralType `json:"collection_type,omitempty"`
	// Defines the type of the value of a map type. The type of the key is always a string.
	MapValueType *CoreLiteralType `json:"map_value_type,omitempty"`
	// A blob might have specialized implementation details depending on associated metadata.
	Blob *CoreBlobType `json:"blob,omitempty"`
	// Defines an enum with pre-defined string values.
	EnumType              *CoreEnumType              `json:"enum_type,omitempty"`
	StructuredDatasetType *CoreStructuredDatasetType `json:"structured_dataset_type,omitempty"`
	// Defines an union type with pre-defined LiteralTypes.
	UnionType *CoreUnionType `json:"union_type,omitempty"`
	// This field contains type metadata that is descriptive of the type, but is NOT considered in type-checking.  This might be used by consumers to identify special behavior or display extended information for the type.
	Metadata *ProtobufStruct `json:"metadata,omitempty"`
	// This field contains arbitrary data that might have special semantic meaning for the client but does not effect internal flyte behavior.
	Annotation *CoreTypeAnnotation `json:"annotation,omitempty"`
	// Hints to improve type matching.
	Structure *CoreTypeStructure `json:"structure,omitempty"`
}

type CoreNode struct {
	// A workflow-level unique identifier that identifies this node in the workflow. 'inputs' and 'outputs' are reserved node ids that cannot be used by other nodes.
	Id string `json:"id,omitempty"`
	// Extra metadata about the node.
	Metadata *CoreNodeMetadata `json:"metadata,omitempty"`
	// Specifies how to bind the underlying interface's inputs. All required inputs specified in the underlying interface must be fulfilled.
	Inputs []CoreBinding `json:"inputs,omitempty"`
	// +optional Specifies execution dependency for this node ensuring it will only get scheduled to run after all its upstream nodes have completed. This node will have an implicit dependency on any node that appears in inputs field.
	UpstreamNodeIds []string `json:"upstream_node_ids,omitempty"`
	// +optional. A node can define aliases for a subset of its outputs. This is particularly useful if different nodes need to conform to the same interface (e.g. all branches in a branch node). Downstream nodes must refer to this nodes outputs using the alias if one's specified.
	OutputAliases []CoreAlias `json:"output_aliases,omitempty"`
	// Information about the Task to execute in this node.
	TaskNode *CoreTaskNode `json:"task_node,omitempty"`
	// Information about the Workflow to execute in this mode.
	WorkflowNode *CoreWorkflowNode `json:"workflow_node,omitempty"`
	// Information about the branch node to evaluate in this node.
	BranchNode *CoreBranchNode `json:"branch_node,omitempty"`
	// Information about the condition to evaluate in this node.
	GateNode *CoreGateNode `json:"gate_node,omitempty"`
	// Information about the sub-node executions for each value in the list of this nodes inputs values.
	ArrayNode *CoreArrayNode `json:"array_node,omitempty"`
}

type CoreNodeExecutionIdentifier struct {
	NodeId      string                           `json:"node_id,omitempty"`
	ExecutionId *CoreWorkflowExecutionIdentifier `json:"execution_id,omitempty"`
}

type CoreNodeExecutionPhase string

type CoreNodeMetadata struct {
	Name string `json:"name,omitempty"`
	// The overall timeout of a task.
	Timeout string `json:"timeout,omitempty"`
	// Number of retries per task.
	Retries       *CoreRetryStrategy `json:"retries,omitempty"`
	Interruptible bool               `json:"interruptible,omitempty"`
}

type CoreOAuth2Client struct {
	ClientId     string      `json:"client_id,omitempty"`
	ClientSecret *CoreSecret `json:"client_secret,omitempty"`
}

type CoreOAuth2TokenRequest struct {
	Name                 string                      `json:"name,omitempty"`
	Type_                *CoreOAuth2TokenRequestType `json:"type,omitempty"`
	Client               *CoreOAuth2Client           `json:"client,omitempty"`
	IdpDiscoveryEndpoint string                      `json:"idp_discovery_endpoint,omitempty"`
	TokenEndpoint        string                      `json:"token_endpoint,omitempty"`
}

type CoreOAuth2TokenRequestType string

type CoreOperand struct {
	Primitive *CorePrimitive `json:"primitive,omitempty"`
	Var_      string         `json:"var,omitempty"`
	Scalar    *CoreScalar    `json:"scalar,omitempty"`
}

type CoreOutputReference struct {
	// Node id must exist at the graph layer.
	NodeId string `json:"node_id,omitempty"`
	// Variable name must refer to an output variable for the node.
	Var_     string                 `json:"var,omitempty"`
	AttrPath []CorePromiseAttribute `json:"attr_path,omitempty"`
}

type CoreParameter struct {
	// +required Variable. Defines the type of the variable backing this parameter.
	Var_ *CoreVariable `json:"var,omitempty"`
	// Defines a default value that has to match the variable type defined.
	Default_ *CoreLiteral `json:"default,omitempty"`
	// +optional, is this value required to be filled.
	Required bool `json:"required,omitempty"`
}

type CoreParameterMap struct {
	// Defines a map of parameter names to parameters.
	Parameters map[string]CoreParameter `json:"parameters,omitempty"`
}

type CorePrimitive struct {
	Integer     string    `json:"integer,omitempty"`
	FloatValue  float64   `json:"float_value,omitempty"`
	StringValue string    `json:"string_value,omitempty"`
	Boolean     bool      `json:"boolean,omitempty"`
	Datetime    time.Time `json:"datetime,omitempty"`
	Duration    string    `json:"duration,omitempty"`
}

type CorePromiseAttribute struct {
	StringValue string `json:"string_value,omitempty"`
	IntValue    int32  `json:"int_value,omitempty"`
}

type CoreQualityOfService struct {
	Tier *QualityOfServiceTier     `json:"tier,omitempty"`
	Spec *CoreQualityOfServiceSpec `json:"spec,omitempty"`
}

type CoreQualityOfServiceSpec struct {
	// Indicates how much queueing delay an execution can tolerate.
	QueueingBudget string `json:"queueing_budget,omitempty"`
}

type CoreResourceType string

type CoreResources struct {
	// The desired set of resources requested. ResourceNames must be unique within the list.
	Requests []ResourcesResourceEntry `json:"requests,omitempty"`
	// Defines a set of bounds (e.g. min/max) within which the task can reliably run. ResourceNames must be unique within the list.
	Limits []ResourcesResourceEntry `json:"limits,omitempty"`
}

type CoreRetryStrategy struct {
	// Number of retries. Retries will be consumed when the job fails with a recoverable error. The number of retries must be less than or equals to 10.
	Retries int64 `json:"retries,omitempty"`
}

type CoreRuntimeMetadata struct {
	// Type of runtime.
	Type_ *RuntimeMetadataRuntimeType `json:"type,omitempty"`
	// Version of the runtime. All versions should be backward compatible. However, certain cases call for version checks to ensure tighter validation or setting expectations.
	Version string `json:"version,omitempty"`
	// +optional It can be used to provide extra information about the runtime (e.g. python, golang... etc.).
	Flavor string `json:"flavor,omitempty"`
}

type CoreScalar struct {
	Primitive         *CorePrimitive         `json:"primitive,omitempty"`
	Blob              *CoreBlob              `json:"blob,omitempty"`
	Binary            *CoreBinary            `json:"binary,omitempty"`
	Schema            *CoreSchema            `json:"schema,omitempty"`
	NoneType          *CoreVoid              `json:"none_type,omitempty"`
	Error_            *CoreError             `json:"error,omitempty"`
	Generic           *ProtobufStruct        `json:"generic,omitempty"`
	StructuredDataset *CoreStructuredDataset `json:"structured_dataset,omitempty"`
	Union             *CoreUnion             `json:"union,omitempty"`
}

type CoreSchema struct {
	Uri   string          `json:"uri,omitempty"`
	Type_ *CoreSchemaType `json:"type,omitempty"`
}

type CoreSchemaType struct {
	// A list of ordered columns this schema comprises of.
	Columns []SchemaTypeSchemaColumn `json:"columns,omitempty"`
}

type CoreSecret struct {
	Group            string           `json:"group,omitempty"`
	GroupVersion     string           `json:"group_version,omitempty"`
	Key              string           `json:"key,omitempty"`
	MountRequirement *SecretMountType `json:"mount_requirement,omitempty"`
}

type CoreSecurityContext struct {
	// run_as encapsulates the identity a pod should run as. If the task fills in multiple fields here, it'll be up to the backend plugin to choose the appropriate identity for the execution engine the task will run on.
	RunAs *CoreIdentity `json:"run_as,omitempty"`
	// secrets indicate the list of secrets the task needs in order to proceed. Secrets will be mounted/passed to the pod as it starts. If the plugin responsible for kicking of the task will not run it on a flyte cluster (e.g. AWS Batch), it's the responsibility of the plugin to fetch the secret (which means propeller identity will need access to the secret) and to pass it to the remote execution engine.
	Secrets []CoreSecret `json:"secrets,omitempty"`
	// tokens indicate the list of token requests the task needs in order to proceed. Tokens will be mounted/passed to the pod as it starts. If the plugin responsible for kicking of the task will not run it on a flyte cluster (e.g. AWS Batch), it's the responsibility of the plugin to fetch the secret (which means propeller identity will need access to the secret) and to pass it to the remote execution engine.
	Tokens []CoreOAuth2TokenRequest `json:"tokens,omitempty"`
}

type CoreSignalCondition struct {
	// A unique identifier for the requested signal.
	SignalId string `json:"signal_id,omitempty"`
	// A type denoting the required value type for this signal.
	Type_ *CoreLiteralType `json:"type,omitempty"`
	// The variable name for the signal value in this nodes outputs.
	OutputVariableName string `json:"output_variable_name,omitempty"`
}

type CoreSimpleType string

type CoreSleepCondition struct {
	// The overall duration for this sleep.
	Duration string `json:"duration,omitempty"`
}

type CoreSpan struct {
	// start_time defines the instance this span began.
	StartTime time.Time `json:"start_time,omitempty"`
	// end_time defines the instance this span completed.
	EndTime time.Time `json:"end_time,omitempty"`
	// workflow_id is the id of the workflow execution this Span represents.
	WorkflowId *CoreWorkflowExecutionIdentifier `json:"workflow_id,omitempty"`
	// node_id is the id of the node execution this Span represents.
	NodeId *CoreNodeExecutionIdentifier `json:"node_id,omitempty"`
	// task_id is the id of the task execution this Span represents.
	TaskId *CoreTaskExecutionIdentifier `json:"task_id,omitempty"`
	// operation_id is the id of a unique operation that this Span represents.
	OperationId string `json:"operation_id,omitempty"`
	// spans defines a collection of Spans that breakdown this execution.
	Spans []CoreSpan `json:"spans,omitempty"`
}

type CoreSql struct {
	Statement string      `json:"statement,omitempty"`
	Dialect   *SqlDialect `json:"dialect,omitempty"`
}

type CoreStructuredDataset struct {
	Uri      string                         `json:"uri,omitempty"`
	Metadata *CoreStructuredDatasetMetadata `json:"metadata,omitempty"`
}

type CoreStructuredDatasetMetadata struct {
	// Bundle the type information along with the literal. This is here because StructuredDatasets can often be more defined at run time than at compile time. That is, at compile time you might only declare a task to return a pandas dataframe or a StructuredDataset, without any column information, but at run time, you might have that column information. flytekit python will copy this type information into the literal, from the type information, if not provided by the various plugins (encoders). Since this field is run time generated, it's not used for any type checking.
	StructuredDatasetType *CoreStructuredDatasetType `json:"structured_dataset_type,omitempty"`
}

type CoreStructuredDatasetType struct {
	// A list of ordered columns this schema comprises of.
	Columns []StructuredDatasetTypeDatasetColumn `json:"columns,omitempty"`
	// This is the storage format, the format of the bits at rest parquet, feather, csv, etc. For two types to be compatible, the format will need to be an exact match.
	Format string `json:"format,omitempty"`
	// This is a string representing the type that the bytes in external_schema_bytes are formatted in. This is an optional field that will not be used for type checking.
	ExternalSchemaType string `json:"external_schema_type,omitempty"`
	// The serialized bytes of a third-party schema library like Arrow. This is an optional field that will not be used for type checking.
	ExternalSchemaBytes string `json:"external_schema_bytes,omitempty"`
}

type CoreTaskExecutionIdentifier struct {
	TaskId          *CoreIdentifier              `json:"task_id,omitempty"`
	NodeExecutionId *CoreNodeExecutionIdentifier `json:"node_execution_id,omitempty"`
	RetryAttempt    int64                        `json:"retry_attempt,omitempty"`
}

type CoreTaskExecutionPhase string

type CoreTaskLog struct {
	Uri           string                `json:"uri,omitempty"`
	Name          string                `json:"name,omitempty"`
	MessageFormat *TaskLogMessageFormat `json:"message_format,omitempty"`
	Ttl           string                `json:"ttl,omitempty"`
}

type CoreTaskMetadata struct {
	// Indicates whether the system should attempt to lookup this task's output to avoid duplication of work.
	Discoverable bool `json:"discoverable,omitempty"`
	// Runtime information about the task.
	Runtime *CoreRuntimeMetadata `json:"runtime,omitempty"`
	// The overall timeout of a task including user-triggered retries.
	Timeout string `json:"timeout,omitempty"`
	// Number of retries per task.
	Retries *CoreRetryStrategy `json:"retries,omitempty"`
	// Indicates a logical version to apply to this task for the purpose of discovery.
	DiscoveryVersion string `json:"discovery_version,omitempty"`
	// If set, this indicates that this task is deprecated.  This will enable owners of tasks to notify consumers of the ending of support for a given task.
	DeprecatedErrorMessage string `json:"deprecated_error_message,omitempty"`
	Interruptible          bool   `json:"interruptible,omitempty"`
	CacheSerializable      bool   `json:"cache_serializable,omitempty"`
	// Indicates whether the task will generate a Deck URI when it finishes executing.
	GeneratesDeck bool              `json:"generates_deck,omitempty"`
	Tags          map[string]string `json:"tags,omitempty"`
	// pod_template_name is the unique name of a PodTemplate k8s resource to be used as the base configuration if this task creates a k8s Pod. If this value is set, the specified PodTemplate will be used instead of, but applied identically as, the default PodTemplate configured in FlytePropeller.
	PodTemplateName string `json:"pod_template_name,omitempty"`
}

type CoreTaskNode struct {
	// A globally unique identifier for the task.
	ReferenceId *CoreIdentifier `json:"reference_id,omitempty"`
	// Optional overrides applied at task execution time.
	Overrides *CoreTaskNodeOverrides `json:"overrides,omitempty"`
}

type CoreTaskNodeOverrides struct {
	// A customizable interface to convey resources requested for a task container.
	Resources *CoreResources `json:"resources,omitempty"`
}

type CoreTaskTemplate struct {
	// Auto generated taskId by the system. Task Id uniquely identifies this task globally.
	Id *CoreIdentifier `json:"id,omitempty"`
	// A predefined yet extensible Task type identifier. This can be used to customize any of the components. If no extensions are provided in the system, Flyte will resolve the this task to its TaskCategory and default the implementation registered for the TaskCategory.
	Type_ string `json:"type,omitempty"`
	// Extra metadata about the task.
	Metadata *CoreTaskMetadata `json:"metadata,omitempty"`
	// A strongly typed interface for the task. This enables others to use this task within a workflow and guarantees compile-time validation of the workflow to avoid costly runtime failures.
	Interface_ *CoreTypedInterface `json:"interface,omitempty"`
	// Custom data about the task. This is extensible to allow various plugins in the system.
	Custom    *ProtobufStruct `json:"custom,omitempty"`
	Container *CoreContainer  `json:"container,omitempty"`
	K8sPod    *CoreK8sPod     `json:"k8s_pod,omitempty"`
	Sql       *CoreSql        `json:"sql,omitempty"`
	// This can be used to customize task handling at execution time for the same task type.
	TaskTypeVersion int32 `json:"task_type_version,omitempty"`
	// security_context encapsulates security attributes requested to run this task.
	SecurityContext *CoreSecurityContext `json:"security_context,omitempty"`
	Config          map[string]string    `json:"config,omitempty"`
}

type CoreTypeAnnotation struct {
	// A arbitrary JSON payload to describe a type.
	Annotations *ProtobufStruct `json:"annotations,omitempty"`
}

type CoreTypeStructure struct {
	Tag string `json:"tag,omitempty"`
}

type CoreTypedInterface struct {
	Inputs  *CoreVariableMap `json:"inputs,omitempty"`
	Outputs *CoreVariableMap `json:"outputs,omitempty"`
}

type CoreUnion struct {
	Value *CoreLiteral     `json:"value,omitempty"`
	Type_ *CoreLiteralType `json:"type,omitempty"`
}

type CoreUnionInfo struct {
	TargetType *CoreLiteralType `json:"targetType,omitempty"`
}

type CoreUnionType struct {
	// Predefined set of variants in union.
	Variants []CoreLiteralType `json:"variants,omitempty"`
}

type CoreVariable struct {
	// Variable literal type.
	Type_       *CoreLiteralType `json:"type,omitempty"`
	Description string           `json:"description,omitempty"`
}

type CoreVariableMap struct {
	// Defines a map of variable names to variables.
	Variables map[string]CoreVariable `json:"variables,omitempty"`
}

type CoreVoid struct {
}

type CoreWorkflowExecutionIdentifier struct {
	// Name of the project the resource belongs to.
	Project string `json:"project,omitempty"`
	// Name of the domain the resource belongs to. A domain can be considered as a subset within a specific project.
	Domain string `json:"domain,omitempty"`
	// User or system provided value for the resource.
	Name string `json:"name,omitempty"`
}

type CoreWorkflowExecutionPhase string

type CoreWorkflowMetadata struct {
	// Indicates the runtime priority of workflow executions.
	QualityOfService *CoreQualityOfService `json:"quality_of_service,omitempty"`
	// Defines how the system should behave when a failure is detected in the workflow execution.
	OnFailure *WorkflowMetadataOnFailurePolicy `json:"on_failure,omitempty"`
	Tags      map[string]string                `json:"tags,omitempty"`
}

type CoreWorkflowMetadataDefaults struct {
	// Whether child nodes of the workflow are interruptible.
	Interruptible bool `json:"interruptible,omitempty"`
}

type CoreWorkflowNode struct {
	// A globally unique identifier for the launch plan.
	LaunchplanRef  *CoreIdentifier `json:"launchplan_ref,omitempty"`
	SubWorkflowRef *CoreIdentifier `json:"sub_workflow_ref,omitempty"`
}

type CoreWorkflowTemplate struct {
	// A globally unique identifier for the workflow.
	Id *CoreIdentifier `json:"id,omitempty"`
	// Extra metadata about the workflow.
	Metadata *CoreWorkflowMetadata `json:"metadata,omitempty"`
	// Defines a strongly typed interface for the Workflow. This can include some optional parameters.
	Interface_ *CoreTypedInterface `json:"interface,omitempty"`
	// A list of nodes. In addition, 'globals' is a special reserved node id that can be used to consume workflow inputs.
	Nodes []CoreNode `json:"nodes,omitempty"`
	// A list of output bindings that specify how to construct workflow outputs. Bindings can pull node outputs or specify literals. All workflow outputs specified in the interface field must be bound in order for the workflow to be validated. A workflow has an implicit dependency on all of its nodes to execute successfully in order to bind final outputs. Most of these outputs will be Binding's with a BindingData of type OutputReference.  That is, your workflow can just have an output of some constant (`Output(5)`), but usually, the workflow will be pulling outputs from the output of a task.
	Outputs []CoreBinding `json:"outputs,omitempty"`
	// +optional A catch-all node. This node is executed whenever the execution engine determines the workflow has failed. The interface of this node must match the Workflow interface with an additional input named 'error' of type pb.lyft.flyte.core.Error.
	FailureNode      *CoreNode                     `json:"failure_node,omitempty"`
	MetadataDefaults *CoreWorkflowMetadataDefaults `json:"metadata_defaults,omitempty"`
}

type DataLoadingConfigLiteralMapFormat string

type EventEventReason struct {
	Reason     string    `json:"reason,omitempty"`
	OccurredAt time.Time `json:"occurred_at,omitempty"`
}

type EventExternalResourceInfo struct {
	// Identifier for an external resource created by this task execution, for example Qubole query ID or presto query ids.
	ExternalId string `json:"external_id,omitempty"`
	// A unique index for the external resource with respect to all external resources for this task. Although the identifier may change between task reporting events or retries, this will remain the same to enable aggregating information from multiple reports.
	Index        int64                   `json:"index,omitempty"`
	RetryAttempt int64                   `json:"retry_attempt,omitempty"`
	Phase        *CoreTaskExecutionPhase `json:"phase,omitempty"`
	// Captures the status of caching for this external resource execution.
	CacheStatus *CoreCatalogCacheStatus `json:"cache_status,omitempty"`
	Logs        []CoreTaskLog           `json:"logs,omitempty"`
}

type EventNodeExecutionEvent struct {
	Id         *CoreNodeExecutionIdentifier `json:"id,omitempty"`
	ProducerId string                       `json:"producer_id,omitempty"`
	Phase      *CoreNodeExecutionPhase      `json:"phase,omitempty"`
	// This timestamp represents when the original event occurred, it is generated by the executor of the node.
	OccurredAt time.Time `json:"occurred_at,omitempty"`
	InputUri   string    `json:"input_uri,omitempty"`
	// Raw input data consumed by this node execution.
	InputData *CoreLiteralMap `json:"input_data,omitempty"`
	// URL to the output of the execution, it encodes all the information including Cloud source provider. ie., s3://...
	OutputUri string              `json:"output_uri,omitempty"`
	Error_    *CoreExecutionError `json:"error,omitempty"`
	// Raw output data produced by this node execution.
	OutputData           *CoreLiteralMap                    `json:"output_data,omitempty"`
	WorkflowNodeMetadata *FlyteidleventWorkflowNodeMetadata `json:"workflow_node_metadata,omitempty"`
	TaskNodeMetadata     *FlyteidleventTaskNodeMetadata     `json:"task_node_metadata,omitempty"`
	// [To be deprecated] Specifies which task (if any) launched this node.
	ParentTaskMetadata *EventParentTaskExecutionMetadata `json:"parent_task_metadata,omitempty"`
	// Specifies the parent node of the current node execution. Node executions at level zero will not have a parent node.
	ParentNodeMetadata *EventParentNodeExecutionMetadata `json:"parent_node_metadata,omitempty"`
	RetryGroup         string                            `json:"retry_group,omitempty"`
	SpecNodeId         string                            `json:"spec_node_id,omitempty"`
	NodeName           string                            `json:"node_name,omitempty"`
	EventVersion       int32                             `json:"event_version,omitempty"`
	// Whether this node launched a subworkflow.
	IsParent bool `json:"is_parent,omitempty"`
	// Whether this node yielded a dynamic workflow.
	IsDynamic bool   `json:"is_dynamic,omitempty"`
	DeckUri   string `json:"deck_uri,omitempty"`
	// This timestamp represents the instant when the event was reported by the executing framework. For example, when first processing a node the `occurred_at` timestamp should be the instant propeller makes progress, so when literal inputs are initially copied. The event however will not be sent until after the copy completes. Extracting both of these timestamps facilitates a more accurate portrayal of the evaluation time-series.
	ReportedAt time.Time `json:"reported_at,omitempty"`
}

type EventParentNodeExecutionMetadata struct {
	NodeId string `json:"node_id,omitempty"`
}

type EventParentTaskExecutionMetadata struct {
	Id *CoreTaskExecutionIdentifier `json:"id,omitempty"`
}

type EventResourcePoolInfo struct {
	// Unique resource ID used to identify this execution when allocating a token.
	AllocationToken string `json:"allocation_token,omitempty"`
	// Namespace under which this task execution requested an allocation token.
	Namespace string `json:"namespace,omitempty"`
}

type EventTaskExecutionEvent struct {
	// ID of the task. In combination with the retryAttempt this will indicate the task execution uniquely for a given parent node execution.
	TaskId                *CoreIdentifier              `json:"task_id,omitempty"`
	ParentNodeExecutionId *CoreNodeExecutionIdentifier `json:"parent_node_execution_id,omitempty"`
	RetryAttempt          int64                        `json:"retry_attempt,omitempty"`
	Phase                 *CoreTaskExecutionPhase      `json:"phase,omitempty"`
	ProducerId            string                       `json:"producer_id,omitempty"`
	Logs                  []CoreTaskLog                `json:"logs,omitempty"`
	// This timestamp represents when the original event occurred, it is generated by the executor of the task.
	OccurredAt time.Time `json:"occurred_at,omitempty"`
	// URI of the input file, it encodes all the information including Cloud source provider. ie., s3://...
	InputUri string `json:"input_uri,omitempty"`
	// Raw input data consumed by this task execution.
	InputData *CoreLiteralMap `json:"input_data,omitempty"`
	// URI to the output of the execution, it will be in a format that encodes all the information including Cloud source provider. ie., s3://...
	OutputUri string              `json:"output_uri,omitempty"`
	Error_    *CoreExecutionError `json:"error,omitempty"`
	// Raw output data produced by this task execution.
	OutputData *CoreLiteralMap `json:"output_data,omitempty"`
	// Custom data that the task plugin sends back. This is extensible to allow various plugins in the system.
	CustomInfo *ProtobufStruct `json:"custom_info,omitempty"`
	// Some phases, like RUNNING, can send multiple events with changed metadata (new logs, additional custom_info, etc) that should be recorded regardless of the lack of phase change. The version field should be incremented when metadata changes across the duration of an individual phase.
	PhaseVersion int64 `json:"phase_version,omitempty"`
	// An optional explanation for the phase transition. Deprecated: Use reasons instead.
	Reason string `json:"reason,omitempty"`
	// An optional list of explanations for the phase transition.
	Reasons []EventEventReason `json:"reasons,omitempty"`
	// A predefined yet extensible Task type identifier. If the task definition is already registered in flyte admin this type will be identical, but not all task executions necessarily use pre-registered definitions and this type is useful to render the task in the UI, filter task executions, etc.
	TaskType string `json:"task_type,omitempty"`
	// Metadata around how a task was executed.
	Metadata *FlyteidleventTaskExecutionMetadata `json:"metadata,omitempty"`
	// The event version is used to indicate versioned changes in how data is reported using this proto message. For example, event_verison > 0 means that maps tasks report logs using the TaskExecutionMetadata ExternalResourceInfo fields for each subtask rather than the TaskLog in this message.
	EventVersion int32 `json:"event_version,omitempty"`
	// This timestamp represents the instant when the event was reported by the executing framework. For example, a k8s pod task may be marked completed at (ie. `occurred_at`) the instant the container running user code completes, but this event will not be reported until the pod is marked as completed. Extracting both of these timestamps facilitates a more accurate portrayal of the evaluation time-series.
	ReportedAt time.Time `json:"reported_at,omitempty"`
}

type EventWorkflowExecutionEvent struct {
	ExecutionId *CoreWorkflowExecutionIdentifier `json:"execution_id,omitempty"`
	ProducerId  string                           `json:"producer_id,omitempty"`
	Phase       *CoreWorkflowExecutionPhase      `json:"phase,omitempty"`
	// This timestamp represents when the original event occurred, it is generated by the executor of the workflow.
	OccurredAt time.Time `json:"occurred_at,omitempty"`
	// URL to the output of the execution, it encodes all the information including Cloud source provider. ie., s3://...
	OutputUri string              `json:"output_uri,omitempty"`
	Error_    *CoreExecutionError `json:"error,omitempty"`
	// Raw output data produced by this workflow execution.
	OutputData *CoreLiteralMap `json:"output_data,omitempty"`
}

type ExecutionErrorErrorKind string

type ExecutionMetadataExecutionMode string

type FlyteidladminDynamicWorkflowNodeMetadata struct {
	// id represents the unique identifier of the workflow.
	Id *CoreIdentifier `json:"id,omitempty"`
	// Represents the compiled representation of the embedded dynamic workflow.
	CompiledWorkflow *CoreCompiledWorkflowClosure `json:"compiled_workflow,omitempty"`
	// dynamic_job_spec_uri is the location of the DynamicJobSpec proto message for this DynamicWorkflow. This is required to correctly recover partially completed executions where the subworkflow has already been compiled.
	DynamicJobSpecUri string `json:"dynamic_job_spec_uri,omitempty"`
}

type FlyteidladminNodeExecution struct {
	// Uniquely identifies an individual node execution.
	Id *CoreNodeExecutionIdentifier `json:"id,omitempty"`
	// Path to remote data store where input blob is stored.
	InputUri string `json:"input_uri,omitempty"`
	// Computed results associated with this node execution.
	Closure  *AdminNodeExecutionClosure  `json:"closure,omitempty"`
	Metadata *AdminNodeExecutionMetaData `json:"metadata,omitempty"`
}

type FlyteidladminTaskCreateRequest struct {
	Id   *CoreIdentifier `json:"id,omitempty"`
	Spec *AdminTaskSpec  `json:"spec,omitempty"`
}

type FlyteidladminTaskCreateResponse struct {
}

type FlyteidladminTaskExecution struct {
	// Unique identifier for the task execution.
	Id *CoreTaskExecutionIdentifier `json:"id,omitempty"`
	// Path to remote data store where input blob is stored.
	InputUri string `json:"input_uri,omitempty"`
	// Task execution details and results.
	Closure *AdminTaskExecutionClosure `json:"closure,omitempty"`
	// Whether this task spawned nodes.
	IsParent bool `json:"is_parent,omitempty"`
}

type FlyteidladminTaskNodeMetadata struct {
	// Captures the status of caching for this execution.
	CacheStatus   *CoreCatalogCacheStatus `json:"cache_status,omitempty"`
	CatalogKey    *CoreCatalogMetadata    `json:"catalog_key,omitempty"`
	CheckpointUri string                  `json:"checkpoint_uri,omitempty"`
}

type FlyteidladminWorkflowNodeMetadata struct {
	// The identifier for a workflow execution launched by a node.
	ExecutionId *CoreWorkflowExecutionIdentifier `json:"executionId,omitempty"`
}

type FlyteidleventDynamicWorkflowNodeMetadata struct {
	// id represents the unique identifier of the workflow.
	Id *CoreIdentifier `json:"id,omitempty"`
	// Represents the compiled representation of the embedded dynamic workflow.
	CompiledWorkflow *CoreCompiledWorkflowClosure `json:"compiled_workflow,omitempty"`
	// dynamic_job_spec_uri is the location of the DynamicJobSpec proto message for this DynamicWorkflow. This is required to correctly recover partially completed executions where the workflow has already been compiled.
	DynamicJobSpecUri string `json:"dynamic_job_spec_uri,omitempty"`
}

type FlyteidleventTaskExecutionMetadata struct {
	// Unique, generated name for this task execution used by the backend.
	GeneratedName string `json:"generated_name,omitempty"`
	// Additional data on external resources on other back-ends or platforms (e.g. Hive, Qubole, etc) launched by this task execution.
	ExternalResources []EventExternalResourceInfo `json:"external_resources,omitempty"`
	// Includes additional data on concurrent resource management used during execution.. This is a repeated field because a plugin can request multiple resource allocations during execution.
	ResourcePoolInfo []EventResourcePoolInfo `json:"resource_pool_info,omitempty"`
	// The identifier of the plugin used to execute this task.
	PluginIdentifier string                              `json:"plugin_identifier,omitempty"`
	InstanceClass    *TaskExecutionMetadataInstanceClass `json:"instance_class,omitempty"`
}

type FlyteidleventTaskNodeMetadata struct {
	// Captures the status of caching for this execution.
	CacheStatus *CoreCatalogCacheStatus `json:"cache_status,omitempty"`
	CatalogKey  *CoreCatalogMetadata    `json:"catalog_key,omitempty"`
	// Captures the status of cache reservations for this execution.
	ReservationStatus *CatalogReservationStatus `json:"reservation_status,omitempty"`
	CheckpointUri     string                    `json:"checkpoint_uri,omitempty"`
	// In the case this task launched a dynamic workflow we capture its structure here.
	DynamicWorkflow *FlyteidleventDynamicWorkflowNodeMetadata `json:"dynamic_workflow,omitempty"`
}

type FlyteidleventWorkflowNodeMetadata struct {
	ExecutionId *CoreWorkflowExecutionIdentifier `json:"execution_id,omitempty"`
}

type GenericSwaggerError struct {
	// contains filtered or unexported fields
}

type GetExecutionMetricsOpts struct {
	Depth optional.Int32
}

type GetLaunchPlanOpts struct {
	IdResourceType optional.String
}

type GetProjectAttributesOpts struct {
	ResourceType optional.String
}

type GetProjectDomainAttributesOpts struct {
	ResourceType optional.String
}

type GetTaskExecutionDataOpts struct {
	IdTaskIdResourceType optional.String
}

type GetTaskExecutionOpts struct {
	IdTaskIdResourceType optional.String
}

type GetTaskOpts struct {
	IdResourceType optional.String
}

type GetWorkflowAttributesOpts struct {
	ResourceType optional.String
}

type GetWorkflowOpts struct {
	IdResourceType optional.String
}

type IoStrategyDownloadMode string

type IoStrategyUploadMode string