2.0.0b28

flyte.remote

Remote Entities that are accessible from the Union Server once deployed or created.

Class	Description
`Action`	A class representing an action.
`ActionDetails`	A class representing an action.
`ActionInputs`	A class representing the inputs of an action.
`ActionOutputs`	A class representing the outputs of an action.
`Project`	A class representing a project in the Union API.
`Run`	A class representing a run of a task.
`RunDetails`	A class representing a run of a task.
`Secret`
`Task`
`Trigger`
`User`

Method	Description
`create_channel()`	Creates a new gRPC channel with appropriate authentication interceptors.
`upload_dir()`	Uploads a directory to a remote location and returns the remote URI.
`upload_file()`	Uploads a file to a remote location and returns the remote URI.

Methods

create_channel()

        
    
def create_channel(
    endpoint: str | None,
    api_key: str | None,
    insecure: typing.Optional[bool],
    insecure_skip_verify: typing.Optional[bool],
    ca_cert_file_path: typing.Optional[str],
    ssl_credentials: typing.Optional[ssl_channel_credentials],
    grpc_options: typing.Optional[typing.Sequence[typing.Tuple[str, typing.Any]]],
    compression: typing.Optional[grpc.Compression],
    http_session: httpx.AsyncClient | None,
    proxy_command: typing.Optional[typing.List[str]],
    kwargs,
) -> grpc.aio._base_channel.Channel

Creates a new gRPC channel with appropriate authentication interceptors.

This function creates either a secure or insecure gRPC channel based on the provided parameters, and adds authentication interceptors to the channel. If SSL credentials are not provided, they are created based on the insecure_skip_verify and ca_cert_file_path parameters.

The function is async because it may need to read certificate files asynchronously and create authentication interceptors that perform async operations.

Parameter	Type
`endpoint`	`str \| None`
`api_key`	`str \| None`
`insecure`	`typing.Optional[bool]`
`insecure_skip_verify`	`typing.Optional[bool]`
`ca_cert_file_path`	`typing.Optional[str]`
`ssl_credentials`	`typing.Optional[ssl_channel_credentials]`
`grpc_options`	`typing.Optional[typing.Sequence[typing.Tuple[str, typing.Any]]]`
`compression`	`typing.Optional[grpc.Compression]`
`http_session`	`httpx.AsyncClient \| None`
`proxy_command`	`typing.Optional[typing.List[str]]`
`kwargs`	`**kwargs`

upload_dir()

        
    
def upload_dir(
    dir_path: pathlib._local.Path,
    verify: bool,
) -> str

Uploads a directory to a remote location and returns the remote URI.

Parameter	Type
`dir_path`	`pathlib._local.Path`
`verify`	`bool`

upload_file()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await upload_file.aio().

        
    
def upload_file(
    fp: pathlib._local.Path,
    verify: bool,
) -> typing.Tuple[str, str]

Uploads a file to a remote location and returns the remote URI.

Parameter	Type
`fp`	`pathlib._local.Path`
`verify`	`bool`

flyte.remote.Action

A class representing an action. It is used to manage the run of a task and its state on the remote Union API.

        
    
class Action(
    pb2: run_definition_pb2.Action,
    _details: ActionDetails | None,
)

Parameter	Type
`pb2`	`run_definition_pb2.Action`
`_details`	`ActionDetails \| None`

Methods

Method	Description
`details()`	Get the details of the action.
`done()`	Check if the action is done.
`get()`	Get a run by its ID or name.
`listall()`	Get all actions for a given run.
`show_logs()`
`sync()`	Sync the action with the remote server.
`to_dict()`	Convert the object to a JSON-serializable dictionary.
`to_json()`	Convert the object to a JSON string.
`wait()`	Wait for the run to complete, displaying a rich progress panel with status transitions,.
`watch()`	Watch the action for updates.

details()

def details()

Get the details of the action. This is a placeholder for getting the action details.

done()

def done()

Check if the action is done.

get()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Action.get.aio().

        
    
def get(
    cls,
    uri: str | None,
    run_name: str | None,
    name: str | None,
) -> Action

Get a run by its ID or name. If both are provided, the ID will take precedence.

Parameter	Type
`cls`
`uri`	`str \| None`
`run_name`	`str \| None`
`name`	`str \| None`

listall()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Action.listall.aio().

        
    
def listall(
    cls,
    for_run_name: str,
    filters: str | None,
    sort_by: Tuple[str, Literal['asc', 'desc']] | None,
) -> Union[Iterator[Action], AsyncIterator[Action]]

Get all actions for a given run.

Parameter	Type
`cls`
`for_run_name`	`str`
`filters`	`str \| None`
`sort_by`	`Tuple[str, Literal['asc', 'desc']] \| None`

show_logs()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await <Action instance>.show_logs.aio().

        
    
def show_logs(
    attempt: int | None,
    max_lines: int,
    show_ts: bool,
    raw: bool,
    filter_system: bool,
)

Parameter	Type
`attempt`	`int \| None`
`max_lines`	`int`
`show_ts`	`bool`
`raw`	`bool`
`filter_system`	`bool`

sync()

def sync()

Sync the action with the remote server. This is a placeholder for syncing the action.

to_dict()

def to_dict()

Convert the object to a JSON-serializable dictionary.

Returns: dict: A dictionary representation of the object.

to_json()

def to_json()

Convert the object to a JSON string.

Returns: str: A JSON string representation of the object.

wait()

        
    
def wait(
    quiet: bool,
    wait_for: WaitFor,
)

Wait for the run to complete, displaying a rich progress panel with status transitions, time elapsed, and error details in case of failure.

Parameter	Type
`quiet`	`bool`
`wait_for`	`WaitFor`

watch()

        
    
def watch(
    cache_data_on_done: bool,
    wait_for: WaitFor,
) -> AsyncGenerator[ActionDetails, None]

Watch the action for updates. This is a placeholder for watching the action.

Parameter	Type
`cache_data_on_done`	`bool`
`wait_for`	`WaitFor`

Properties

Property	Type	Description
`action_id`	`None`	Get the action ID.
`name`	`None`	Get the name of the action.
`phase`	`None`	Get the phase of the action.
`raw_phase`	`None`	Get the raw phase of the action.
`run_name`	`None`	Get the name of the run.
`task_name`	`None`	Get the name of the task.

flyte.remote.ActionDetails

A class representing an action. It is used to manage the run of a task and its state on the remote Union API.

        
    
class ActionDetails(
    pb2: run_definition_pb2.ActionDetails,
    _inputs: ActionInputs | None,
    _outputs: ActionOutputs | None,
)

Parameter	Type
`pb2`	`run_definition_pb2.ActionDetails`
`_inputs`	`ActionInputs \| None`
`_outputs`	`ActionOutputs \| None`

Methods

Method	Description
`done()`	Check if the action is in a terminal state (completed or failed).
`get()`	Get a run by its ID or name.
`get_details()`	Get the details of the action.
`inputs()`	Placeholder for inputs.
`logs_available()`	Check if logs are available for the action, optionally for a specific attempt.
`outputs()`	Placeholder for outputs.
`to_dict()`	Convert the object to a JSON-serializable dictionary.
`to_json()`	Convert the object to a JSON string.
`watch()`	Watch the action for updates.
`watch_updates()`

done()

def done()

Check if the action is in a terminal state (completed or failed). This is a placeholder for checking the action state.

get()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await ActionDetails.get.aio().

        
    
def get(
    cls,
    uri: str | None,
    run_name: str | None,
    name: str | None,
) -> ActionDetails

Get a run by its ID or name. If both are provided, the ID will take precedence.

Parameter	Type
`cls`
`uri`	`str \| None`
`run_name`	`str \| None`
`name`	`str \| None`

