I am running a GStreamer pipeline in a separate Python multiprocessing process. The process captures frames from a camera to a multiprocessing Queue (full_frame_queue). I want to stop the process properly by first stopping the pipeline, and then waiting for the process to join. I am able to set the pipeline to NULL, and the queue is empty, but still the process does not join. Here is how I start the pipeline process: