update realtime_filter factories

geomagio/processing/obsrio.py

@@ -3,7 +3,6 @@ from typing import Optional
 import typer
 
 from ..algorithm import Algorithm, FilterAlgorithm
-from ..edge import EdgeFactory, MiniSeedFactory
 from ..Controller import (
     Controller,
     get_realtime_interval,
@@ -87,15 +86,15 @@ def filter_realtime(
     """Filter 10Hz miniseed, 1 second, one minute, and temperature data.
     Defaults set for realtime processing; can also be implemented to update legacy data"""
     if input_factory == "miniseed":
-        input_factory = MiniSeedFactory(host=host, port=port)
+        input_factory = get_miniseed_factory(host=host, port=port)
     elif input_factory == "edge":
-        input_factory = EdgeFactory(host=host, port=port)
+        input_factory = get_edge_factory(host=host, port=port)
     if output_factory == "miniseed":
-        output_factory = MiniSeedFactory(
+        output_factory = get_miniseed_factory(
             host=host, port=output_read_port, write_port=output_port
         )
     elif output_factory == "edge":
-        output_factory = EdgeFactory(
+        output_factory = get_edge_factory(
             host=host, port=output_read_port, write_port=output_port
         )