diff --git a/tests/async_tests/conftest.py b/tests/async_tests/conftest.py index b701eea91a..1f225d322d 100644 --- a/tests/async_tests/conftest.py +++ b/tests/async_tests/conftest.py @@ -4,7 +4,7 @@ if "REDIS_URL" in os.environ: - managers = ["celery", "diskcache"] + managers = ["celery-redis", "diskcache"] else: print("Skipping celery tests because REDIS_URL is not defined") managers = ["diskcache"] diff --git a/tests/async_tests/utils.py b/tests/async_tests/utils.py index b7074b0735..2b88f8a3ca 100644 --- a/tests/async_tests/utils.py +++ b/tests/async_tests/utils.py @@ -36,7 +36,7 @@ def get_background_callback_manager(): """ Get the long callback mangaer configured by environment variables """ - if os.environ.get("LONG_CALLBACK_MANAGER", None) == "celery": + if os.environ.get("LONG_CALLBACK_MANAGER", None) == "celery-redis": from dash.background_callback import CeleryManager from celery import Celery @@ -77,8 +77,8 @@ def kill(proc_pid): def setup_background_callback_app(manager_name, app_name): from dash.testing.application_runners import import_app - if manager_name == "celery": - os.environ["LONG_CALLBACK_MANAGER"] = "celery" + if manager_name == "celery-redis": + os.environ["LONG_CALLBACK_MANAGER"] = "celery-redis" redis_url = os.environ["REDIS_URL"].rstrip("/") os.environ["CELERY_BROKER"] = f"{redis_url}/0" os.environ["CELERY_BACKEND"] = f"{redis_url}/1" diff --git a/tests/background_callback/conftest.py b/tests/background_callback/conftest.py index b701eea91a..1f225d322d 100644 --- a/tests/background_callback/conftest.py +++ b/tests/background_callback/conftest.py @@ -4,7 +4,7 @@ if "REDIS_URL" in os.environ: - managers = ["celery", "diskcache"] + managers = ["celery-redis", "diskcache"] else: print("Skipping celery tests because REDIS_URL is not defined") managers = ["diskcache"] diff --git a/tests/background_callback/utils.py b/tests/background_callback/utils.py index 1cefd4ecc3..60c35487d2 100644 --- a/tests/background_callback/utils.py +++ b/tests/background_callback/utils.py @@ -35,7 +35,7 @@ def get_background_callback_manager(): """ Get the long callback mangaer configured by environment variables """ - if os.environ.get("LONG_CALLBACK_MANAGER", None) == "celery": + if os.environ.get("LONG_CALLBACK_MANAGER", None) == "celery-redis": from dash.background_callback import CeleryManager from celery import Celery import redis @@ -77,8 +77,8 @@ def kill(proc_pid): def setup_background_callback_app(manager_name, app_name): from dash.testing.application_runners import import_app - if manager_name == "celery": - os.environ["LONG_CALLBACK_MANAGER"] = "celery" + if manager_name == "celery-redis": + os.environ["LONG_CALLBACK_MANAGER"] = "celery-redis" redis_url = os.environ["REDIS_URL"].rstrip("/") os.environ["CELERY_BROKER"] = f"{redis_url}/0" os.environ["CELERY_BACKEND"] = f"{redis_url}/1"