MCPcopy
hub / github.com/celery/celery / _clear_dead_receivers

Method _clear_dead_receivers

celery/utils/dispatch/signal.py:292–301  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

290 send_robust = send # Compat with Django interface.
291
292 def _clear_dead_receivers(self):
293 # Warning: caller is assumed to hold self.lock
294 if self._dead_receivers:
295 self._dead_receivers = False
296 new_receivers = []
297 for r in self.receivers:
298 if isinstance(r[1], weakref.ReferenceType) and r[1]() is None:
299 continue
300 new_receivers.append(r)
301 self.receivers = new_receivers
302
303 def _live_receivers(self, sender):
304 """Filter sequence of receivers to get resolved, live receivers.

Callers 3

_connect_signalMethod · 0.95
disconnectMethod · 0.95
_live_receiversMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected