Forráskód Böngészése

Allow + in result backend URLs

Ask Solem 11 éve
szülő
commit
3b63d534d3
1 módosított fájl, 4 hozzáadás és 1 törlés
  1. 4 1
      celery/backends/__init__.py

+ 4 - 1
celery/backends/__init__.py

@@ -57,5 +57,8 @@ def get_backend_by_url(backend=None, loader=None):
     url = None
     if backend and '://' in backend:
         url = backend
-        backend, _, _, _, _, _, _ = _parse_url(url)
+        if '+' in url[:url.index('://')]:
+            backend, url = url.split('+', 1)
+        else:
+            backend, _, _, _, _, _, _ = _parse_url(url)
     return get_backend_cls(backend, loader), url