step_in_line.stepfunctions.steps.Parallel

class documentation

class Parallel(State): (source)

Constructor: Parallel(state_id, retry, catch, **kwargs)

View In Hierarchy

Parallel State causes parallel execution of "branches".

A Parallel state causes the interpreter to execute each branch as concurrently as possible, and wait until each branch terminates (reaches a terminal state) before processing the next state in the Chain.

Method __init__ state_id (str): State name whose length must be less than or equal to 128 unicode characters. State names must be unique within the scope of the whole state machine. retry (Retry or list(Retry), optional): A retrier or list of retriers that define the state's retry policy...
Method add_branch Add a State or Chain as a branch to the Parallel state.
Method allowed_fields Undocumented
Method to_dict Undocumented
Instance Variable branches Undocumented

Inherited from State:

Method __repr__ Undocumented
Method accept Undocumented
Method add_catch Add a catcher or a list of catchers to the tail end of the list of catchers for the state. See Error handling in Step Functions for more details.
Method add_retry Add a retrier or a list of retriers to the tail end of the list of retriers for the state. See Error handling in Step Functions for more details.
Method next Specify the next state or chain to transition to.
Method output Get the placeholder collection for the State's output.
Method update_parameters Update 'parameters' field in the state, if supported.
Instance Variable catches Undocumented
Instance Variable in_chain Undocumented
Instance Variable next_step Undocumented
Instance Variable output_schema Undocumented
Instance Variable retries Undocumented
Instance Variable state_id Undocumented
Instance Variable state_type Undocumented
Instance Variable step_output Undocumented

Inherited from Block (via State):

Method __getattr__ Undocumented
Method __str__ Undocumented
Method is_field_allowed Undocumented
Method to_json Serialize to a JSON formatted string.
Instance Variable fields Undocumented
Method _replace_placeholders Undocumented
def __init__(self, state_id, retry=None, catch=None, **kwargs): (source)
overrides step_in_line.stepfunctions.steps.State.__init__

Args:
state_id (str): State name whose length must be less than or equal to 128 unicode characters. State names must be unique within the scope of the whole state machine. retry (Retry or list(Retry), optional): A retrier or list of retriers that define the state's retry policy. See Error handling in Step Functions for more details. catch (Catch or list(Catch), optional): A catcher or list of catchers that define a fallback state. See Error handling in Step Functions for more details. comment (str, optional): Human-readable comment or description. (default: None) input_path (str, optional): Path applied to the state’s raw input to select some or all of it; that selection is used by the state. (default: '$') parameters (dict, optional): The value of this field becomes the effective input for the state. result_path (str, optional): Path specifying the raw input’s combination with or replacement by the state’s result. (default: '$') output_path (str, optional): Path applied to the state’s output after the application of 'result_path', producing the effective output which serves as the raw input for the next state. (default: '$')

def add_branch(self, branch): (source)

Add a State or Chain as a branch to the Parallel state.

Args:
branch (State or Chain): State or Chain to attach as a branch to the Parallel state.
def allowed_fields(self): (source)
overrides step_in_line.stepfunctions.steps.State.allowed_fields

Undocumented

def to_dict(self): (source)
overrides step_in_line.stepfunctions.steps.State.to_dict

Undocumented

branches: list = (source)

Undocumented