feat: add field parameters transfer and associated metrics handling

Author: jirhiker

transfers/metrics.py

@@ -36,6 +36,8 @@
     Asset,
     PermissionHistory,
     ThingGeologicFormationAssociation,
+    Stratigraphy,
+    FieldParameters,
     ChemistrySampleInfo,
     NMAHydraulicsData,
     NMARadionuclides,
@@ -168,6 +170,12 @@ def permissions_metrics(self, *args, **kw) -> None:
     def stratigraphy_metrics(self, *args, **kw) -> None:
         self._handle_metrics(ThingGeologicFormationAssociation, *args, **kw)
 
+    def nma_stratigraphy_metrics(self, *args, **kw) -> None:
+        self._handle_metrics(Stratigraphy, name="NMA_Stratigraphy", *args, **kw)
+
+    def field_parameters_metrics(self, *args, **kw) -> None:
+        self._handle_metrics(FieldParameters, name="FieldParameters", *args, **kw)
+
     def associated_data_metrics(self, *args, **kw) -> None:
         self._handle_metrics(AssociatedData, name="AssociatedData", *args, **kw)
 

transfers/transfer.py

@@ -66,6 +66,7 @@
 
 from transfers.asset_transfer import AssetTransferer
 from transfers.chemistry_sampleinfo import ChemistrySampleInfoTransferer
+from transfers.field_parameters_transfer import FieldParametersTransferer
 from transfers.hydraulicsdata import HydraulicsDataTransferer
 from transfers.radionuclides import RadionuclidesTransferer
 from transfers.major_chemistry import MajorChemistryTransferer
@@ -104,6 +105,7 @@ class TransferOptions:
     transfer_surface_water_data: bool
     transfer_hydraulics_data: bool
     transfer_chemistry_sampleinfo: bool
+    transfer_field_parameters: bool
     transfer_major_chemistry: bool
     transfer_radionuclides: bool
     transfer_ngwmn_views: bool
@@ -137,6 +139,7 @@ def load_transfer_options() -> TransferOptions:
         transfer_chemistry_sampleinfo=get_bool_env(
             "TRANSFER_CHEMISTRY_SAMPLEINFO", True
         ),
+        transfer_field_parameters=get_bool_env("TRANSFER_FIELD_PARAMETERS", True),
         transfer_major_chemistry=get_bool_env("TRANSFER_MAJOR_CHEMISTRY", True),
         transfer_radionuclides=get_bool_env("TRANSFER_RADIONUCLIDES", True),
         transfer_ngwmn_views=get_bool_env("TRANSFER_NGWMN_VIEWS", True),
@@ -420,7 +423,7 @@ def _transfer_parallel(
         if opts.transfer_nma_stratigraphy:
             future = executor.submit(
                 _execute_transfer_with_timing,
-                "Stratigraphy",
+                "StratigraphyLegacy",
                 StratigraphyLegacyTransferer,
                 flags,
             )
@@ -510,6 +513,11 @@ def _transfer_parallel(
         results = _execute_transfer(MinorTraceChemistryTransferer, flags=flags)
         metrics.minor_trace_chemistry_metrics(*results)
 
+    if opts.transfer_field_parameters:
+        message("TRANSFERRING FIELD PARAMETERS")
+        results = _execute_transfer(FieldParametersTransferer, flags=flags)
+        metrics.field_parameters_metrics(*results)
+
     # =========================================================================
     # PHASE 3: Sensors (Sequential - required before continuous water levels)
     # =========================================================================
@@ -662,6 +670,11 @@ def _transfer_sequential(
         results = _execute_transfer(ChemistrySampleInfoTransferer, flags=flags)
         metrics.chemistry_sampleinfo_metrics(*results)
 
+    if opts.transfer_field_parameters:
+        message("TRANSFERRING FIELD PARAMETERS")
+        results = _execute_transfer(FieldParametersTransferer, flags=flags)
+        metrics.field_parameters_metrics(*results)
+
     if opts.transfer_major_chemistry:
         message("TRANSFERRING MAJOR CHEMISTRY")
         results = _execute_transfer(MajorChemistryTransferer, flags=flags)