Method terminate_job

celery/concurrency/eventlet.py:147–151

(self, pid, signal=None)

        self.limit = limit

    def terminate_job(self, pid, signal=None):
        if pid in self._pool_map.keys():
            greenlet = self._pool_map[pid]
            greenlet.kill()
            greenlet.wait()

    def _get_info(self):
        info = super()._get_info()