A baseline consumer

baseline.py

for _ in range(n_frames):
    # produce the frame
    np_arr = prepare_random_frame(np_arr_shape) 
    # consume the frame and do some example processing
    _ = np_arr.astype("uint8").copy() * 2