get_details()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await ActionDetails.get_details.aio().

        
    
def get_details(
    cls,
    action_id: identifier_pb2.ActionIdentifier,
) -> ActionDetails

Get the details of the action. This is a placeholder for getting the action details.

Parameter	Type
`cls`
`action_id`	`identifier_pb2.ActionIdentifier`

inputs()

def inputs()

Placeholder for inputs. This can be extended to handle inputs from the run context.

logs_available()

        
    
def logs_available(
    attempt: int | None,
) -> bool

Check if logs are available for the action, optionally for a specific attempt. If attempt is None, it checks for the latest attempt.

Parameter	Type
`attempt`	`int \| None`

outputs()

def outputs()

Placeholder for outputs. This can be extended to handle outputs from the run context.

to_dict()

def to_dict()

Convert the object to a JSON-serializable dictionary.

Returns: dict: A dictionary representation of the object.

to_json()

def to_json()

Convert the object to a JSON string.

Returns: str: A JSON string representation of the object.

watch()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await ActionDetails.watch.aio().

        
    
def watch(
    cls,
    action_id: identifier_pb2.ActionIdentifier,
) -> AsyncIterator[ActionDetails]

Watch the action for updates. This is a placeholder for watching the action.

Parameter	Type
`cls`
`action_id`	`identifier_pb2.ActionIdentifier`

watch_updates()

        
    
def watch_updates(
    cache_data_on_done: bool,
) -> AsyncGenerator[ActionDetails, None]

Parameter	Type
`cache_data_on_done`	`bool`

Properties

Property	Type	Description
`abort_info`	`None`
`action_id`	`None`	Get the action ID.
`attempts`	`None`	Get the number of attempts of the action.
`error_info`	`None`
`is_running`	`None`	Check if the action is currently running.
`metadata`	`None`
`name`	`None`	Get the name of the action.
`phase`	`None`	Get the phase of the action.
`raw_phase`	`None`	Get the raw phase of the action.
`run_name`	`None`	Get the name of the run.
`runtime`	`None`	Get the runtime of the action.
`status`	`None`
`task_name`	`None`	Get the name of the task.

flyte.remote.ActionInputs

A class representing the inputs of an action. It is used to manage the inputs of a task and its state on the remote Union API.

        
    
class ActionInputs(
    pb2: common_pb2.Inputs,
    data: Dict[str, Any],
)

Parameter	Type
`pb2`	`common_pb2.Inputs`
`data`	`Dict[str, Any]`

Methods

Method	Description
`clear()`	D.
`copy()`
`fromkeys()`
`get()`	D.
`items()`	D.
`keys()`	D.
`pop()`	D.
`popitem()`	D.
`setdefault()`	D.
`to_dict()`	Convert the object to a JSON-serializable dictionary.
`to_json()`	Convert the object to a JSON string.
`update()`	D.
`values()`	D.

clear()

def clear()

D.clear() -> None. Remove all items from D.

copy()

def copy()

fromkeys()

        
    
def fromkeys(
    iterable,
    value,
)

Parameter	Type
`iterable`
`value`

get()

        
    
def get(
    key,
    default,
)

D.get(k[,d]) -> D[k] if k in D, else d. d defaults to None.

Parameter	Type
`key`
`default`

items()

def items()

D.items() -> a set-like object providing a view on D’s items

keys()

def keys()

D.keys() -> a set-like object providing a view on D’s keys

pop()

        
    
def pop(
    key,
    default,
)

D.pop(k[,d]) -> v, remove specified key and return the corresponding value. If key is not found, d is returned if given, otherwise KeyError is raised.

Parameter	Type
`key`
`default`

popitem()

def popitem()

D.popitem() -> (k, v), remove and return some (key, value) pair as a 2-tuple; but raise KeyError if D is empty.

setdefault()

        
    
def setdefault(
    key,
    default,
)

