Strip out output options

Opentrons · Oct 10, 2024 · 7a4dbd4 · 7a4dbd4
1 parent de0e096
commit 7a4dbd4
Show file tree

Hide file tree

Showing 19 changed files with 217 additions and 620 deletions.
diff --git a/api/src/opentrons/config/defaults_ot3.py b/api/src/opentrons/config/defaults_ot3.py
@@ -15,7 +15,6 @@
     LiquidProbeSettings,
     ZSenseSettings,
     EdgeSenseSettings,
-    OutputOptions,
 )
 
 
@@ -27,13 +26,11 @@
     plunger_speed=15,
     plunger_impulse_time=0.2,
     sensor_threshold_pascals=15,
-    output_option=OutputOptions.sync_buffer_to_csv,
     aspirate_while_sensing=False,
     z_overlap_between_passes_mm=0.1,
     plunger_reset_offset=2.0,
     samples_for_baselining=20,
     sample_time_sec=0.004,
-    data_files={InstrumentProbeType.PRIMARY: "/data/pressure_sensor_data.csv"},
 )
 
 DEFAULT_CALIBRATION_SETTINGS: Final[OT3CalibrationSettings] = OT3CalibrationSettings(
@@ -43,7 +40,6 @@
             max_overrun_distance_mm=5.0,
             speed_mm_per_s=1.0,
             sensor_threshold_pf=3.0,
-            output_option=OutputOptions.sync_only,
         ),
     ),
     edge_sense=EdgeSenseSettings(
@@ -54,7 +50,6 @@
             max_overrun_distance_mm=0.5,
             speed_mm_per_s=1,
             sensor_threshold_pf=3.0,
-            output_option=OutputOptions.sync_only,
         ),
         search_initial_tolerance_mm=12.0,
         search_iteration_limit=8,
@@ -195,23 +190,6 @@
 )
 
 
-def _build_output_option_with_default(
-    from_conf: Any, default: OutputOptions
-) -> OutputOptions:
-    if from_conf is None:
-        return default
-    else:
-        if isinstance(from_conf, OutputOptions):
-            return from_conf
-        else:
-            try:
-                enumval = OutputOptions[from_conf]
-            except KeyError:  # not an enum entry
-                return default
-            else:
-                return enumval
-
-
 def _build_log_files_with_default(
     from_conf: Any,
     default: Optional[Dict[InstrumentProbeType, str]],
@@ -316,24 +294,12 @@ def _build_default_cap_pass(
         sensor_threshold_pf=from_conf.get(
             "sensor_threshold_pf", default.sensor_threshold_pf
         ),
-        output_option=from_conf.get("output_option", default.output_option),
     )
 
 
 def _build_default_liquid_probe(
     from_conf: Any, default: LiquidProbeSettings
 ) -> LiquidProbeSettings:
-    output_option = _build_output_option_with_default(
-        from_conf.get("output_option", None), default.output_option
-    )
-    data_files: Optional[Dict[InstrumentProbeType, str]] = None
-    if (
-        output_option is OutputOptions.sync_buffer_to_csv
-        or output_option is OutputOptions.stream_to_csv
-    ):
-        data_files = _build_log_files_with_default(
-            from_conf.get("data_files", None), default.data_files
-        )
     return LiquidProbeSettings(
         mount_speed=from_conf.get("mount_speed", default.mount_speed),
         plunger_speed=from_conf.get("plunger_speed", default.plunger_speed),
@@ -343,7 +309,6 @@ def _build_default_liquid_probe(
         sensor_threshold_pascals=from_conf.get(
             "sensor_threshold_pascals", default.sensor_threshold_pascals
         ),
-        output_option=from_conf.get("output_option", default.output_option),
         aspirate_while_sensing=from_conf.get(
             "aspirate_while_sensing", default.aspirate_while_sensing
         ),
@@ -357,7 +322,6 @@ def _build_default_liquid_probe(
             "samples_for_baselining", default.samples_for_baselining
         ),
         sample_time_sec=from_conf.get("sample_time_sec", default.sample_time_sec),
-        data_files=data_files,
     )
 
 

diff --git a/api/src/opentrons/config/types.py b/api/src/opentrons/config/types.py
@@ -1,8 +1,8 @@
 from enum import Enum
 from dataclasses import dataclass, asdict, fields
-from typing import Dict, Tuple, TypeVar, Generic, List, cast, Optional
+from typing import Dict, Tuple, TypeVar, Generic, List, cast
 from typing_extensions import TypedDict, Literal
-from opentrons.hardware_control.types import OT3AxisKind, InstrumentProbeType
+from opentrons.hardware_control.types import OT3AxisKind
 
 
 class AxisDict(TypedDict):
@@ -103,25 +103,12 @@ def by_gantry_load(
         )
 
 
-class OutputOptions(int, Enum):
-    """Specifies where we should report sensor data to during a sensor pass."""
-
-    stream_to_csv = 0x1  # compile sensor data stream into a csv file, in addition to can_bus_only behavior
-    sync_buffer_to_csv = 0x2  # collect sensor data on pipette mcu, then stream to robot server and compile into a csv file, in addition to can_bus_only behavior
-    can_bus_only = (
-        0x4  # stream sensor data over CAN bus, in addition to sync_only behavior
-    )
-    sync_only = 0x8  # trigger pipette sync line upon sensor's detection of something
-
-
 @dataclass(frozen=True)
 class CapacitivePassSettings:
     prep_distance_mm: float
     max_overrun_distance_mm: float
     speed_mm_per_s: float
     sensor_threshold_pf: float
-    output_option: OutputOptions
-    data_files: Optional[Dict[InstrumentProbeType, str]] = None
 
 
 @dataclass(frozen=True)
@@ -135,13 +122,11 @@ class LiquidProbeSettings:
     plunger_speed: float
     plunger_impulse_time: float
     sensor_threshold_pascals: float
-    output_option: OutputOptions
     aspirate_while_sensing: bool
     z_overlap_between_passes_mm: float
     plunger_reset_offset: float
     samples_for_baselining: int
     sample_time_sec: float
-    data_files: Optional[Dict[InstrumentProbeType, str]]
 
 
 @dataclass(frozen=True)

diff --git a/api/src/opentrons/hardware_control/backends/flex_protocol.py b/api/src/opentrons/hardware_control/backends/flex_protocol.py
@@ -15,7 +15,7 @@
 from opentrons_shared_data.pipette.types import (
     PipetteName,
 )
-from opentrons.config.types import GantryLoad, OutputOptions
+from opentrons.config.types import GantryLoad
 from opentrons.hardware_control.types import (
     BoardRevision,
     Axis,
@@ -152,8 +152,6 @@ async def liquid_probe(
         threshold_pascals: float,
         plunger_impulse_time: float,
         num_baseline_reads: int,
-        output_format: OutputOptions = OutputOptions.can_bus_only,
-        data_files: Optional[Dict[InstrumentProbeType, str]] = None,
         probe: InstrumentProbeType = InstrumentProbeType.PRIMARY,
         force_both_sensors: bool = False,
     ) -> float:
@@ -371,8 +369,6 @@ async def capacitive_probe(
         speed_mm_per_s: float,
         sensor_threshold_pf: float,
         probe: InstrumentProbeType = InstrumentProbeType.PRIMARY,
-        output_format: OutputOptions = OutputOptions.sync_only,
-        data_files: Optional[Dict[InstrumentProbeType, str]] = None,
     ) -> bool:
         ...
 

diff --git a/api/src/opentrons/hardware_control/backends/ot3controller.py b/api/src/opentrons/hardware_control/backends/ot3controller.py
@@ -25,7 +25,7 @@
     Union,
     Mapping,
 )
-from opentrons.config.types import OT3Config, GantryLoad, OutputOptions
+from opentrons.config.types import OT3Config, GantryLoad
 from opentrons.config import gripper_config
 from .ot3utils import (
     axis_convert,
@@ -1368,28 +1368,11 @@ async def liquid_probe(
         threshold_pascals: float,
         plunger_impulse_time: float,
         num_baseline_reads: int,
-        output_option: OutputOptions = OutputOptions.can_bus_only,
-        data_files: Optional[Dict[InstrumentProbeType, str]] = None,
         probe: InstrumentProbeType = InstrumentProbeType.PRIMARY,
         force_both_sensors: bool = False,
     ) -> float:
         head_node = axis_to_node(Axis.by_mount(mount))
         tool = sensor_node_for_pipette(OT3Mount(mount.value))
-        csv_output = bool(output_option.value & OutputOptions.stream_to_csv.value)
-        sync_buffer_output = bool(
-            output_option.value & OutputOptions.sync_buffer_to_csv.value
-        )
-        can_bus_only_output = bool(
-            output_option.value & OutputOptions.can_bus_only.value
-        )
-        data_files_transposed = (
-            None
-            if data_files is None
-            else {
-                sensor_id_for_instrument(probe): data_files[probe]
-                for probe in data_files.keys()
-            }
-        )
         positions = await liquid_probe(
             messenger=self._messenger,
             tool=tool,
@@ -1400,10 +1383,6 @@ async def liquid_probe(
             threshold_pascals=threshold_pascals,
             plunger_impulse_time=plunger_impulse_time,
             num_baseline_reads=num_baseline_reads,
-            csv_output=csv_output,
-            sync_buffer_output=sync_buffer_output,
-            can_bus_only_output=can_bus_only_output,
-            data_files=data_files_transposed,
             sensor_id=sensor_id_for_instrument(probe),
             force_both_sensors=force_both_sensors,
         )
@@ -1432,41 +1411,13 @@ async def capacitive_probe(
         speed_mm_per_s: float,
         sensor_threshold_pf: float,
         probe: InstrumentProbeType = InstrumentProbeType.PRIMARY,
-        output_option: OutputOptions = OutputOptions.sync_only,
-        data_files: Optional[Dict[InstrumentProbeType, str]] = None,
     ) -> bool:
-        if output_option == OutputOptions.sync_buffer_to_csv:
-            assert (
-                self._subsystem_manager.device_info[
-                    SubSystem.of_mount(mount)
-                ].revision.tertiary
-                == "1"
-            )
-        csv_output = bool(output_option.value & OutputOptions.stream_to_csv.value)
-        sync_buffer_output = bool(
-            output_option.value & OutputOptions.sync_buffer_to_csv.value
-        )
-        can_bus_only_output = bool(
-            output_option.value & OutputOptions.can_bus_only.value
-        )
-        data_files_transposed = (
-            None
-            if data_files is None
-            else {
-                sensor_id_for_instrument(probe): data_files[probe]
-                for probe in data_files.keys()
-            }
-        )
         status = await capacitive_probe(
             messenger=self._messenger,
             tool=sensor_node_for_mount(mount),
             mover=axis_to_node(moving),
             distance=distance_mm,
             mount_speed=speed_mm_per_s,
-            csv_output=csv_output,
-            sync_buffer_output=sync_buffer_output,
-            can_bus_only_output=can_bus_only_output,
-            data_files=data_files_transposed,
             sensor_id=sensor_id_for_instrument(probe),
             relative_threshold_pf=sensor_threshold_pf,
         )

diff --git a/api/src/opentrons/hardware_control/backends/ot3simulator.py b/api/src/opentrons/hardware_control/backends/ot3simulator.py
@@ -17,7 +17,7 @@
     Mapping,
 )
 
-from opentrons.config.types import OT3Config, GantryLoad, OutputOptions
+from opentrons.config.types import OT3Config, GantryLoad
 from opentrons.config import gripper_config
 
 from opentrons.hardware_control.module_control import AttachedModulesControl
@@ -347,8 +347,6 @@ async def liquid_probe(
         threshold_pascals: float,
         plunger_impulse_time: float,
         num_baseline_reads: int,
-        output_format: OutputOptions = OutputOptions.can_bus_only,
-        data_files: Optional[Dict[InstrumentProbeType, str]] = None,
         probe: InstrumentProbeType = InstrumentProbeType.PRIMARY,
         force_both_sensors: bool = False,
     ) -> float:
@@ -750,8 +748,6 @@ async def capacitive_probe(
         speed_mm_per_s: float,
         sensor_threshold_pf: float,
         probe: InstrumentProbeType = InstrumentProbeType.PRIMARY,
-        output_format: OutputOptions = OutputOptions.sync_only,
-        data_files: Optional[Dict[InstrumentProbeType, str]] = None,
     ) -> bool:
         self._position[moving] += distance_mm
         return True

diff --git a/api/src/opentrons/hardware_control/ot3api.py b/api/src/opentrons/hardware_control/ot3api.py
@@ -2644,8 +2644,6 @@ async def _liquid_probe_pass(
             probe_settings.sensor_threshold_pascals,
             probe_settings.plunger_impulse_time,
             probe_settings.samples_for_baselining,
-            probe_settings.output_option,
-            probe_settings.data_files,
             probe=probe,
             force_both_sensors=force_both_sensors,
         )
@@ -2861,8 +2859,6 @@ async def capacitive_probe(
             pass_settings.speed_mm_per_s,
             pass_settings.sensor_threshold_pf,
             probe,
-            pass_settings.output_option,
-            pass_settings.data_files,
         )
         end_pos = await self.gantry_position(mount, refresh=True)
         if retract_after:

diff --git a/api/tests/opentrons/config/ot3_settings.py b/api/tests/opentrons/config/ot3_settings.py
@@ -1,5 +1,3 @@
-from opentrons.config.types import OutputOptions
-
 ot3_dummy_settings = {
     "name": "Marie Curie",
     "model": "OT-3 Standard",
@@ -122,13 +120,11 @@
         "plunger_speed": 10,
         "plunger_impulse_time": 0.2,
         "sensor_threshold_pascals": 17,
-        "output_option": OutputOptions.stream_to_csv,
         "aspirate_while_sensing": False,
         "z_overlap_between_passes_mm": 0.1,
         "plunger_reset_offset": 2.0,
         "samples_for_baselining": 20,
         "sample_time_sec": 0.004,
-        "data_files": {"PRIMARY": "/data/pressure_sensor_data.csv"},
     },
     "calibration": {
         "z_offset": {
@@ -137,8 +133,6 @@
                 "max_overrun_distance_mm": 2,
                 "speed_mm_per_s": 3,
                 "sensor_threshold_pf": 4,
-                "output_option": OutputOptions.sync_only,
-                "data_files": None,
             },
         },
         "edge_sense": {
@@ -149,8 +143,6 @@
                 "max_overrun_distance_mm": 5,
                 "speed_mm_per_s": 6,
                 "sensor_threshold_pf": 7,
-                "output_option": OutputOptions.sync_only,
-                "data_files": None,
             },
             "search_initial_tolerance_mm": 18,
             "search_iteration_limit": 3,