WIP: Obsrio/PCDCP Processing Pipeline

Fixes #12 (closed), #10

Depends on !98 (closed)

geomagio/processing/derived.py

@@ -117,6 +117,7 @@ def deltaf(
     ----------
     observatory: observatory to calculate
     data_type: factory data type
+    interval: data interval
     input_factory: where to read, should be configured with data_type and interval
     output_factory: where to write, should be configured with data_type and interval
     deltaf_from: one of {"obs", "mag", "geo"}
@@ -163,7 +164,7 @@ def process_adjusted(
     realtime_interval: int = 600,
     update_limit: int = 10,
 ):
-    """compute 1 second adjusted variation channels"""
+    """compute 1 second/minute adjusted variation channels"""
     rotate(
         observatory=observatory,
         data_type="adjusted",
@@ -198,7 +199,7 @@ def process_variation(
     realtime_interval: int = 600,
     update_limit: int = 10,
 ):
-    """compute 1 second derived variation channels"""
+    """compute 1 second/minute derived variation channels"""
     rotate(
         observatory=observatory,
         data_type="variation",
@@ -245,6 +246,7 @@ def rotate(
     ----------
     observatory: observatory to calculate
     data_type: factory data type
+    interval: data interval
     input_factory: where to read, should be configured with data_type and interval
     output_channels: which channels to write
     output_factory: where to write, should be configured with data_type and interval
@@ -296,6 +298,8 @@ def sqdist_minute(
     """
     if not statefile:
         raise ValueError("Statefile is required.")
+    if realtime_interval < 1800:
+        realtime_interval = 1800
     starttime, endtime = get_realtime_interval(realtime_interval)
     controller = Controller(
         algorithm=SqDistAlgorithm(