Skip to content

Commit 9c525ca

Browse files
committed
Fix celery manager tests.
1 parent d0c4c3c commit 9c525ca

File tree

1 file changed

+4
-3
lines changed
  • tests/integration/background_callback

1 file changed

+4
-3
lines changed

tests/integration/background_callback/utils.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ def get_background_callback_manager():
3535
Get the long callback mangaer configured by environment variables
3636
"""
3737
if os.environ.get("LONG_CALLBACK_MANAGER", None) == "celery":
38-
from dash.background_callback import CeleryLongCallbackManager
38+
from dash.background_callback import CeleryManager
3939
from celery import Celery
4040
import redis
4141

@@ -44,7 +44,7 @@ def get_background_callback_manager():
4444
broker=os.environ.get("CELERY_BROKER"),
4545
backend=os.environ.get("CELERY_BACKEND"),
4646
)
47-
background_callback_manager = CeleryLongCallbackManager(celery_app)
47+
background_callback_manager = CeleryManager(celery_app)
4848
redis_conn = redis.Redis(host="localhost", port=6379, db=1)
4949
background_callback_manager.test_lock = redis_conn.lock("test-lock")
5050
elif os.environ.get("LONG_CALLBACK_MANAGER", None) == "diskcache":
@@ -112,7 +112,8 @@ def setup_background_callback_app(manager_name, app_name):
112112
break
113113
lines.append(line)
114114
else:
115-
raise RuntimeError("celery failed to start: " + {"\n".join(lines)})
115+
error = "\n".join(lines)
116+
raise RuntimeError(f"celery failed to start: {error}")
116117

117118
try:
118119
yield import_app(f"tests.integration.background_callback.{app_name}")

0 commit comments

Comments
 (0)