flytekit.models.core.workflow

def Alias(
    var,
    alias,
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def ApproveCondition(
    signal_id: str,
):

def from_flyte_idl(
    pb2_object: flyteidl.core.workflow_pb2.ApproveCondition,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def ArrayNode(
    node: Node,
    parallelism,
    min_successes,
    min_success_ratio,
    execution_mode,
    is_original_sub_node_interface,
    data_mode,
    bound_inputs,
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def BranchNode(
    if_else: flytekit.models.core.workflow.IfElseBlock,
):

def from_flyte_idl(
    pb2_objct,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def GateNode(
    signal: typing.Optional[flytekit.models.core.workflow.SignalCondition],
    sleep: typing.Optional[flytekit.models.core.workflow.SleepCondition],
    approve: typing.Optional[flytekit.models.core.workflow.ApproveCondition],
):

def from_flyte_idl(
    pb2_object: flyteidl.core.workflow_pb2.GateNode,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def IfBlock(
    condition,
    then_node,
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def IfElseBlock(
    case,
    other,
    else_node,
    error,
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def K8sObjectMetadata(
    labels: typing.Dict[str, str],
    annotations: typing.Dict[str, str],
):

def from_flyte_idl(
    pb2_object: flyteidl.core.tasks_pb2.K8sObjectMetadata,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def Node(
    id,
    metadata,
    inputs,
    upstream_node_ids,
    output_aliases,
    task_node,
    workflow_node,
    branch_node,
    gate_node: typing.Optional[flytekit.models.core.workflow.GateNode],
    array_node: typing.Optional[flytekit.models.core.workflow.ArrayNode],
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def NodeMetadata(
    name,
    timeout,
    retries,
    interruptible: typing.Optional[bool],
    cacheable: typing.Optional[bool],
    cache_version: typing.Optional[str],
    cache_serializable: typing.Optional[bool],
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def PodTemplate(
    pod_spec: typing.Optional[ForwardRef('V1PodSpec')],
    primary_container_name: str,
    labels: typing.Optional[typing.Dict[str, str]],
    annotations: typing.Optional[typing.Dict[str, str]],
):

def Resources(
    requests,
    limits,
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def SignalCondition(
    signal_id: str,
    type: flytekit.models.types.LiteralType,
    output_variable_name: str,
):

def from_flyte_idl(
    pb2_object: flyteidl.core.workflow_pb2.SignalCondition,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def SleepCondition(
    duration: datetime.timedelta,
):

def from_flyte_idl(
    pb2_object: flyteidl.core.workflow_pb2.SignalCondition,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def TaskNode(
    reference_id,
    overrides: typing.Optional[flytekit.models.core.workflow.TaskNodeOverrides],
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def TaskNodeOverrides(
    resources: typing.Optional[flytekit.models.task.Resources],
    extended_resources: typing.Optional[flyteidl.core.tasks_pb2.ExtendedResources],
    container_image: typing.Optional[str],
    pod_template: typing.Optional[flytekit.core.pod_template.PodTemplate],
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def WorkflowMetadata(
    on_failure,
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def WorkflowMetadataDefaults(
    interruptible,
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def WorkflowNode(
    launchplan_ref,
    sub_workflow_ref,
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def WorkflowTemplate(
    id,
    metadata,
    metadata_defaults,
    interface,
    nodes,
    outputs,
    failure_node,
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()