flytekit.core.gate

Directory

Classes

Methods

Variables

Methods

approve()

def approve(
    upstream_item: Union[Tuple[Promise], Promise, VoidPromise],
    name: str,
    timeout: datetime.timedelta,
) -> n:

Create a Gate object for binary approval.

Create a Gate object. This object will function like a task. Note that unlike a task, each time this function is called, a new Python object is created. If a workflow calls a subworkflow twice, and the subworkflow has a signal, then two Gate objects are created. This shouldn’t be a problem as long as the objects are identical.

sleep()

def sleep(
    duration: datetime.timedelta,
) -> n:

Create a sleep Gate object.

wait_for_input()

def wait_for_input(
    name: str,
    timeout: datetime.timedelta,
    expected_type: typing.Type,
) -> n:

Create a Gate object that waits for user input of the specified type.

Create a Gate object. This object will function like a task. Note that unlike a task, each time this function is called, a new Python object is created. If a workflow calls a subworkflow twice, and the subworkflow has a signal, then two Gate objects are created. This shouldn’t be a problem as long as the objects are identical.

flytekit.core.gate.Gate

A node type that waits for user input before proceeding with a workflow. A gate is a type of node that behaves like a task, but instead of running code, it either needs to wait for user input to proceed or wait for a timer to complete running.

class Gate(
    name: str,
    input_type: typing.Optional[typing.Type],
    upstream_item: typing.Optional[typing.Any],
    sleep_duration: typing.Optional[datetime.timedelta],
    timeout: typing.Optional[datetime.timedelta],
)

Methods

construct_node_metadata()

def construct_node_metadata()

local_execute()

def local_execute(
    ctx: FlyteContext,
    kwargs,
) -> Union[Tuple[Promise], Promise, VoidPromise]

local_execution_mode()

def local_execution_mode()

Properties