Move DataManagement and Preprocessors to Dodal

src/blueapi/config.py

@@ -51,12 +51,6 @@ class StompConfig(BaseModel):
     auth: BasicAuthentication | None = None
 
 
-class DataWritingConfig(BlueapiBaseModel):
-    visit_service_url: str | None = None  # e.g. "http://localhost:8088/api"
-    visit_directory: Path = Path("/tmp/0-0")
-    group_name: str = "example"
-
-
 class WorkerEventConfig(BlueapiBaseModel):
     """
     Config for event broadcasting via the message bus
@@ -78,7 +72,6 @@ class EnvironmentConfig(BlueapiBaseModel):
         Source(kind=SourceKind.PLAN_FUNCTIONS, module="dls_bluesky_core.plans"),
         Source(kind=SourceKind.PLAN_FUNCTIONS, module="dls_bluesky_core.stubs"),
     ]
-    data_writing: DataWritingConfig = Field(default_factory=DataWritingConfig)
     events: WorkerEventConfig = Field(default_factory=WorkerEventConfig)
 
 

src/blueapi/core/context.py

@@ -1,6 +1,5 @@
-import functools
 import logging
-from collections.abc import Callable, Sequence
+from collections.abc import Callable
 from dataclasses import dataclass, field
 from importlib import import_module
 from inspect import Parameter, signature
@@ -29,10 +28,8 @@
     BLUESKY_PROTOCOLS,
     Device,
     HasName,
-    MsgGenerator,
     Plan,
     PlanGenerator,
-    PlanWrapper,
     is_bluesky_compatible_device,
     is_bluesky_plan_generator,
 )
@@ -52,22 +49,13 @@ class BlueskyContext:
     run_engine: RunEngine = field(
         default_factory=lambda: RunEngine(context_managers=[])
     )
-    plan_wrappers: Sequence[PlanWrapper] = field(default_factory=list)
     plans: dict[str, Plan] = field(default_factory=dict)
     devices: dict[str, Device] = field(default_factory=dict)
     plan_functions: dict[str, PlanGenerator] = field(default_factory=dict)
     sim: bool = field(default=False)
 
     _reference_cache: dict[type, type] = field(default_factory=dict)
 
-    def wrap(self, plan: MsgGenerator) -> MsgGenerator:
-        wrapped_plan = functools.reduce(
-            lambda wrapped, next_wrapper: next_wrapper(wrapped),
-            self.plan_wrappers,
-            plan,
-        )
-        yield from wrapped_plan
-
     def find_device(self, addr: str | list[str]) -> Device | None:
         """
         Find a device in this context, allows for recursive search.

src/blueapi/service/handler.py

@@ -4,15 +4,8 @@
 from blueapi.config import ApplicationConfig
 from blueapi.core import BlueskyContext
 from blueapi.core.event import EventStream
-from blueapi.data_management.visit_directory_provider import (
-    LocalVisitServiceClient,
-    VisitDirectoryProvider,
-    VisitServiceClient,
-    VisitServiceClientBase,
-)
 from blueapi.messaging import StompMessagingTemplate
 from blueapi.messaging.base import MessagingTemplate
-from blueapi.preprocessors.attach_metadata import attach_metadata
 from blueapi.service.handler_base import BlueskyHandler
 from blueapi.service.model import DeviceModel, PlanModel, WorkerTask
 from blueapi.worker.event import WorkerState
@@ -150,42 +143,9 @@ def setup_handler(
 ) -> None:
     global HANDLER
 
-    provider = None
-    plan_wrappers = []
-    if config:
-        visit_service_client: VisitServiceClientBase
-        if config.env.data_writing.visit_service_url is not None:
-            visit_service_client = VisitServiceClient(
-                config.env.data_writing.visit_service_url
-            )
-        else:
-            visit_service_client = LocalVisitServiceClient()
-
-        provider = VisitDirectoryProvider(
-            data_group_name=config.env.data_writing.group_name,
-            data_directory=config.env.data_writing.visit_directory,
-            client=visit_service_client,
-        )
-
-        # Make all dodal devices created by the context use provider if they can
-        try:
-            from dodal.parameters.gda_directory_provider import (
-                set_directory_provider_singleton,
-            )
-
-            set_directory_provider_singleton(provider)
-        except ImportError:
-            logging.error(
-                "Unable to set directory provider for ophyd-async devices, "
-                "a newer version of dodal is required"
-            )
-
-        plan_wrappers.append(lambda plan: attach_metadata(plan, provider))
-
     handler = Handler(
         config,
         context=BlueskyContext(
-            plan_wrappers=plan_wrappers,
             sim=False,
         ),
     )