MCPcopy
hub / github.com/celery/celery / _params_from_url

Method _params_from_url

celery/backends/redis.py:661–675  ·  view source on GitHub ↗
(self, url, defaults)

Source from the content-addressed store, hash-verified

659 )
660
661 def _params_from_url(self, url, defaults):
662 chunks = url.split(self._SERVER_URI_SEPARATOR)
663 connparams = dict(defaults, hosts=[])
664 for chunk in chunks:
665 data = super()._params_from_url(
666 url=chunk, defaults=defaults)
667 connparams['hosts'].append(data)
668 for param in ("host", "port", "db", "password"):
669 connparams.pop(param)
670
671 # Adding db/password/username in connparams to connect to the correct instance
672 for param in ("db", "password", "username"):
673 if connparams['hosts'] and param in connparams['hosts'][0]:
674 connparams[param] = connparams['hosts'][0].get(param)
675 return connparams
676
677 def _get_sentinel_instance(self, **params):
678 connparams = params.copy()

Callers

nothing calls this directly

Calls 3

_params_from_urlMethod · 0.45
popMethod · 0.45
getMethod · 0.45

Tested by

no test coverage detected