diff --git a/src/pypelines/__init__.py b/src/pypelines/__init__.py index d8edc2583325c5ac4b09fa390ea2828088bbfecf..4f62a7d83fa429f4211b27209bcbd7ce7249273d 100644 --- a/src/pypelines/__init__.py +++ b/src/pypelines/__init__.py @@ -1,4 +1,4 @@ -__version__ = "0.0.33" +__version__ = "0.0.34" from . import loggs from .pipes import * diff --git a/src/pypelines/celery_tasks.py b/src/pypelines/celery_tasks.py index 7d7a9179c5708b2b762612e87ee7a6d58b3ff0a0..06a3b3a69766d30949b3f4bcc3629eca817a893b 100644 --- a/src/pypelines/celery_tasks.py +++ b/src/pypelines/celery_tasks.py @@ -309,7 +309,7 @@ def create_celery_app(conf_path, app_name="pypelines", v_host=None) -> "Celery": address = settings.address backend = settings.connexion.backend conf_data = settings.conf - v_host = settings.virtual_host if v_host is None else v_host + v_host = settings.broker_conf.virtual_host if v_host is None else v_host except (AttributeError, KeyError) as e: logger.warning(f"{failure_message} {e}") return None