flytekit.clients package

Submodules

flytekit.clients.friendly module

class flytekit.clients.friendly.SynchronousFlyteClient(url, insecure=False, credentials=None, options=None)[source]

Bases: flytekit.clients.raw.RawSynchronousFlyteClient

create_execution(project, domain, name, execution_spec, inputs)[source]

This will create an execution for the given execution spec. :param Text project: :param Text domain: :param Text name: :param flytekit.models.execution.ExecutionSpec execution_spec: This is the specification for the execution. :param flytekit.models.literals.LiteralMap inputs: The inputs for the execution :returns: The unique identifier for the execution. :rtype: flytekit.models.core.identifier.WorkflowExecutionIdentifier

create_launch_plan(launch_plan_identifer, launch_plan_spec)[source]

This will create a launch plan definition in the Admin database. Once successful, the launch plan object can be retrieved via the client or viewed via the UI or command-line interfaces.

Note

Overwrites are not supported so any request for a given project, domain, name, and version that exists in the database must match the existing definition exactly. This also means that as long as the request remains identical, calling this method multiple times will result in success.

Param

flytekit.models.core.identifier.Identifier launch_plan_identifer: The identifier for this launch plan.

Param

flytekit.models.launch_plan.LaunchPlanSpec launch_plan_spec: This is the actual definition of the launch plan that should be created.

Raises
create_task(task_identifer, task_spec)[source]

This will create a task definition in the Admin database. Once successful, the task object can be retrieved via the client or viewed via the UI or command-line interfaces.

Note

Overwrites are not supported so any request for a given project, domain, name, and version that exists in the database must match the existing definition exactly. Furthermore, as long as the request remains identical, calling this method multiple times will result in success.

Parameters
Raises
create_workflow(workflow_identifier, workflow_spec)[source]

This will create a workflow definition in the Admin database. Once successful, the workflow object can be retrieved via the client or viewed via the UI or command-line interfaces.

Note

Overwrites are not supported so any request for a given project, domain, name, and version that exists in the database must match the existing definition exactly. Furthermore, as long as the request remains identical, calling this method multiple times will result in success.

Param

flytekit.models.core.identifier.Identifier workflow_identifier: The identifier for this workflow.

Param

flytekit.models.admin.workflow.WorkflowSpec workflow_spec: This is the actual definition of the workflow that should be created.

Raises
get_active_launch_plan(identifier)[source]

Retrieves the active launch plan entity given a named entity identifier (project, domain, name). Raises an error if no active launch plan exists.

Parameters

identifier (flytekit.models.common.NamedEntityIdentifier) – NamedEntityIdentifier to list.

Return type

flytekit.models.launch_plan.LaunchPlan

get_execution(id)[source]
Parameters

id (flytekit.common.core.identifier.WorkflowExecutionIdentifier) –

Return type

flytekit.models.execution.Execution

get_execution_data(id)[source]

Returns signed URLs to LiteralMap blobs for an execution’s inputs and outputs (when available).

Parameters

id (flytekit.models.core.identifier.WorkflowExecutionIdentifier) –

Return type

flytekit.models.execution.WorkflowExecutionGetDataResponse

get_launch_plan(id)[source]

Retrieves a launch plan entity.

Parameters

id (flytekit.models.core.identifier.Identifier) – unique identifier for launch plan to retrieve

Return type

flytekit.models.launch_plan.LaunchPlan

get_node_execution(node_execution_identifier)[source]
Parameters

node_execution_identifier (flytekit.models.core.identifier.NodeExecutionIdentifier) –

Return type

flytekit.models.node_execution.NodeExecution

get_node_execution_data(node_execution_identifier)[source]

Returns signed URLs to LiteralMap blobs for a node execution’s inputs and outputs (when available).

Parameters

node_execution_identifier (flytekit.models.core.identifier.NodeExecutionIdentifier) –

Return type

flytekit.models.execution.NodeExecutionGetDataResponse

get_project_domain_attributes(project, domain, resource_type)[source]

Fetches the custom attributes set for a project and domain combination. :param Text project: :param Text domain: :param flytekit.models.MatchableResource resource_type: :return:

get_task(id)[source]

This returns a single task for a given identifier.

Parameters

id (flytekit.models.core.identifier.Identifier) – The ID representing a given task.

Raises

TODO

Return type

flytekit.models.task.Task

get_task_execution(id)[source]
Parameters

id (flytekit.models.core.identifier.TaskExecutionIdentifier) –

Return type

flytekit.models.admin.task_execution.TaskExecution

get_task_execution_data(task_execution_identifier)[source]

Returns signed URLs to LiteralMap blobs for a node execution’s inputs and outputs (when available).

Parameters

task_execution_identifier (flytekit.models.core.identifier.TaskExecutionIdentifier) –

Return type

flytekit.models.execution.NodeExecutionGetDataResponse

get_workflow(id)[source]

This returns a single task for a given ID.

Parameters

id (flytekit.models.core.identifier.Identifier) – The ID representing a given task.

Raises

TODO

Return type

flytekit.models.admin.workflow.Workflow

get_workflow_attributes(project, domain, workflow, resource_type)[source]

Fetches the custom attributes set for a project, domain, and workflow combination. :param Text project: :param Text domain: :param Text workflow: :param flytekit.models.MatchableResource resource_type: :return:

list_active_launch_plans_paginated(project, domain, limit=100, token=None, sort_by=None)[source]

This returns a page of currently active launch plan meta-information for launch plans in a given project and domain.

Note

This is a paginated API. Use the token field in the request to specify a page offset token. The user of the API is responsible for providing this token.

Note

If entries are added to the database between requests for different pages, it is possible to receive entries on the second page that also appeared on the first.

Parameters
  • project (Text) –

  • domain (Text) –

  • limit (int) – [Optional] The maximum number of entries to return. Must be greater than 0. The maximum page size is determined by the Flyte Admin Service configuration. If limit is greater than the maximum page size, an exception will be raised.

  • token (int) – [Optional] If specified, this specifies where in the rows of results to skip before reading. If you previously retrieved a page response with token=”foo” and you want the next page, specify token=”foo”. Please see the notes for this function about the caveats of the paginated API.

  • sort_by (flytekit.models.admin.common.Sort) – [Optional] If provided, the results will be sorted.

Raises

TODO

Return type

list[flytekit.models.launch_plan.LaunchPlan], str

list_executions_paginated(project, domain, limit=100, token=None, filters=None, sort_by=None)[source]

This returns a page of executions in a given project and domain.

Note

This is a paginated API. Use the token field in the request to specify a page offset token. The user of the API is responsible for providing this token.

Note

If entries are added to the database between requests for different pages, it is possible to receive entries on the second page that also appeared on the first.

Parameters
  • project (Text) – Project in which to list executions.

  • domain (Text) – Project in which to list executions.

  • limit (int) – [Optional] The maximum number of entries to return. Must be greater than 0. The maximum page size is determined by the Flyte Admin Service configuration. If limit is greater than the maximum page size, an exception will be raised.

  • token (Text) – [Optional] If specified, this specifies where in the rows of results to skip before reading. If you previously retrieved a page response with token=”foo” and you want the next page, specify token=”foo”. Please see the notes for this function about the caveats of the paginated API.

  • filters (list[flytekit.models.filters.Filter]) – [Optional] If specified, the filters will be applied to the query. If the filter is not supported, an exception will be raised.

  • sort_by (flytekit.models.admin.common.Sort) – [Optional] If provided, the results will be sorted.

Raises

TODO

Return type

(list[flytekit.models.execution.Execution], Text)

list_launch_plan_ids_paginated(project, domain, limit=100, token=None, sort_by=None)[source]

This returns a page of identifiers for the launch plans for a given project and domain. Filters can also be specified.

Note

This is a paginated API. Use the token field in the request to specify a page offset token. The user of the API is responsible for providing this token.

Note

If entries are added to the database between requests for different pages, it is possible to receive entries on the second page that also appeared on the first.

Param

Text project: The namespace of the project to list.

Param

Text domain: The domain space of the project to list.

Param

int limit: [Optional] The maximum number of entries to return. Must be greater than 0. The maximum page size is determined by the Flyte Admin Service configuration. If limit is greater than the maximum page size, an exception will be raised.

Param

int token: [Optional] If specified, this specifies where in the rows of results to skip before reading. If you previously retrieved a page response with token=”foo” and you want the next page, specify token=”foo”. Please see the notes for this function about the caveats of the paginated API.

Parameters

sort_by (flytekit.models.admin.common.Sort) – [Optional] If provided, the results will be sorted.

Raises

TODO

Return type

list[flytekit.models.common.NamedEntityIdentifier], Text

list_launch_plans_paginated(identifier, limit=100, token=None, filters=None, sort_by=None)[source]

This returns a page of launch plan meta-information for launch plans in a given project and domain. Optionally, specifying a name will limit the results to only workflows with that name in the given project and domain.

Note

This is a paginated API. Use the token field in the request to specify a page offset token. The user of the API is responsible for providing this token.

Note

If entries are added to the database between requests for different pages, it is possible to receive entries on the second page that also appeared on the first.

Parameters
  • identifier (flytekit.models.common.NamedEntityIdentifier) – NamedEntityIdentifier to list.

  • limit (int) – [Optional] The maximum number of entries to return. Must be greater than 0. The maximum page size is determined by the Flyte Admin Service configuration. If limit is greater than the maximum page size, an exception will be raised.

  • token (int) – [Optional] If specified, this specifies where in the rows of results to skip before reading. If you previously retrieved a page response with token=”foo” and you want the next page, specify token=”foo”. Please see the notes for this function about the caveats of the paginated API.

  • filters (list[flytekit.models.filters.Filter]) – [Optional] If specified, the filters will be applied to the query. If the filter is not supported, an exception will be raised.

  • sort_by (flytekit.models.admin.common.Sort) – [Optional] If provided, the results will be sorted.

Raises

TODO

Return type

list[flytekit.models.launch_plan.LaunchPlan], str

list_matchable_attributes(resource_type)[source]

Fetches all custom attributes for a resource type. :param flytekit.models.MatchableResource resource_type: :return:

list_node_executions(workflow_execution_identifier, limit=100, token=None, filters=None, sort_by=None)[source]

TODO: Comment :param flytekit.models.core.identifier.WorkflowExecutionIdentifier workflow_execution_identifier: :param int limit: :param Text token: [Optional] If specified, this specifies where in the rows of results to skip before reading. If you previously retrieved a page response with token=”foo” and you want the next page, specify token=”foo”. :param list[flytekit.models.filters.Filter] filters: :param flytekit.models.admin.common.Sort sort_by: [Optional] If provided, the results will be sorted. :rtype: list[flytekit.models.node_execution.NodeExecution], Text

list_node_executions_for_task_paginated(task_execution_identifier, limit=100, token=None, filters=None, sort_by=None)[source]

This returns nodes spawned by a specific task execution. This is generally from things like dynamic tasks. :param flytekit.models.core.identifier.TaskExecutionIdentifier task_execution_identifier: :param int limit: Number to return per page :param Text token: [Optional] If specified, this specifies where in the rows of results to skip before reading. If you previously retrieved a page response with token=”foo” and you want the next page, specify token=”foo”. :param list[flytekit.models.filters.Filter] filters: :param flytekit.models.admin.common.Sort sort_by: [Optional] If provided, the results will be sorted. :rtype: list[flytekit.models.node_execution.NodeExecution], Text

list_task_executions_paginated(node_execution_identifier, limit=100, token=None, filters=None, sort_by=None)[source]
Parameters

If you previously retrieved a page response with token=”foo” and you want the next page, specify token=”foo”. :param list[flytekit.models.filters.Filter] filters: :param flytekit.models.admin.common.Sort sort_by: [Optional] If provided, the results will be sorted. :rtype: (list[flytekit.models.admin.task_execution.TaskExecution], Text)

list_task_ids_paginated(project, domain, limit=100, token=None, sort_by=None)[source]

This returns a page of identifiers for the tasks for a given project and domain. Filters can also be specified.

Note

This is a paginated API. Use the token field in the request to specify a page offset token. The user of the API is responsible for providing this token.

Note

If entries are added to the database between requests for different pages, it is possible to receive entries on the second page that also appeared on the first.

Parameters
  • project (Text) – The namespace of the project to list.

  • domain (Text) – The domain space of the project to list.

  • limit (int) – [Optional] The maximum number of entries to return. Must be greater than 0. The maximum page size is determined by the Flyte Admin Service configuration. If limit is greater than the maximum page size, an exception will be raised.

  • token (Text) – [Optional] If specified, this specifies where in the rows of results to skip before reading. If you previously retrieved a page response with token=”foo” and you want the next page, specify token=”foo”. Please see the notes for this function about the caveats of the paginated API.

  • sort_by (flytekit.models.admin.common.Sort) – [Optional] If provided, the results will be sorted.

