adding stuff

Author: sanderegg

services/web/server/tests/integration/01/notifications/test_rabbitmq_consumers.py

@@ -70,12 +70,20 @@
 from tenacity.wait import wait_fixed
 
 pytest_simcore_core_services_selection = [
+    "catalog",
+    "director-v2",
+    "director",
+    "migration",
     "postgres",
     "rabbit",
     "redis",
+    "storage",
 ]
 
-pytest_simcore_ops_services_selection = ["redis-commander"]
+pytest_simcore_ops_services_selection = [
+    "minio",
+    "redis-commander",
+]
 
 _STABLE_DELAY_S = 2
 
@@ -132,13 +140,15 @@ async def _assert_handler_called_with_json(
 
 @pytest.fixture
 async def client(
+    docker_registry: str,
     mock_redis_socket_timeout: None,
     aiohttp_client: Callable,
     app_config: dict[str, Any],
     rabbit_service: RabbitSettings,
     postgres_db: sa.engine.Engine,
     redis_client: Redis,
     monkeypatch_setenv_from_app_config: Callable,
+    simcore_services_ready: None,
 ) -> TestClient:
     app_config["storage"]["enabled"] = False
 
@@ -370,45 +380,6 @@ async def test_progress_non_computational_workflow(
         await _assert_handler_not_called(mock_progress_handler)
 
 
-@pytest.fixture
-def mock_dynamic_scheduler(mocker: MockerFixture) -> None:
-    mocker.patch(
-        "simcore_service_webserver.dynamic_scheduler.api.stop_dynamic_services_in_project",
-        autospec=True,
-    )
-    mocker.patch(
-        "simcore_service_webserver.dynamic_scheduler.api.update_projects_networks",
-        autospec=True,
-    )
-
-
-@pytest.fixture
-async def mocked_dynamic_services_interface(
-    mocker: MockerFixture,
-) -> dict[str, mock.MagicMock]:
-    mock = {}
-
-    for func_name in (
-        "list_dynamic_services",
-        "get_dynamic_service",
-        "run_dynamic_service",
-        "stop_dynamic_service",
-    ):
-        name = f"dynamic_scheduler.api.{func_name}"
-        mock[name] = mocker.patch(
-            f"simcore_service_webserver.{name}",
-            autospec=True,
-            return_value={},
-        )
-
-    mock["director_v2.api.create_or_update_pipeline"] = mocker.patch(
-        "simcore_service_webserver.director_v2.director_v2_service.create_or_update_pipeline",
-        autospec=True,
-        return_value=None,
-    )
-    return mock
-
-
 @pytest.mark.parametrize("user_role", [UserRole.GUEST], ids=str)
 @pytest.mark.parametrize(
     "sender_same_user_id", [True, False], ids=lambda id_: f"same_sender_id={id_}"
@@ -417,8 +388,6 @@ async def mocked_dynamic_services_interface(
     "subscribe_to_logs", [True, False], ids=lambda id_: f"subscribed={id_}"
 )
 async def test_progress_computational_workflow(
-    mock_dynamic_scheduler: None,
-    mocked_dynamic_services_interface: dict[str, mock.MagicMock],
     client: TestClient,
     rabbitmq_publisher: RabbitMQClient,
     user_project: ProjectDict,