D.setdefault(k[,d]) -> D.get(k,d), also set D[k]=d if k not in D

Parameter	Type
`key`
`default`

to_dict()

def to_dict()

Convert the object to a JSON-serializable dictionary.

Returns: dict: A dictionary representation of the object.

to_json()

def to_json()

Convert the object to a JSON string.

Returns: str: A JSON string representation of the object.

update()

        
    
def update(
    other,
    kwds,
)

D.update([E, ]**F) -> None. Update D from mapping/iterable E and F. If E present and has a .keys() method, does: for k in E.keys(): D[k] = E[k] If E present and lacks .keys() method, does: for (k, v) in E: D[k] = v In either case, this is followed by: for k, v in F.items(): D[k] = v

Parameter	Type
`other`
`kwds`

values()

def values()

D.values() -> an object providing a view on D’s values

flyte.remote.ActionOutputs

A class representing the outputs of an action. It is used to manage the outputs of a task and its state on the remote Union API.

        
    
class ActionOutputs(
    pb2: common_pb2.Outputs,
    data: Tuple[Any, ...],
)

Parameter	Type
`pb2`	`common_pb2.Outputs`
`data`	`Tuple[Any, ...]`

Methods

Method	Description
`to_dict()`	Convert the object to a JSON-serializable dictionary.
`to_json()`	Convert the object to a JSON string.

to_dict()

def to_dict()

Convert the object to a JSON-serializable dictionary.

Returns: dict: A dictionary representation of the object.

to_json()

def to_json()

Convert the object to a JSON string.

Returns: str: A JSON string representation of the object.

flyte.remote.Project

A class representing a project in the Union API.

        
    
class Project(
    pb2: project_pb2.Project,
)

Parameter	Type
`pb2`	`project_pb2.Project`

Methods

Method	Description
`get()`	Get a run by its ID or name.
`listall()`	Get a run by its ID or name.
`to_dict()`	Convert the object to a JSON-serializable dictionary.
`to_json()`	Convert the object to a JSON string.

get()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Project.get.aio().

        
    
def get(
    cls,
    name: str,
    org: str | None,
) -> Project

Get a run by its ID or name. If both are provided, the ID will take precedence.

Parameter	Type
`cls`
`name`	`str`
`org`	`str \| None`

listall()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Project.listall.aio().

        
    
def listall(
    cls,
    filters: str | None,
    sort_by: Tuple[str, Literal['asc', 'desc']] | None,
) -> Union[AsyncIterator[Project], Iterator[Project]]

Get a run by its ID or name. If both are provided, the ID will take precedence.

Parameter	Type
`cls`
`filters`	`str \| None`
`sort_by`	`Tuple[str, Literal['asc', 'desc']] \| None`

to_dict()

def to_dict()

Convert the object to a JSON-serializable dictionary.

Returns: dict: A dictionary representation of the object.

to_json()

def to_json()

Convert the object to a JSON string.

Returns: str: A JSON string representation of the object.

flyte.remote.Run

A class representing a run of a task. It is used to manage the run of a task and its state on the remote Union API.

        
    
class Run(
    pb2: run_definition_pb2.Run,
    _details: RunDetails | None,
)

Parameter	Type
`pb2`	`run_definition_pb2.Run`
`_details`	`RunDetails \| None`

Methods

Method	Description
`abort()`	Aborts / Terminates the run.
`details()`	Get the details of the run.
`done()`	Check if the run is done.
`get()`	Get the current run.
`inputs()`	Get the inputs of the run.
`listall()`	Get all runs for the current project and domain.
`outputs()`	Get the outputs of the run.
`show_logs()`
`sync()`	Sync the run with the remote server.
`to_dict()`	Convert the object to a JSON-serializable dictionary.
`to_json()`	Convert the object to a JSON string.
`wait()`	Wait for the run to complete, displaying a rich progress panel with status transitions,.
`watch()`	Get the details of the run.

abort()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await <Run instance>.abort.aio().

def abort()

Aborts / Terminates the run.

details()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await <Run instance>.details.aio().

def details()

Get the details of the run. This is a placeholder for getting the run details.

done()

def done()

Check if the run is done.

get()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Run.get.aio().

        
    
def get(
    cls,
    name: str,
) -> Run

Get the current run.

:return: The current run.

Parameter	Type
`cls`
`name`	`str`

inputs()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await <Run instance>.inputs.aio().

def inputs()

Get the inputs of the run. This is a placeholder for getting the run inputs.

listall()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Run.listall.aio().

        
    
def listall(
    cls,
    in_phase: Tuple[Phase] | None,
    created_by_subject: str | None,
    sort_by: Tuple[str, Literal['asc', 'desc']] | None,
    limit: int,
) -> AsyncIterator[Run]

Get all runs for the current project and domain.

Parameter	Type
`cls`
`in_phase`	`Tuple[Phase] \| None`
`created_by_subject`	`str \| None`
`sort_by`	`Tuple[str, Literal['asc', 'desc']] \| None`
`limit`	`int`

outputs()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await <Run instance>.outputs.aio().

def outputs()

Get the outputs of the run. This is a placeholder for getting the run outputs.

show_logs()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await <Run instance>.show_logs.aio().

        
    
def show_logs(
    attempt: int | None,
    max_lines: int,
    show_ts: bool,
    raw: bool,
    filter_system: bool,
)

Parameter	Type
`attempt`	`int \| None`
`max_lines`	`int`
`show_ts`	`bool`
`raw`	`bool`
`filter_system`	`bool`

sync()

def sync()

Sync the run with the remote server. This is a placeholder for syncing the run.

to_dict()

def to_dict()

Convert the object to a JSON-serializable dictionary.

Returns: dict: A dictionary representation of the object.

to_json()

def to_json()

Convert the object to a JSON string.

Returns: str: A JSON string representation of the object.

wait()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await <Run instance>.wait.aio().

        
    
def wait(
    quiet: bool,
    wait_for: Literal['terminal', 'running'],
)

Wait for the run to complete, displaying a rich progress panel with status transitions, time elapsed, and error details in case of failure.

Parameter	Type
`quiet`	`bool`
`wait_for`	`Literal['terminal', 'running']`

watch()

        
    
def watch(
    cache_data_on_done: bool,
) -> AsyncGenerator[ActionDetails, None]

Get the details of the run. This is a placeholder for getting the run details.

Parameter	Type
`cache_data_on_done`	`bool`

Properties

Property	Type	Description
`name`	`None`	Get the name of the run.
`phase`	`None`	Get the phase of the run.
`raw_phase`	`None`	Get the raw phase of the run.
`url`	`None`	Get the URL of the run.

flyte.remote.RunDetails

A class representing a run of a task. It is used to manage the run of a task and its state on the remote Union API.

        
    
class RunDetails(
    pb2: run_definition_pb2.RunDetails,
)

Parameter	Type
`pb2`	`run_definition_pb2.RunDetails`

Methods

Method	Description
`done()`	Check if the run is in a terminal state (completed or failed).
`get()`	Get a run by its ID or name.
`get_details()`	Get the details of the run.
`inputs()`	Placeholder for inputs.
`outputs()`	Placeholder for outputs.
`to_dict()`	Convert the object to a JSON-serializable dictionary.
`to_json()`	Convert the object to a JSON string.

done()

def done()

Check if the run is in a terminal state (completed or failed). This is a placeholder for checking the run state.

get()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await RunDetails.get.aio().

        
    
def get(
    cls,
    name: str | None,
) -> RunDetails

Get a run by its ID or name. If both are provided, the ID will take precedence.

Parameter	Type
`cls`
`name`	`str \| None`

get_details()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await RunDetails.get_details.aio().

        
    
