Run the OAK pipeline

run_pipeline.py

def run_pipeline(pipeline):
    with depthai.Device(pipeline) as device:
        q_nn = device.getOutputQueue("nn", maxSize=4, blocking=False)
        while True:
            in_nn = q_nn.tryGet()
            if in_nn is not None:
                # get data
                output = in_nn.getAllLayerNames()[-1]
                data = np.array(in_nn.getLayerFp16(output))

                # format data as image
                data = data.reshape(3, 256, 256).transpose(1, 2, 0).astype(np.uint8)
                data = cv2.resize(data, (1024, 1020))

                # show image
                cv2.imshow("preview", data)

            # quit if user presses q
            if cv2.waitKey(1) == ord('q'):
                break