Skip to content

Commit 41446dc

Browse files
fix: explicity stop worker
1 parent 246d695 commit 41446dc

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

packages/celery-library/tests/conftest.py

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -104,10 +104,8 @@ def celery_settings(
104104

105105

106106
@pytest.fixture
107-
def app_server(
108-
celery_session_app: Celery, celery_settings: CelerySettings
109-
) -> BaseAppServer:
110-
return FakeAppServer(app=celery_session_app, settings=celery_settings)
107+
def app_server(celery_app: Celery, celery_settings: CelerySettings) -> BaseAppServer:
108+
return FakeAppServer(app=celery_app, settings=celery_settings)
111109

112110

113111
@pytest.fixture(scope="session")
@@ -150,8 +148,8 @@ def _on_worker_init_wrapper(sender: WorkController, **_kwargs):
150148
try:
151149
yield worker
152150
finally:
151+
worker.stop() # explicitly stop the worker
153152
on_worker_shutdown(worker)
154-
worker_init.disconnect(_on_worker_init_wrapper)
155153

156154

157155
@pytest.fixture

0 commit comments

Comments
 (0)