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

Method _add_to_pool_map

celery/concurrency/eventlet.py:171–177  ·  view source on GitHub ↗
(self, pid, greenlet)

Source from the content-addressed store, hash-verified

169 return killable_target
170
171 def _add_to_pool_map(self, pid, greenlet):
172 self._pool_map[pid] = greenlet
173 greenlet.link(
174 TaskPool._cleanup_after_job_finish,
175 self._pool_map,
176 pid
177 )
178
179 @staticmethod
180 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