n = 0
            while True:
                if exit_event.is_set():
                    break
                req = CallbackRequest(str(dag_filepath))
                try:
                    logging.debug("Sending CallbackRequests %d", n + 1)
                    pipe.send(req)
                except TypeError:
                    
                    
                    break
                except OSError:
                    break
                n += 1
                logging.debug("   Sent %d CallbackRequests", n)
        thread = threading.Thread(target=keep_pipe_full, args=(parent_pipe, exit_event))
        fake_processors = []
        def fake_processor_(*args, **kwargs):