MCPcopy
hub / github.com/celery/celery / terminate_job

Method terminate_job

celery/concurrency/gevent.py:136–141  ·  view source on GitHub ↗
(self, pid, signal=None)

Source from the content-addressed store, hash-verified

134 self._pool.size -= n
135
136 def terminate_job(self, pid, signal=None):
137 import gevent
138
139 if pid in self._pool_map:
140 greenlet = self._pool_map[pid]
141 gevent.kill(greenlet)
142
143 @property
144 def num_processes(self):

Callers 2

test_terminate_jobMethod · 0.95
test_terminate_jobMethod · 0.95

Calls 1

killMethod · 0.45

Tested by 2

test_terminate_jobMethod · 0.76
test_terminate_jobMethod · 0.76