def get_details(
    cls,
    run_id: identifier_pb2.RunIdentifier,
) -> RunDetails

Get the details of the run. This is a placeholder for getting the run details.

Parameter	Type
`cls`
`run_id`	`identifier_pb2.RunIdentifier`

inputs()

def inputs()

Placeholder for inputs. This can be extended to handle inputs from the run context.

outputs()

def outputs()

Placeholder for outputs. This can be extended to handle outputs from the run context.

to_dict()

def to_dict()

Convert the object to a JSON-serializable dictionary.

Returns: dict: A dictionary representation of the object.

to_json()

def to_json()

Convert the object to a JSON string.

Returns: str: A JSON string representation of the object.

Properties

Property	Type	Description
`action_id`	`None`	Get the action ID.
`name`	`None`	Get the name of the action.
`task_name`	`None`	Get the name of the task.

flyte.remote.Secret

        
    
class Secret(
    pb2: definition_pb2.Secret,
)

Parameter	Type
`pb2`	`definition_pb2.Secret`

Methods

Method	Description
`create()`
`delete()`
`get()`
`listall()`
`to_dict()`	Convert the object to a JSON-serializable dictionary.
`to_json()`	Convert the object to a JSON string.

create()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Secret.create.aio().

        
    
def create(
    cls,
    name: str,
    value: Union[str, bytes],
    type: SecretTypes,
)

Parameter	Type
`cls`
`name`	`str`
`value`	`Union[str, bytes]`
`type`	`SecretTypes`

delete()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Secret.delete.aio().

        
    
def delete(
    cls,
    name,
)

Parameter	Type
`cls`
`name`

get()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Secret.get.aio().

        
    
def get(
    cls,
    name: str,
) -> Secret

Parameter	Type
`cls`
`name`	`str`

listall()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Secret.listall.aio().

        
    
def listall(
    cls,
    limit: int,
) -> AsyncIterator[Secret]

Parameter	Type
`cls`
`limit`	`int`

to_dict()

def to_dict()

Convert the object to a JSON-serializable dictionary.

Returns: dict: A dictionary representation of the object.

to_json()

def to_json()

Convert the object to a JSON string.

Returns: str: A JSON string representation of the object.

Properties

Property	Type	Description
`name`	`None`
`type`	`None`

flyte.remote.Task

        
    
class Task(
    pb2: task_definition_pb2.Task,
)

Parameter	Type
`pb2`	`task_definition_pb2.Task`

Methods

Method	Description
`get()`	Get a task by its ID or name.
`listall()`	Get all runs for the current project and domain.
`to_dict()`	Convert the object to a JSON-serializable dictionary.
`to_json()`	Convert the object to a JSON string.

get()

        
    
def get(
    name: str,
    project: str | None,
    domain: str | None,
    version: str | None,
    auto_version: AutoVersioning | None,
) -> LazyEntity

Get a task by its ID or name. If both are provided, the ID will take precedence.

Either version or auto_version are required parameters.

Parameter	Type
`name`	`str`
`project`	`str \| None`
`domain`	`str \| None`
`version`	`str \| None`
`auto_version`	`AutoVersioning \| None`

listall()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Task.listall.aio().

        
    
def listall(
    cls,
    by_task_name: str | None,
    by_task_env: str | None,
    project: str | None,
    domain: str | None,
    sort_by: Tuple[str, Literal['asc', 'desc']] | None,
    limit: int,
) -> Union[AsyncIterator[Task], Iterator[Task]]

Get all runs for the current project and domain.

Parameter	Type
`cls`
`by_task_name`	`str \| None`
`by_task_env`	`str \| None`
`project`	`str \| None`
`domain`	`str \| None`
`sort_by`	`Tuple[str, Literal['asc', 'desc']] \| None`
`limit`	`int`

to_dict()

def to_dict()

Convert the object to a JSON-serializable dictionary.

Returns: dict: A dictionary representation of the object.

to_json()

def to_json()

Convert the object to a JSON string.

Returns: str: A JSON string representation of the object.

Properties

Property	Type	Description
`name`	`None`	The name of the task.
`version`	`None`	The version of the task.

flyte.remote.Trigger

        
    
class Trigger(
    pb2: trigger_definition_pb2.Trigger,
    details: TriggerDetails | None,
)

Parameter	Type
`pb2`	`trigger_definition_pb2.Trigger`
`details`	`TriggerDetails \| None`

Methods

Method	Description
`create()`	Create a new trigger in the Flyte platform.
`delete()`	Delete a trigger by its name.
`get()`	Retrieve a trigger by its name and associated task name.
`get_details()`	Get detailed information about this trigger.
`listall()`	List all triggers associated with a specific task or all tasks if no task name is provided.
`to_dict()`	Convert the object to a JSON-serializable dictionary.
`to_json()`	Convert the object to a JSON string.
`update()`	Pause a trigger by its name and associated task name.

create()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Trigger.create.aio().

        
    
def create(
    cls,
    trigger: flyte.Trigger,
    task_name: str,
    task_version: str | None,
) -> Trigger

Create a new trigger in the Flyte platform.

Parameter	Type
`cls`
`trigger`	`flyte.Trigger`
`task_name`	`str`
`task_version`	`str \| None`

delete()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Trigger.delete.aio().

        
    
def delete(
    cls,
    name: str,
    task_name: str,
)

Delete a trigger by its name.

Parameter	Type
`cls`
`name`	`str`
`task_name`	`str`

get()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Trigger.get.aio().

        
    
def get(
    cls,
    name: str,
    task_name: str,
) -> TriggerDetails

Retrieve a trigger by its name and associated task name.

Parameter	Type
`cls`
`name`	`str`
`task_name`	`str`

get_details()

def get_details()

Get detailed information about this trigger.

listall()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Trigger.listall.aio().

        
    
def listall(
    cls,
    task_name: str | None,
    task_version: str | None,
    limit: int,
) -> AsyncIterator[Trigger]

List all triggers associated with a specific task or all tasks if no task name is provided.

Parameter	Type
`cls`
`task_name`	`str \| None`
`task_version`	`str \| None`
`limit`	`int`

to_dict()

def to_dict()

Convert the object to a JSON-serializable dictionary.

Returns: dict: A dictionary representation of the object.

to_json()

def to_json()

Convert the object to a JSON string.

Returns: str: A JSON string representation of the object.

update()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await Trigger.update.aio().

        
    
def update(
    cls,
    name: str,
    task_name: str,
    active: bool,
)

Pause a trigger by its name and associated task name.

Parameter	Type
`cls`
`name`	`str`
`task_name`	`str`
`active`	`bool`

Properties

Property	Type	Description
`automation_spec`	`None`
`id`	`None`
`is_active`	`None`
`name`	`None`
`task_name`	`None`

flyte.remote.User

        
    
class User(
    pb2: UserInfoResponse,
)

Parameter	Type
`pb2`	`UserInfoResponse`

Methods

Method	Description
`get()`	Fetches information about the currently logged in user.
`name()`
`subject()`
`to_dict()`	Convert the object to a JSON-serializable dictionary.
`to_json()`	Convert the object to a JSON string.

get()

This method can be called both synchronously or asynchronously.

Default invocation is sync and will block. To call it asynchronously, use the function .aio() on the method name itself, e.g.,: result = await User.get.aio().

        
    
def get(
    cls,
) -> User

Fetches information about the currently logged in user. Returns: A User object containing details about the user.

Parameter	Type
`cls`

name()

def name()

subject()

def subject()

to_dict()

def to_dict()

Convert the object to a JSON-serializable dictionary.

Returns: dict: A dictionary representation of the object.

to_json()

def to_json()

Convert the object to a JSON string.

Returns: str: A JSON string representation of the object.