FlowMsgQueue Constructor

Applicable Products

Product	Supported
Atlas A3 training products/Atlas A3 inference products	√
Atlas A2 training products/Atlas A2 inference products	√
Atlas 200I/500 A2 inference products	x
Atlas inference products	x
Atlas training products	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