async def METHOD_NAME(self):
    input_array = np.zeros((100, 100, 3), dtype=np.uint8)
    output_array = [0] * (100 * 100 * 3)
    async for ctx, results in MemoryOrchestrator.run(
        DataFlow.auto(flatten, GetSingle),
        [
            Input(
                value=[flatten.op.outputs["result"].name,],
                definition=GetSingle.op.inputs["spec"],
            ),
            Input(
                value=input_array, definition=flatten.op.inputs["array"],
            ),
        ],
    ):
        self.assertEqual(
            results[flatten.op.outputs["result"].name].tolist(),
            output_array,
        )