Raises

TODO

Return type

list[flytekit.models.common.NamedEntityIdentifier], Text

list_tasks_paginated(identifier, limit=100, token=None, filters=None, sort_by=None)[source]

This returns a page of task metadata for tasks in a given project and domain. Optionally, specifying a name will limit the results to only tasks with that name in the given project and domain.

Note

This is a paginated API. Use the token field in the request to specify a page offset token. The user of the API is responsible for providing this token.

Note

If entries are added to the database between requests for different pages, it is possible to receive entries on the second page that also appeared on the first.

Parameters
  • identifier (flytekit.models.common.NamedEntityIdentifier) – NamedEntityIdentifier to list.

  • limit (int) – [Optional] The maximum number of entries to return. Must be greater than 0. The maximum page size is determined by the Flyte Admin Service configuration. If limit is greater than the maximum page size, an exception will be raised.

  • token (int) – [Optional] If specified, this specifies where in the rows of results to skip before reading. If you previously retrieved a page response with token=”foo” and you want the next page, specify token=”foo”. Please see the notes for this function about the caveats of the paginated API.

  • filters (list[flytekit.models.filters.Filter]) – [Optional] If specified, the filters will be applied to the query. If the filter is not supported, an exception will be raised.

  • sort_by (flytekit.models.admin.common.Sort) – [Optional] If provided, the results will be sorted.

Raises

TODO

Return type

list[flytekit.models.task.Task], Text

list_workflow_ids_paginated(project, domain, limit=100, token=None, sort_by=None)[source]

This returns a page of identifiers for the workflows for a given project and domain. Filters can also be specified.

Note

This is a paginated API. Use the token field in the request to specify a page offset token. The user of the API is responsible for providing this token.

Note

If entries are added to the database between requests for different pages, it is possible to receive entries on the second page that also appeared on the first.

Param

Text project: The namespace of the project to list.

Param

Text domain: The domain space of the project to list.

Param

int limit: [Optional] The maximum number of entries to return. Must be greater than 0. The maximum page size is determined by the Flyte Admin Service configuration. If limit is greater than the maximum page size, an exception will be raised.

Param

int token: [Optional] If specified, this specifies where in the rows of results to skip before reading. If you previously retrieved a page response with token=”foo” and you want the next page, specify token=”foo”. Please see the notes for this function about the caveats of the paginated API.

Parameters

sort_by (flytekit.models.admin.common.Sort) – [Optional] If provided, the results will be sorted.

Raises

TODO

Return type

list[flytekit.models.common.NamedEntityIdentifier], Text

list_workflows_paginated(identifier, limit=100, token=None, filters=None, sort_by=None)[source]

This returns a page of workflow meta-information for workflows in a given project and domain. Optionally, specifying a name will limit the results to only workflows with that name in the given project and domain.

Note

This is a paginated API. Use the token field in the request to specify a page offset token. The user of the API is responsible for providing this token.

Note

If entries are added to the database between requests for different pages, it is possible to receive entries on the second page that also appeared on the first.

Parameters
  • identifier (flytekit.models.common.NamedEntityIdentifier) – NamedEntityIdentifier to list.

  • limit (int) – [Optional] The maximum number of entries to return. Must be greater than 0. The maximum page size is determined by the Flyte Admin Service configuration. If limit is greater than the maximum page size, an exception will be raised.

  • token (int) – [Optional] If specified, this specifies where in the rows of results to skip before reading. If you previously retrieved a page response with token=”foo” and you want the next page, specify token=”foo”. Please see the notes for this function about the caveats of the paginated API.

  • filters (list[flytekit.models.filters.Filter]) – [Optional] If specified, the filters will be applied to the query. If the filter is not supported, an exception will be raised.

  • sort_by (flytekit.models.admin.common.Sort) – [Optional] If provided, the results will be sorted.

Raises

TODO

Return type

list[flytekit.models.admin.workflow.Workflow], Text

property raw

Gives access to the raw client :rtype: flytekit.clients.raw.RawSynchronousFlyteClient

register_project(project)[source]

Registers a project. :param flytekit.models.project.Project project: :rtype: flyteidl.admin.project_pb2.ProjectRegisterResponse

