Merge pull request #138 from scipp/fix-live-workflow

Fix live data reduction.

src/ess/loki/workflow.py

@@ -15,7 +15,6 @@
 from ess.sans.conversions import monitor_to_wavelength, sans_monitor
 from ess.sans.types import (
     Filename,
-    FilePath,
     Incident,
     MonitorType,
     NeXusMonitorName,
@@ -116,7 +115,7 @@ def __call__(self, group: JSONGroup) -> dict[str, sc.DataArray]:
         """
         # ``JsonGroup`` is turned into the ``NexusGroup`` here, not in the ``beamlime``
         # so that the workflow can control the definition of the group.
-        self.pipeline[FilePath[Filename[SampleRun]]] = snx.Group(
+        self.pipeline[Filename[SampleRun]] = snx.Group(
             group, definitions=snx.base_definitions()
         )
         results = self.pipeline.compute(

tests/loki/live_reduction_test.py

@@ -0,0 +1,11 @@
+# SPDX-License-Identifier: BSD-3-Clause
+# Copyright (c) 2024 Scipp contributors (https://github.com/scipp)
+import sciline as sl
+
+from ess.loki.workflow import LoKiMonitorWorkflow
+
+
+def loki_monitor_workflow_test() -> None:
+    # Test building the sciline pipeline.
+    workflow = LoKiMonitorWorkflow()
+    assert isinstance(workflow.pipeline, sl.pipeline)