Pipeline not terminated

[MubashirWaheed]

Why is the program not terminated on keyboard interrupt?

def main(
    weight_path: str,
    rtsp_url: str,
    zone_configuration_path: str,
    model_id: str,
    confidence: float,
    iou: float,
    classes: List[int],
) -> None:
    sink = CustomSink(weights_path=weight_path ,zone_configuration_path=zone_configuration_path, classes=classes)

    pipeline = InferencePipeline.init_with_custom_logic(
        video_reference=rtsp_url,
        on_video_frame=sink.infer,
        on_prediction=sink.on_prediction,
    )

    pipeline.start()

    try:
        pipeline.join()
    # except (KeyboardInterrupt, SystemExit):
    except KeyboardInterrupt:
        pipeline.terminate()
        print("Program terminated.")
        pipeline.terminate()
        print("Program terminated.")

I tried ctrl + c and ctrl + x but both doesn't work. what is the issue?

[MubashirWaheed]

I fixed it by moving the pipeline.start() inside the try

    try:
        pipeline.start()
        pipeline.join()
    except (KeyboardInterrupt, SystemExit):
        pipeline.terminate()
        print("Program terminated.")

and added this in the on_prediction function

       def on_prediction()
           // code here
            if cv2.waitKey(1) & 0xFF == ord('q'):
                cv2.destroyAllWindows()
                raise SystemExit("Program terminated by user")

now I can quit it by pressing q key

[PawelPeczek-Roboflow]

👍