We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1e02fe7 commit ad4cc8cCopy full SHA for ad4cc8c
packages/celery-library/tests/conftest.py
@@ -5,7 +5,6 @@
5
import logging
6
import threading
7
from collections.abc import AsyncIterator, Callable
8
-from functools import partial
9
from typing import Any
10
11
import pytest
@@ -131,7 +130,7 @@ async def with_celery_worker(
131
130
register_celery_tasks: Callable[[Celery], None],
132
) -> AsyncIterator[TestWorkController]:
133
def _on_worker_init_wrapper(sender: WorkController, **_kwargs):
134
- return partial(on_worker_init, app_server)(sender, **_kwargs)
+ return on_worker_init(app_server, sender, **_kwargs)
135
136
worker_init.connect(_on_worker_init_wrapper)
137
worker_shutdown.connect(on_worker_shutdown)
0 commit comments