Index

Symbols

--activate union-launchplan command line option --activate-launchplan union-register command line option --activate-launchplans union-register command line option --active-only union-get-launchplan command line option --annotation union-build command line option union-run command line option --annotations union-build command line option union-run command line option --auth union-create-login command line option --backfill-window union-backfill command line option --cluster-pool union-build command line option union-run command line option --config union command line option --copy union-build command line option union-package command line option union-register command line option union-run command line option --copy-all union-build command line option union-run command line option --deactivate union-launchplan command line option --depth union-metrics command line option --deref-symlinks union-package command line option union-register command line option union-serialize-fast-workflows command line option --destination-dir union-build command line option union-register command line option union-run command line option --disable-notifications union-build command line option union-run command line option --do-not-execute union-backfill command line option --domain union-backfill command line option union-build command line option union-create-secret command line option union-delete-secret command line option union-delete-workspace command line option union-execution command line option union-get-launchplan command line option union-get-secret command line option union-get-workspace command line option union-launchplan command line option union-metrics command line option union-register command line option union-run command line option union-update-secret command line option --dry-run union-backfill command line option union-register command line option --dump-snippet union-build command line option union-run command line option --ecl union-build command line option union-run command line option --env union-build command line option union-package command line option union-register command line option union-run command line option union-serialize command line option --envvars union-build command line option union-package command line option union-register command line option union-run command line option union-serialize command line option --execute union-backfill command line option --execution-cluster-label union-build command line option union-run command line option --execution-id union-execution command line option --execution-name union-backfill command line option --fail-fast union-backfill command line option --fast union-build command line option union-package command line option --folder union-serialize-fast-workflows command line option union-serialize-workflows command line option --force union-package command line option --from-date union-backfill command line option --host union-create-login command line option --image union-build command line option union-package command line option union-register command line option union-run command line option union-serialize command line option --in-container-config-path union-serialize command line option --in-container-source-path union-package command line option --in-container-virtualenv-root union-serialize command line option --init union-create-workspace-config command line option --label union-build command line option union-run command line option --labels union-build command line option union-run command line option --limit union-build command line option union-get-launchplan command line option union-run command line option --local-source-root union-serialize command line option --max-parallelism union-build command line option union-run command line option --name union-build command line option union-get-workspace command line option union-run command line option --no-fail-fast union-backfill command line option --non-fast union-register command line option

--output union-package command line option union-register command line option --overwrite-cache union-backfill command line option union-build command line option union-run command line option --parallel union-backfill command line option --pkgs union command line option --port union-serve-agent command line option --project union-backfill command line option union-build command line option union-create-secret command line option union-delete-secret command line option union-delete-workspace command line option union-execution command line option union-get-launchplan command line option union-get-secret command line option union-get-workspace command line option union-launchplan command line option union-metrics command line option union-register command line option union-run command line option union-update-secret command line option --python-interpreter union-package command line option --raw-data-prefix union-build command line option union-register command line option union-run command line option --raw-output-data-prefix union-build command line option union-run command line option --recursive union-fetch command line option --remote union-build command line option union-run command line option --scheduled union-get-launchplan command line option --serial union-backfill command line option --serverless union-create-login command line option --service-account union-build command line option union-register command line option union-run command line option --show-details union-get-workspace command line option --skip-error union-register command line option --skip-errors union-register command line option --source union-package command line option --tag union-build command line option union-run command line option --tags union-build command line option union-run command line option --template union-init command line option --timeout union-serve-agent command line option --to-date union-backfill command line option --value union-create-secret command line option union-update-secret command line option --value-file union-create-secret command line option union-update-secret command line option --verbose union command line option --version union-backfill command line option union-register command line option --wait-execution union-build command line option union-run command line option --worker union-serve-agent command line option -c union command line option -D union-register command line option -d union-backfill command line option union-build command line option union-execution command line option union-get-launchplan command line option union-launchplan command line option union-metrics command line option, [1] union-package command line option union-register command line option union-run command line option -f union-create-secret command line option union-package command line option union-serialize-fast-workflows command line option union-serialize-workflows command line option union-update-secret command line option -i union-build command line option union-package command line option union-register command line option union-run command line option union-serialize command line option -k union command line option -l union-get-launchplan command line option -n union-backfill command line option -o union-package command line option union-register command line option -p union-backfill command line option union-build command line option union-execution command line option union-get-launchplan command line option union-launchplan command line option union-metrics command line option union-package command line option union-register command line option union-run command line option -r union-build command line option union-fetch command line option union-run command line option -s union-package command line option -v union command line option union-backfill command line option union-register command line option

A

activate_launchplan() (union.remote.UnionRemote method) ActorEnvironment (class in union.actor) add_entity() (flytekit.core.workflow.ImperativeWorkflow method) add_workflow_input() (flytekit.core.workflow.ImperativeWorkflow method) add_workflow_output() (flytekit.core.workflow.ImperativeWorkflow method) AirflowMetadata (class in flytekitplugins.airflow.agent) AirflowTask (class in flytekitplugins.airflow) annotation (flytekit.LiteralType property) Annotations (class in flytekit) ANY (flytekit.Secret.MountType attribute) approve (class in flytekit)

Artifact (class in flytekit) assumable_iam_role (flytekit.AuthRole property) attr_path (flytekit.extend.Promise property) AuthRole (class in flytekit) auto() (flytekit.configuration.Config class method) (flytekit.configuration.ImageConfig class method) (flytekit.configuration.PlatformConfig class method) (flytekit.configuration.S3Config class method) (flytekit.configuration.SecretsConfig class method) (flytekit.configuration.StatsConfig class method) (flytekit.extend.ImageConfig class method) (in module flytekit.configuration.Config)

B

BaseAccelerator (class in flytekit.extras.accelerators) BigQueryConfig (class in flytekitplugins.bigquery) BigQueryTask (class in flytekitplugins.bigquery) binary (flytekit.Scalar property) Blob (class in flytekit)

blob (flytekit.Scalar property) BlobMetadata (class in flytekit) BlobType (class in flytekit) BotoAgent (class in flytekitplugins.awssagemaker_inference) BotoTask (class in flytekitplugins.awssagemaker_inference) branch_complete() (flytekit.extend.ExecutionState method)

C

calculate() (flytekit.HashMethod method) ChatGPTTask (class in flytekitplugins.openai) CLIENT_ID union-delete-app command line option CLIENT_NAME union-create-app command line option collection (flytekit.Literal property) collection_type (flytekit.LiteralType property) compilation_state (flytekit.core.workflow.ImperativeWorkflow property) compile() (flytekit.core.base_task.PythonTask method) compile_into_workflow() (flytekit.PythonFunctionTask method) conditional (class in flytekit) Config (class in flytekit.configuration) config (flytekit.remote.entities.FlyteTask property) CONFIG_FILE union-create-workspace command line option union-create-workspace-config command line option construct_node_metadata() (flytekit.core.base_task.PythonTask method) container (flytekit.remote.entities.FlyteTask property) ContainerTask (class in flytekit) ContainerTask.IOStrategy (class in flytekit)

ContainerTask.MetadataFormat (class in flytekit) context_manager (in module flytekit.extend) crawl() (flytekit.types.directory.FlyteDirectory method) create() (flytekitplugins.awssagemaker_inference.SageMakerEndpointAgent method) create_artifact() (union.remote.UnionRemote method) create_execution() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) create_from() (flytekit.Artifact method) create_launch_plan() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) create_node (class in flytekit.core.node_creation) create_sagemaker_deployment() (in module flytekitplugins.awssagemaker_inference) create_task() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) create_upload_location() (flytekit.clients.raw.RawSynchronousFlyteClient method) create_workflow() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) CronSchedule (class in flytekit) current_context (class in flytekit) current_context() (flytekit.FlyteContext static method) custom (flytekit.remote.entities.FlyteTask property)

D

DatabricksV2 (class in flytekitplugins.spark) DataCard (class in union.artifacts) DataConfig (class in flytekit.configuration) Deck (class in flytekit.deck) deck_fields (flytekit.core.base_task.PythonTask property) decks (flytekit.ExecutionParameters property) decode() (flytekit.types.structured.StructuredDatasetDecoder method) (flytekitplugins.airflow.agent.AirflowMetadata class method) (flytekitplugins.spark.ParquetToSparkDecodingHandler method) default_entrypoint_settings() (flytekit.configuration.SerializationSettings static method) delete() (flytekitplugins.awssagemaker_inference.SageMakerEndpointAgent method) delete_sagemaker_deployment() (in module flytekitplugins.awssagemaker_inference) Description (class in flytekit) Description.DescriptionFormat (class in flytekit)

dict_to_generic_literal() (flytekit.extend.DictTransformer static method) dict_to_literal_map() (flytekit.extend.TypeEngine class method) DictTransformer (class in flytekit.extend) dimensionality (flytekit.BlobType property) disable_deck (flytekit.core.base_task.PythonTask property) dispatch_execute() (flytekit.core.base_task.PythonTask method) (flytekit.core.base_task.Task method) (flytekit.extend.ExecutableTemplateShimTask method) do() (flytekitplugins.awssagemaker_inference.BotoAgent method) Documentation (class in flytekit) download() (union.remote.UnionRemote method) DOWNLOAD-TO union-fetch command line option dynamic (in module flytekit) dynamic_execute() (flytekit.PythonFunctionTask method)

E

eager() (in module flytekit.experimental) EagerException (class in flytekit.experimental) Email (class in flytekit) embed_as_query() (flytekit.Artifact method) encode() (flytekit.types.structured.StructuredDatasetEncoder method) (flytekitplugins.airflow.agent.AirflowMetadata method) enter_conditional_section() (flytekit.FlyteContext.Builder method) enum_to_string() (flytekit.WorkflowExecutionPhase class method) ENV_VAR (flytekit.Secret.MountType attribute) environment (flytekit.core.base_task.PythonTask property) error (flytekit.remote.executions.FlyteNodeExecution property) (flytekit.remote.executions.FlyteTaskExecution property) (flytekit.remote.executions.FlyteWorkflowExecution property) (flytekit.Scalar property) ExecutableTemplateShimTask (class in flytekit.extend) execute() (flytekit.ContainerTask method) (flytekit.core.base_task.PythonTask method) (flytekit.core.base_task.Task method) (flytekit.core.workflow.ImperativeWorkflow method) (flytekit.extend.ExecutableTemplateShimTask method) (flytekit.extras.tasks.shell.ShellTask method) (flytekit.PythonFunctionTask method) (flytekit.SQLTask method) (flytekitplugins.mmcloud.MMCloudTask method) (union.remote.UnionRemote method)

execute_from_model() (flytekit.extend.ShimTaskExecutor method) execute_local_launch_plan() (union.remote.UnionRemote method) execute_local_task() (union.remote.UnionRemote method) execute_local_workflow() (union.remote.UnionRemote method) execute_reference_launch_plan() (union.remote.UnionRemote method) execute_reference_task() (union.remote.UnionRemote method) execute_reference_workflow() (union.remote.UnionRemote method) execute_remote_task_lp() (union.remote.UnionRemote method) execute_remote_wf() (union.remote.UnionRemote method) execution_date (flytekit.ExecutionParameters property) EXECUTION_ID union-metrics-dump command line option union-metrics-explain command line option execution_id (flytekit.ExecutionParameters property) ExecutionParameters (class in flytekit) ExecutionParameters.Builder (class in flytekit) ExecutionState (class in flytekit.extend) ExecutionState.Mode (class in flytekit.extend) exist() (flytekit.image_spec.ImageSpec method)

F

FAIL_AFTER_EXECUTABLE_NODES_COMPLETE (flytekit.WorkflowFailurePolicy attribute) FAIL_IMMEDIATELY (flytekit.WorkflowFailurePolicy attribute) failure_node (flytekit.remote.entities.FlyteWorkflow property) fast_package() (union.remote.UnionRemote method) FastSerializationSettings (class in flytekit.configuration) fetch_execution() (union.remote.UnionRemote method) fetch_launch_plan() (union.remote.UnionRemote method) fetch_task() (union.remote.UnionRemote method) fetch_task_lazy() (union.remote.UnionRemote method) fetch_workflow() (union.remote.UnionRemote method) fetch_workflow_lazy() (union.remote.UnionRemote method) FILE (flytekit.Secret.MountType attribute) FileSensor (class in flytekit.sensor) find_image() (flytekit.configuration.ImageConfig method) (flytekit.extend.ImageConfig method) FixedRate (class in flytekit) FLYTE-DATA-URI union-fetch command line option FlyteContext (class in flytekit) FlyteContext.Builder (class in flytekit) FlyteContextManager (class in flytekit) FlyteDirectory (class in flytekit.types.directory) FlyteFile (class in flytekit.types.file) FlyteIterator (class in flytekit.types.iterator) flytekit.configuration.Config module FlyteLaunchPlan (class in flytekit.remote.entities)

FlyteNode (class in flytekit.remote.entities) FlyteNodeExecution (class in flytekit.remote.executions) FlyteTask (class in flytekit.remote.entities) FlyteTaskExecution (class in flytekit.remote.executions) FlyteTaskNode (class in flytekit.remote.entities) FlyteWorkflow (class in flytekit.remote.entities) FlyteWorkflowExecution (class in flytekit.remote.executions) FlyteWorkflowNode (class in flytekit.remote.entities) for_endpoint() (flytekit.configuration.Config class method) (in module flytekit.configuration.Config) for_sandbox() (flytekit.configuration.Config class method) (in module flytekit.configuration.Config) force_push() (flytekit.image_spec.ImageSpec method) format (flytekit.BlobType property) from_flyte_idl() (flytekit.Annotations class method) (flytekit.AuthRole class method) (flytekit.Blob class method) (flytekit.BlobMetadata class method) (flytekit.BlobType class method) (flytekit.Labels class method) (flytekit.Literal class method) (flytekit.LiteralType class method) (flytekit.Scalar class method) from_images() (flytekit.configuration.ImageConfig class method) (flytekit.extend.ImageConfig class method) from_source() (flytekit.types.directory.FlyteDirectory class method) (flytekit.types.file.FlyteFile class method) full (flytekit.configuration.Image property)

