MCPcopy
hub / github.com/celery/celery / connection_for_read

Method connection_for_read

celery/worker/consumer/consumer.py:480–482  ·  view source on GitHub ↗
(self, heartbeat=None)

Source from the content-addressed store, hash-verified

478 return conn
479
480 def connection_for_read(self, heartbeat=None):
481 return self.ensure_connected(
482 self.app.connection_for_read(heartbeat=heartbeat))
483
484 def connection_for_write(self, url=None, heartbeat=None):
485 return self.ensure_connected(

Callers 6

connectMethod · 0.95
loopMethod · 0.45
setup_instanceMethod · 0.45
compatible_transportMethod · 0.45
compatible_transportMethod · 0.45
__init__Method · 0.45

Calls 1

ensure_connectedMethod · 0.95

Tested by

no test coverage detected