FlowMsgQueue Constructor

Applicability

Product	Supported
Atlas A3 training product/Atlas A3 inference product	√
Atlas A2 training product/Atlas A2 inference product	√
Atlas 200I/500 A2 inference product	x
Atlas inference product	x
Atlas training product	x

Function Description

Constructs and destructs an object of class FlowMsgQueue.

Prototype

__init__(self, flow_msg_queue: flowfunc_wrapper.FlowMsgQueue) -> None

Parameters

Parameter	Input/Output	Description
flowfunc_wrapper.FlowMsgQueue	Input	FlowMsgQueue defined in the flowfunc_wrapper module. During actual execution, the parameter is passed by the C++ code and mapped to the FlowMsgQueue object of flowfunc_wrapper through the binding relationship of pybind11.

Returns

The object of class FlowMsgQueue is returned.

Exception Handling

None

Constraints

The queue.Queue type of Python is inherited, but only the get, get_nowait, full, empty, and qsize APIs are supported.

In streaming input scenarios (where the input parameter of FlowFunc is a queue), DataFlow does not support data alignment or proactive exception reporting by UDFs.

Parent topic: Class FlowMsgQueue