From 014365faaf9add026fd2c369cada98ab486b0ff4 Mon Sep 17 00:00:00 2001
From: Timothe Jost <timothe.jost@wanadoo.fr>
Date: Wed, 27 Mar 2024 21:02:12 +0100
Subject: [PATCH] updated error on broker_conf in dynaconf
---
src/pypelines/__init__.py | 2 +-
src/pypelines/celery_tasks.py | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/pypelines/__init__.py b/src/pypelines/__init__.py
index d8edc25..4f62a7d 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 7d7a917..06a3b3a 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
--
GitLab