relaunch_execution(id, name=None)[source]
Parameters
Returns

The unique identifier for the new execution.

Return type

flytekit.models.core.identifier.WorkflowExecutionIdentifier

terminate_execution(id, cause)[source]
Parameters
update_launch_plan(id, state)[source]

Updates a launch plan. Currently, this can only be used to update a given launch plan’s state (ACTIVE v. INACTIVE) for schedules. If a launch plan with a given project, domain, and name is set to ACTIVE, then any other launch plan with the same project, domain, and name that was set to ACTIVE will be switched to INACTIVE in one transaction.

Parameters
update_named_entity(resource_type, id, metadata)[source]

Updates the metadata associated with a named entity. A named entity is designated a resource, e.g. a workflow, task or launch plan specified by {project, domain, name} across all versions of the resource.

Parameters
  • resource_type (int) – Enum value from flytekit.models.identifier.ResourceType

  • id (flytekit.models.admin.named_entity.NamedEntityIdentifier) – identifier for named entity to update

  • metadata (flytekit.models.admin.named_entity.NamedEntityIdentifierMetadata) –

update_project_domain_attributes(project, domain, matching_attributes)[source]

Sets custom attributes for a project and domain combination. :param Text project: :param Text domain: :param flytekit.models.MatchingAttributes matching_attributes: :return:

update_workflow_attributes(project, domain, workflow, matching_attributes)[source]

Sets custom attributes for a project, domain, and workflow combination. :param Text project: :param Text domain: :param Text workflow: :param flytekit.models.MatchingAttributes matching_attributes: :return:

flytekit.clients.helpers module

flytekit.clients.helpers.iterate_node_executions(client, workflow_execution_identifier=None, task_execution_identifier=None, limit=None, filters=None)[source]

This returns a generator for node executions. :param flytekit.clients.friendly.SynchronousFlyteClient client: :param flytekit.common.core.identifier.WorkflowExecutionIdentifier workflow_execution_identifier: :param flytekit.common.core.identifier.TaskExecutionIdentifier task_execution_identifier: :param int limit: The maximum number of elements to retrieve :param list[flytekit.models.filters.Filter] filters: :rtype: Iterator[flytekit.models.node_execution.NodeExecution]

flytekit.clients.helpers.iterate_task_executions(client, node_execution_identifier, limit=None, filters=None)[source]

This returns a generator for task executions, given a node execution identifier :param flytekit.clients.friendly.SynchronousFlyteClient client: :param flytekit.models.core.identifier.NodeExecutionIdentifier node_execution_identifier: :param int limit: The maximum number of elements to retrieve :param list[flytekit.models.filters.Filter] filters: :rtype: Iterator[flytekit.models.admin.task_execution.TaskExecution]

flytekit.clients.raw module

class flytekit.clients.raw.RawSynchronousFlyteClient(url, insecure=False, credentials=None, options=None)[source]

Bases: object

This is a thin synchronous wrapper around the auto-generated GRPC stubs for communicating with the admin service.

This client should be usable regardless of environment in which this is used. In other words, configurations should be explicit as opposed to inferred from the environment or a configuration file.

create_execution(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

create_launch_plan(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

create_task(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

create_workflow(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

force_auth_flow()[source]
get_active_launch_plan(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

get_execution(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

get_execution_data(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

get_launch_plan(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

get_node_execution(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

get_node_execution_data(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

get_project_domain_attributes(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

get_task(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

get_task_execution(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

get_task_execution_data(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

get_workflow(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

get_workflow_attributes(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

list_active_launch_plans_paginated(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

list_executions_paginated(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

list_launch_plan_ids_paginated(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

list_launch_plans_paginated(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

list_matchable_attributes(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

list_node_executions_for_task_paginated(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

list_node_executions_paginated(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

list_projects(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

list_task_executions_paginated(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

list_task_ids_paginated(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

list_tasks_paginated(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

list_workflow_ids_paginated(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

list_workflows_paginated(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

register_project(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

relaunch_execution(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

set_access_token(access_token)[source]
terminate_execution(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

update_launch_plan(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

update_named_entity(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

update_project_domain_attributes(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

update_workflow_attributes(**kwargs)[source]

Wraps rpc errors as Flyte exceptions and handles authentication the client. :param args: :param kwargs: :return:

property url

Module contents