start converting task tests

Author: bisgaard-itis

services/api-server/tests/unit/celery/conftest.py

@@ -103,7 +103,7 @@ def add_worker_tasks() -> bool:
 
 
 @pytest.fixture
-async def with_storage_celery_worker(
+async def with_api_server_celery_worker(
     app_environment: EnvVarsDict,
     celery_app: Celery,
     monkeypatch: pytest.MonkeyPatch,

services/api-server/tests/unit/celery/test_functions.py

@@ -124,7 +124,7 @@ async def test_with_fake_run_function(
     app: FastAPI,
     client: AsyncClient,
     auth: BasicAuth,
-    with_storage_celery_worker: TestWorkController,
+    with_api_server_celery_worker: TestWorkController,
 ):
     app.dependency_overrides[get_function] = (
         lambda: RegisteredProjectFunction.model_validate(

services/api-server/tests/unit/test_tasks.py renamed to services/api-server/tests/unit/celery/test_tasks.py

@@ -4,6 +4,7 @@
 from typing import Any
 
 import pytest
+from celery.contrib.testing.worker import TestWorkController
 from faker import Faker
 from fastapi import status
 from httpx import AsyncClient, BasicAuth
@@ -19,6 +20,9 @@
 from pytest_simcore.helpers.async_jobs_server import AsyncJobSideEffects
 from simcore_service_api_server.models.schemas.base import ApiServerEnvelope
 
+pytest_simcore_core_services_selection = ["postgres", "rabbit"]
+
+
 _faker = Faker()
 
 
@@ -64,26 +68,17 @@ def mocked_async_jobs_rpc_api(
 
 
 @pytest.mark.parametrize(
-    "async_job_error, expected_status_code",
-    [
-        (None, status.HTTP_200_OK),
-        (
-            JobSchedulerError(
-                exc=Exception("A very rare exception raised by the scheduler")
-            ),
-            status.HTTP_500_INTERNAL_SERVER_ERROR,
-        ),
-    ],
+    "expected_status_code",
+    [status.HTTP_200_OK],
 )
-async def test_get_async_jobs(
+async def test_get_celery_tasks(
     client: AsyncClient,
-    mocked_async_jobs_rpc_api: dict[str, MockType],
     auth: BasicAuth,
     expected_status_code: int,
+    with_api_server_celery_worker: TestWorkController,
 ):
 
     response = await client.get("/v0/tasks", auth=auth)
-    assert mocked_async_jobs_rpc_api["list_jobs"].called
     assert response.status_code == expected_status_code
 
     if response.status_code == status.HTTP_200_OK: