MCPcopy
hub / github.com/celery/celery / _get_sentinel_instance

Method _get_sentinel_instance

celery/backends/redis.py:677–690  ·  view source on GitHub ↗
(self, **params)

Source from the content-addressed store, hash-verified

675 return connparams
676
677 def _get_sentinel_instance(self, **params):
678 connparams = params.copy()
679
680 hosts = connparams.pop("hosts")
681 min_other_sentinels = self._transport_options.get("min_other_sentinels", 0)
682 sentinel_kwargs = self._transport_options.get("sentinel_kwargs", {})
683
684 sentinel_instance = self.sentinel.Sentinel(
685 [(cp['host'], cp['port']) for cp in hosts],
686 min_other_sentinels=min_other_sentinels,
687 sentinel_kwargs=sentinel_kwargs,
688 **connparams)
689
690 return sentinel_instance
691
692 def _get_pool(self, **params):
693 sentinel_instance = self._get_sentinel_instance(**params)

Callers 2

_get_poolMethod · 0.95

Calls 3

copyMethod · 0.80
popMethod · 0.45
getMethod · 0.45

Tested by 1