7.14. Pipeline Stage Payload

Application code looking to make use of Clara’s pipeline orchestration should utilize of Clara Pipeline Driver life-cycle and register an execute callback handler. When the execution event callback handler is called, a reference to the current stage’s payload (clara.Payload) will be passed to application code.

Using the supplied pointer enables application code to iterate through the list of name / path pairs for both inputs and outputs.

see also: Clara Pipeline Driver and Clara Pipeline Driver Callbacks

Gets the collection of clara.PayloadEntry objects defining the payload input for this stage.

The set of input entries returned when calling this function is determined by the pipeline definition. Pipeline definitions declare a set of input values for each operator. Those input values are represented as payload entries.

see also: Payload Entry

Return

Returns a clara.PayloadCollection which is a collection of clara.PayloadEntry objects.

Copy
Copied!
            

@property def input_entries(self):

Gets the collection of clara.PayloadEntry objects defining the payload output for this stage.

The set of output entries returned when calling this function is determined by the pipeline definition. Pipeline definitions declare a set of output values for each operator. Those output values are represented as payload entries.

see also: Payload Entry

Return

Returns a clara.PayloadCollection which is a collection of clara.PayloadEntry objects.

Copy
Copied!
            

@property def output_entries(self):

Gets the clara.FastIOContext provided by the payload for this stage.

see also: Fast I/O Context

Return

Returns a clara.FastIOContext to provide access to Fast I/O pipeline job resources.

Copy
Copied!
            

@property def fastio_context(self):

Gets the collection of clara.FastIOEntry objects defining the FastIO input payload for this stage.

The set of input entries returned when calling this function is determined by the pipeline definition. Pipeline definitions declare a set of typed input values for each operator. Input values with type = {array, string} or any Clara Primitive (uint8, uint16, uint32, uint64, int8, int16, int32, int64, float16, float32, float64) are represented as FastIO payload entries.

see also: FastIO Entry

Return

Returns a clara.FastIOCollection which is a collection of clara.FastIOEntry objects.

Copy
Copied!
            

@property def fastio_input_entries(self):

Gets the collection of clara.FastIOEntry objects defining the FastIO output payload for this stage.

The set of output entries returned when calling this function is determined by the pipeline definition. Pipeline definitions declare a set of typed input values for each operator. Input values with type = {array, string} or any Clara Primitive (uint8, uint16, uint32, uint64, int8, int16, int32, int64, float16, float32, float64) are represented as FastIO payload entries.

see also: FastIO Entry

Return

Returns a clara.FastIOCollection which is a collection of clara.FastIOEntry objects.

Copy
Copied!
            

@property def fastio_output_entries(self):

© Copyright 2018-2021, NVIDIA Corporation. All rights reserved. Last updated on Feb 1, 2023.