flytekit.clients.helpers

Directory

Methods

Method	Description
`iterate_node_executions()`	This returns a generator for node executions.
`iterate_task_executions()`	This returns a generator for task executions, given a node execution identifier.

Methods

iterate_node_executions()

        
    
def iterate_node_executions(
    client,
    workflow_execution_identifier,
    task_execution_identifier,
    limit,
    filters,
    sort_by,
    unique_parent_id,
)

This returns a generator for node executions.

Parameter	Type	Description
`client`
`workflow_execution_identifier`
`task_execution_identifier`
`limit`
`filters`
`sort_by`
`unique_parent_id`

iterate_task_executions()

        
    
def iterate_task_executions(
    client,
    node_execution_identifier,
    limit,
    filters,
    sort_by,
)

This returns a generator for task executions, given a node execution identifier

Parameter	Type	Description
`client`
`node_execution_identifier`
`limit`
`filters`
`sort_by`