Method _flush_events

celery/worker/consumer/consumer.py:543–545 · view source on GitHub ↗

(self)

Source from the content-addressed store, hash-verified

541	return conn
542
543	def _flush_events(self):
544	if self.event_dispatcher:
545	self.event_dispatcher.flush()
546
547	def on_send_event_buffered(self):
548	if self.hub:

test_flush_eventsMethod · 0.80

flushMethod · 0.45

test_flush_eventsMethod · 0.64