@@ -79,17 +79,13 @@ def _(celery_app: Celery) -> None: ...
7979@pytest .fixture
8080def app_environment (
8181 monkeypatch : pytest .MonkeyPatch ,
82- redis_service : RedisSettings ,
82+ use_in_memory_redis : RedisSettings ,
8383 env_devel_dict : EnvVarsDict ,
8484) -> EnvVarsDict :
8585 return setenvs_from_dict (
8686 monkeypatch ,
8787 {
8888 ** env_devel_dict ,
89- "REDIS_SECURE" : redis_service .REDIS_SECURE ,
90- "REDIS_HOST" : redis_service .REDIS_HOST ,
91- "REDIS_PORT" : f"{ redis_service .REDIS_PORT } " ,
92- "REDIS_PASSWORD" : redis_service .REDIS_PASSWORD .get_secret_value (),
9389 },
9490 )
9591
@@ -151,16 +147,14 @@ def _on_worker_init_wrapper(sender: WorkController, **_kwargs):
151147async def celery_task_manager (
152148 celery_app : Celery ,
153149 celery_settings : CelerySettings ,
154- mock_redis_socket_timeout : None ,
150+ use_in_memory_redis : RedisSettings ,
155151 with_celery_worker : TestWorkController ,
156152) -> AsyncIterator [CeleryTaskManager ]:
157153 register_celery_types ()
158154
159155 try :
160156 redis_client_sdk = RedisClientSDK (
161- celery_settings .CELERY_REDIS_RESULT_BACKEND .build_redis_dsn (
162- RedisDatabase .CELERY_TASKS
163- ),
157+ use_in_memory_redis .build_redis_dsn (RedisDatabase .CELERY_TASKS ),
164158 client_name = "pytest_celery_tasks" ,
165159 )
166160 await redis_client_sdk .setup ()
0 commit comments