MCPcopy
hub / github.com/celery/celery / _add_to_pool_map

Method _add_to_pool_map

celery/concurrency/gevent.py:158–162  ·  view source on GitHub ↗
(self, pid, greenlet)

Source from the content-addressed store, hash-verified

156 return killable_target
157
158 def _add_to_pool_map(self, pid, greenlet):
159 self._pool_map[pid] = greenlet
160 greenlet.link(
161 functools.partial(self._cleanup_after_job_finish, pid=pid, pool_map=self._pool_map),
162 )
163
164 @staticmethod
165 def _cleanup_after_job_finish(greenlet, pool_map, pid):

Callers 1

on_applyMethod · 0.95

Calls 1

linkMethod · 0.45

Tested by

no test coverage detected