G

GCSConfig (class in flytekit.configuration) generate_console_http_domain() (union.remote.UnionRemote method) generate_console_url() (union.remote.UnionRemote method) generic (flytekit.Scalar property) get() (flytekit.ExecutionParameters method) (flytekitplugins.awssagemaker_inference.SageMakerEndpointAgent method) (union.remote.UnionRemote method) get_active_launch_plan() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) get_all_tasks() (flytekit.core.base_task.TaskResolverMixin method) get_artifact() (union.remote.UnionRemote method) get_available_transformers() (flytekit.extend.TypeEngine class method) get_config() (flytekit.ContainerTask method) (flytekit.core.base_task.Task method) (flytekit.extend.PythonCustomizedContainerTask method) (flytekitplugins.snowflake.SnowflakeTask method) get_container() (flytekit.ContainerTask method) (flytekit.core.base_task.Task method) (flytekit.extend.PythonCustomizedContainerTask method) get_custom() (flytekit.core.base_task.Task method) (flytekit.extend.PythonCustomizedContainerTask method) (flytekit.extras.sqlite3.task.SQLite3Task method) (flytekitplugins.airflow.AirflowTask method) (flytekitplugins.awssagemaker_inference.BotoTask method) (flytekitplugins.awssagemaker_inference.SageMakerEndpointTask method) (flytekitplugins.bigquery.BigQueryTask method) (flytekitplugins.mmcloud.MMCloudTask method) (flytekitplugins.openai.ChatGPTTask method) get_deck() (flytekit.FlyteContext method) get_default_launch_plan() (flytekit.LaunchPlan static method) get_execution() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) get_execution_data() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) get_execution_metrics() (flytekit.clients.raw.RawSynchronousFlyteClient method) get_extended_resources() (flytekit.core.base_task.Task method) get_extra_headers_for_protocol() (union.remote.UnionRemote static method) get_input_types() (flytekit.core.base_task.PythonTask method) (flytekit.core.base_task.Task method) get_k8s_pod() (flytekit.ContainerTask method) (flytekit.core.base_task.Task method) get_launch_plan() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) get_literal_type() (flytekit.extend.DictTransformer method) (flytekit.extend.TypeTransformer method) (flytekit.extras.pytorch.PyTorchCheckpointTransformer method) (flytekit.extras.tensorflow.TensorFlowRecordFileTransformer method) (flytekit.extras.tensorflow.TensorFlowRecordsDirTransformer method) (flytekitplugins.spark.SparkDataFrameTransformer method)

get_node_execution() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) get_node_execution_data() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) get_or_create() (flytekit.LaunchPlan class method) get_project_domain_attributes() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) get_reference_entity (class in flytekit) get_serializable (class in flytekit.extend) get_sql() (flytekit.core.base_task.Task method) (flytekitplugins.bigquery.BigQueryTask method) (flytekitplugins.snowflake.SnowflakeTask method) get_task() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) get_task_execution() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) get_task_execution_data() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) get_transformer() (flytekit.extend.TypeEngine class method) get_type_for_input_var() (flytekit.core.base_task.PythonTask method) (flytekit.core.base_task.Task method) get_type_for_output_var() (flytekit.core.base_task.PythonTask method) (flytekit.core.base_task.Task method) get_upload_signed_url() (flytekit.clients.friendly.SynchronousFlyteClient method) get_workflow() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) get_workflow_attributes() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) GPUAccelerator (class in flytekit.extras.accelerators) guess_python_type() (flytekit.extend.DictTransformer method) (flytekit.extend.TypeEngine class method) (flytekit.extend.TypeTransformer method) (flytekit.extras.pytorch.PyTorchCheckpointTransformer method) (flytekit.extras.pytorch.PyTorchModuleTransformer method) (flytekit.extras.pytorch.PyTorchTensorTransformer method) (flytekit.extras.sklearn.SklearnEstimatorTransformer method) (flytekit.extras.tensorflow.TensorFlowRecordFileTransformer method) (flytekit.extras.tensorflow.TensorFlowRecordsDirTransformer method) guess_python_types() (flytekit.extend.TypeEngine class method)

H

hash (flytekit.Literal property) HashMethod (class in flytekit)

HDF5EncodedFile (in module flytekit.types.file) HTMLPage (in module flytekit.types.file)

I

id (flytekit.image_spec.ImageSpec property) (flytekit.remote.entities.FlyteTask property) (flytekit.remote.entities.FlyteWorkflow property) IgnoreOutputs (class in flytekit.core.base_task) (class in flytekit.extend) Image (class in flytekit.configuration) image_name() (flytekit.image_spec.ImageSpec method) ImageConfig (class in flytekit.configuration) (class in flytekit.extend) ImageSpec (class in flytekit.image_spec) ImperativeWorkflow (class in flytekit.core.workflow) initialize() (flytekit.FlyteContextManager static method)

