Method _untrack_child_process

celery/concurrency/asynpool.py:515–520

(self, proc, hub)

            self._event_process_exit, hub, proc)

    def _untrack_child_process(self, proc, hub):
        sentinel_poll = getattr(proc, '_sentinel_poll', None)
        if sentinel_poll is not None:
            proc._sentinel_poll = None
            hub.remove(sentinel_poll)
            os.close(sentinel_poll)

    def register_with_event_loop(self, hub):
        """Register the async pool with the current event loop."""