inputs (flytekit.core.workflow.ImperativeWorkflow property) Interface (class in flytekit.extend) interface (flytekit.remote.entities.FlyteLaunchPlan property) (flytekit.remote.entities.FlyteTask property) (flytekit.remote.entities.FlyteWorkflow property) (flytekit.remote.executions.FlyteNodeExecution property) interpolate_query() (flytekit.SQLTask class method) is_container() (flytekit.image_spec.ImageSpec method) is_done (flytekit.remote.executions.FlyteNodeExecution property) (flytekit.remote.executions.FlyteTaskExecution property) (flytekit.remote.executions.FlyteWorkflowExecution property) is_ready (flytekit.extend.Promise property)

J

JoblibSerializedFile (in module flytekit.types.file)

JPEGImageFile (in module flytekit.types.file) JSON (in module flytekit.types.iterator)

K

kubernetes_service_account (flytekit.AuthRole property)

kwtypes (class in flytekit) (class in flytekit.core.base_task)

L

Labels (class in flytekit) launch_backfill() (union.remote.UnionRemote method) LAUNCHPLAN union-backfill command line option union-launchplan command line option LaunchPlan (class in flytekit) LAUNCHPLAN-NAME union-get-launchplan command line option LAUNCHPLAN-VERSION union-get-launchplan command line option launchplan_ref (flytekit.remote.entities.FlyteWorkflowNode property) LAUNCHPLAN_VERSION union-backfill command line option union-launchplan command line option LaunchPlanReference (class in flytekit) lazy_import_transformers() (flytekit.extend.TypeEngine class method) list_active_launch_plans_paginated() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) list_executions_paginated() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) list_launch_plan_ids_paginated() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) list_launch_plans_paginated() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) list_matchable_attributes() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) list_node_executions() (flytekit.clients.friendly.SynchronousFlyteClient method)

list_node_executions_for_task_paginated() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) list_node_executions_paginated() (flytekit.clients.raw.RawSynchronousFlyteClient method) list_projects() (flytekit.clients.raw.RawSynchronousFlyteClient method) list_projects_paginated() (flytekit.clients.friendly.SynchronousFlyteClient method) list_signals() (flytekit.clients.raw.RawSynchronousFlyteClient method) (union.remote.UnionRemote method) list_task_executions_paginated() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) list_task_ids_paginated() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) list_tasks_by_version() (union.remote.UnionRemote method) list_tasks_paginated() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) list_workflow_ids_paginated() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) list_workflows_paginated() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) listdir() (flytekit.types.directory.FlyteDirectory class method) Literal (class in flytekit) literal_map_to_kwargs() (flytekit.extend.TypeEngine class method) LiteralType (class in flytekit) load_task() (flytekit.core.base_task.TaskResolverMixin method) loader_args() (flytekit.core.base_task.TaskResolverMixin method) local_execute() (flytekit.core.base_task.Task method) logging (flytekit.ExecutionParameters property) look_up_image_info() (flytekit.configuration.Image static method)

M

map (flytekit.Literal property) map_task (class in flytekit.core.array_node_map_task) map_value_type (flytekit.LiteralType property) MarkdownRenderer (class in flytekit.deck) metadata (flytekit.Blob property) (flytekit.Literal property) (flytekit.LiteralType property) (flytekit.remote.entities.FlyteTask property) (flytekit.remote.entities.FlyteWorkflow property)

metadata_defaults (flytekit.remote.entities.FlyteWorkflow property) MMCloudConfig (class in flytekitplugins.mmcloud) MMCloudTask (class in flytekitplugins.mmcloud) ModelCard (class in union.artifacts) module flytekit.configuration.Config MultiInstanceGPUAccelerator (class in flytekit.extras.accelerators)

N

NAME union-create-secret command line option union-delete-secret command line option union-delete-workspace command line option union-update-secret command line option name (flytekit.extend.ExecutableTemplateShimTask property) (flytekit.PythonFunctionTask property) named_tuple_to_variable_map() (flytekit.extend.TypeEngine class method) new_builder() (flytekit.configuration.SerializationSettings method) new_compilation_state() (flytekit.FlyteContext method) (flytekit.FlyteContext.Builder method) new_dir() (flytekit.types.directory.FlyteDirectory method)

new_execution_state() (flytekit.FlyteContext method) (flytekit.FlyteContext.Builder method) new_file() (flytekit.types.directory.FlyteDirectory method) new_remote() (flytekit.types.directory.FlyteDirectory class method) new_remote_file() (flytekit.types.file.FlyteFile class method) new_spark_session() (in module flytekitplugins.spark) node (flytekit.core.promise.NodeOutput property) node_executions (flytekit.remote.executions.FlyteWorkflowExecution property) node_id (flytekit.core.promise.NodeOutput property) NodeOutput (class in flytekit.core.promise) nodes (flytekit.remote.entities.FlyteWorkflow property) none_type (flytekit.Scalar property)

O

offloaded_metadata (flytekit.Literal property) OnArtifact (class in union.artifacts) open() (flytekit.types.file.FlyteFile method)

Options (class in flytekit.remote.remote) OutputLocation (class in flytekit.extras.tasks.shell) outputs (flytekit.remote.entities.FlyteWorkflow property)

P

PACKAGE_OR_MODULE union-register command line option PagerDuty (class in flytekit) ParquetToSparkDecodingHandler (class in flytekitplugins.spark) patch() (in module flytekit.testing) path (flytekit.types.directory.FlyteDirectory attribute) (flytekit.types.file.FlyteFile attribute) PDFFile (in module flytekit.types.file) PlatformConfig (class in flytekit.configuration) PNGImageFile (in module flytekit.types.file) PodTemplate (class in flytekit) poke() (flytekit.sensor.FileSensor method) post_execute() (flytekit.core.base_task.PythonTask method) (flytekit.extend.ExecutableTemplateShimTask method) (flytekit.extras.tasks.shell.ShellTask method) pre_execute() (flytekit.core.base_task.PythonTask method) (flytekit.core.base_task.Task method) (flytekit.extend.ExecutableTemplateShimTask method) (flytekit.extras.tasks.shell.ShellTask method)

primitive (flytekit.Scalar property) PROJECT_NAME union-init command line option Promise (class in flytekit.extend) promote_from_closure() (flytekit.remote.entities.FlyteWorkflow class method) promote_from_model() (flytekit.remote.entities.FlyteTaskNode class method) python_interface (flytekit.core.base_task.PythonTask property) python_type (flytekit.extend.TypeTransformer property) PythonCustomizedContainerTask (class in flytekit.extend) PythonFunctionTask (class in flytekit) PythonFunctionTask.ExecutionBehavior (class in flytekit) PythonInstanceTask (class in flytekit) PythonNotebook (in module flytekit.types.file) PythonPickledFile (in module flytekit.types.file) PythonTask (class in flytekit.core.base_task) PyTorchCheckpoint (class in flytekit.extras.pytorch) PyTorchCheckpointTransformer (class in flytekit.extras.pytorch) PyTorchModuleTransformer (class in flytekit.extras.pytorch) PyTorchTensorTransformer (class in flytekit.extras.pytorch)

R

raw (flytekit.clients.friendly.SynchronousFlyteClient property) raw_register() (union.remote.UnionRemote method) RawSynchronousFlyteClient (class in flytekit.clients.raw) ready() (flytekit.core.workflow.ImperativeWorkflow method) recent_executions() (union.remote.UnionRemote method) recover_execution() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) ref (flytekit.extend.Promise property) reference_id (flytekit.remote.entities.FlyteTaskNode property) reference_launch_plan (class in flytekit) reference_task (class in flytekit) reference_workflow (class in flytekit) register() (flytekit.extend.TypeEngine class method)

register_launch_plan() (union.remote.UnionRemote method) register_project() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) register_script() (union.remote.UnionRemote method) register_task() (union.remote.UnionRemote method) register_workflow() (union.remote.UnionRemote method) relaunch_execution() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) remote_context() (union.remote.UnionRemote method) remote_source (flytekit.types.directory.FlyteDirectory property) (flytekit.types.file.FlyteFile property) remove_inputs() (flytekit.extend.Interface method) Resources (class in flytekit)

S

S3Config (class in flytekit.configuration) SageMakerDeleteEndpointConfigTask (class in flytekitplugins.awssagemaker_inference) SageMakerDeleteModelTask (class in flytekitplugins.awssagemaker_inference) SageMakerEndpointAgent (class in flytekitplugins.awssagemaker_inference) SageMakerEndpointConfigTask (class in flytekitplugins.awssagemaker_inference) SageMakerEndpointTask (class in flytekitplugins.awssagemaker_inference) SageMakerInvokeEndpointTask (class in flytekitplugins.awssagemaker_inference) SageMakerModelTask (class in flytekitplugins.awssagemaker_inference) sandbox_execute() (flytekit.core.base_task.Task method) Scalar (class in flytekit) scalar (flytekit.Literal property) schema (flytekit.Scalar property) Secret (class in flytekit) Secret.MountType (class in flytekit) SecretsConfig (class in flytekit.configuration) SecurityContext (class in flytekit) SerializationSettings (class in flytekit.configuration) SerializationSettings.Builder (class in flytekit.configuration) serialized_context (flytekit.configuration.SerializationSettings property) set_metadata() (flytekit.Literal method) set_signal() (flytekit.clients.raw.RawSynchronousFlyteClient method) (union.remote.UnionRemote method) ShellTask (class in flytekit.extras.tasks.shell) ShimTaskExecutor (class in flytekit.extend) should_fast_serialize() (flytekit.configuration.SerializationSettings method) SklearnEstimatorTransformer (class in flytekit.extras.sklearn)

Slack (class in flytekit) sleep (class in flytekit) SnowflakeConfig (class in flytekitplugins.snowflake) SnowflakeTask (class in flytekitplugins.snowflake) SourceCode (class in flytekit) SourceCodeRenderer (class in flytekit.deck) Spark (class in flytekitplugins.spark) SparkDataFrameSchemaReader (class in flytekitplugins.spark) SparkDataFrameSchemaWriter (class in flytekitplugins.spark) SparkDataFrameTransformer (class in flytekitplugins.spark) SQLite3Config (class in flytekit.extras.sqlite3.task) SQLite3Task (class in flytekit.extras.sqlite3.task) SQLTask (class in flytekit) stats (flytekit.ExecutionParameters property) StatsConfig (class in flytekit.configuration) StructuredDataset (class in flytekit.types.structured) StructuredDatasetDecoder (class in flytekit.types.structured) StructuredDatasetEncoder (class in flytekit.types.structured) sub_workflow_ref (flytekit.remote.entities.FlyteWorkflowNode property) subworkflow_node_executions (flytekit.remote.executions.FlyteNodeExecution property) SVGImageFile (in module flytekit.types.file) sync() (union.remote.UnionRemote method) sync_execution() (union.remote.UnionRemote method) sync_node_execution() (union.remote.UnionRemote method) sync_task_execution() (union.remote.UnionRemote method) SynchronousFlyteClient (class in flytekit.clients.friendly) system_entry_point() (in module flytekit.exceptions.scopes)

T

T (class in flytekit.extend) tag (flytekit.image_spec.ImageSpec property) take_branch() (flytekit.extend.ExecutionState method) task (class in flytekit) Task (class in flytekit.core.base_task) task_config (flytekit.core.base_task.PythonTask property) task_id (flytekit.ExecutionParameters property) task_mock() (in module flytekit.testing) task_name() (flytekit.core.base_task.TaskResolverMixin method) task_node (flytekit.remote.entities.FlyteNode property) task_template (flytekit.extend.PythonCustomizedContainerTask property) TaskMetadata (class in flytekit) TaskReference (class in flytekit) TaskResolverMixin (class in flytekit.core.base_task) TensorboardLogs (in module flytekit.types.directory) TensorFlowRecordFileTransformer (class in flytekit.extras.tensorflow) TensorFlowRecordsDirTransformer (class in flytekit.extras.tensorflow) terminate() (union.remote.UnionRemote method) terminate_execution() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) TFRecordsDirectory (in module flytekit.types.directory) to_flyte_idl() (flytekit.Annotations method) (flytekit.AuthRole method) (flytekit.Blob method) (flytekit.BlobMetadata method) (flytekit.BlobType method) (flytekit.Labels method) (flytekit.Literal method) (flytekit.LiteralType method) (flytekit.Scalar method)

to_html() (flytekit.deck.SourceCodeRenderer method) (flytekit.extend.TypeTransformer method) to_id_idl() (flytekit.Artifact method) to_literal() (flytekit.extend.DictTransformer method) (flytekit.extend.TypeEngine class method) (flytekit.extend.TypeTransformer method) (flytekit.extras.pytorch.PyTorchCheckpointTransformer method) (flytekit.extras.tensorflow.TensorFlowRecordFileTransformer method) (flytekit.extras.tensorflow.TensorFlowRecordsDirTransformer method) (flytekitplugins.spark.SparkDataFrameTransformer method) to_literal_type() (flytekit.extend.TypeEngine class method) to_python_value() (flytekit.extend.DictTransformer method) (flytekit.extend.TypeEngine class method) (flytekit.extend.TypeTransformer method) (flytekit.extras.pytorch.PyTorchCheckpointTransformer method) (flytekit.extras.tensorflow.TensorFlowRecordFileTransformer method) (flytekit.extras.tensorflow.TensorFlowRecordsDirTransformer method) (flytekitplugins.spark.SparkDataFrameTransformer method) to_taskmetadata_model() (flytekit.TaskMetadata method) TopFrameRenderer (class in flytekit.deck) type (flytekit.BlobMetadata property) (flytekit.remote.entities.FlyteTask property) type_assertions_enabled (flytekit.extend.TypeTransformer property) TypeEngine (class in flytekit.extend) TypeTransformer (class in flytekit.extend)

U

union (flytekit.Scalar property) union command line option --config --pkgs --verbose -c -k -v union-backfill command line option --backfill-window --do-not-execute --domain --dry-run --execute --execution-name --fail-fast --from-date --no-fail-fast --overwrite-cache --parallel --project --serial --to-date --version -d -n -p -v LAUNCHPLAN LAUNCHPLAN_VERSION union-build command line option --annotation --annotations --cluster-pool --copy --copy-all --destination-dir --disable-notifications --domain --dump-snippet --ecl --env --envvars --execution-cluster-label --fast --image --label --labels --limit --max-parallelism --name --overwrite-cache --project --raw-data-prefix --raw-output-data-prefix --remote --service-account --tag --tags --wait-execution -d -i -p -r union-create-app command line option CLIENT_NAME union-create-login command line option --auth --host --serverless union-create-secret command line option --domain --project --value --value-file -f NAME union-create-workspace command line option CONFIG_FILE union-create-workspace-config command line option --init CONFIG_FILE union-delete-app command line option CLIENT_ID union-delete-secret command line option --domain --project NAME union-delete-workspace command line option --domain --project NAME union-execution command line option --domain --execution-id --project -d -p union-fetch command line option --recursive -r DOWNLOAD-TO FLYTE-DATA-URI union-get-launchplan command line option --active-only --domain --limit --project --scheduled -d -l -p LAUNCHPLAN-NAME LAUNCHPLAN-VERSION union-get-secret command line option --domain --project union-get-workspace command line option --domain --name --project --show-details union-init command line option --template PROJECT_NAME union-launchplan command line option --activate --deactivate --domain --project -d -p LAUNCHPLAN LAUNCHPLAN_VERSION

union-metrics command line option --depth --domain --project -d, [1] -p union-metrics-dump command line option EXECUTION_ID union-metrics-explain command line option EXECUTION_ID union-package command line option --copy --deref-symlinks --env --envvars --fast --force --image --in-container-source-path --output --python-interpreter --source -d -f -i -o -p -s union-register command line option --activate-launchplan --activate-launchplans --copy --deref-symlinks --destination-dir --domain --dry-run --env --envvars --image --non-fast --output --project --raw-data-prefix --service-account --skip-error --skip-errors --version -d -D -i -o -p -v PACKAGE_OR_MODULE union-run command line option --annotation --annotations --cluster-pool --copy --copy-all --destination-dir --disable-notifications --domain --dump-snippet --ecl --env --envvars --execution-cluster-label --image --label --labels --limit --max-parallelism --name --overwrite-cache --project --raw-data-prefix --raw-output-data-prefix --remote --service-account --tag --tags --wait-execution -d -i -p -r union-serialize command line option --env --envvars --image --in-container-config-path --in-container-virtualenv-root --local-source-root -i union-serialize-fast-workflows command line option --deref-symlinks --folder -f union-serialize-workflows command line option --folder -f union-serve-agent command line option --port --timeout --worker union-update-secret command line option --domain --project --value --value-file -f NAME UnionRemote (class in union.remote) update_launch_plan() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) update_named_entity() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) update_project() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) update_project_domain_attributes() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) update_workflow_attributes() (flytekit.clients.friendly.SynchronousFlyteClient method) (flytekit.clients.raw.RawSynchronousFlyteClient method) upload_file() (union.remote.UnionRemote method) upstream_node_ids (flytekit.remote.entities.FlyteNode property) uri (flytekit.Blob property) user_entry_point() (in module flytekit.exceptions.scopes)

V

val (flytekit.extend.Promise property) validate_image() (flytekit.configuration.ImageConfig static method) (flytekit.extend.ImageConfig static method) value (flytekit.Literal property) (flytekit.Scalar property)

var (flytekit.extend.Promise property) venv_root_from_interpreter() (flytekit.configuration.SerializationSettings static method) version (flytekit.configuration.Image property)

W

wait() (union.remote.UnionRemote method) wait_for_input (class in flytekit) with_apt_packages() (flytekit.image_spec.ImageSpec method) with_commands() (flytekit.image_spec.ImageSpec method) with_copy() (flytekit.image_spec.ImageSpec method) with_inputs() (flytekit.extend.Interface method) with_outputs() (flytekit.extend.Interface method) with_packages() (flytekit.image_spec.ImageSpec method)

with_params() (flytekit.extend.ExecutionState method) with_serialized_context() (flytekit.configuration.SerializationSettings method) workflow (class in flytekit) workflow_id (flytekit.remote.entities.FlyteLaunchPlan property) WorkflowExecutionPhase (class in flytekit) WorkflowFailurePolicy (class in flytekit) WorkflowReference (class in flytekit) working_directory (flytekit.ExecutionParameters property)