From f8cda2b6b1f0d75282ceb19186347957b6f684a9 Mon Sep 17 00:00:00 2001
From: pcain <pcain@usgs.gov>
Date: Thu, 2 Sep 2021 11:17:13 -0600
Subject: [PATCH] update realtime_filter factories
---
geomagio/processing/obsrio.py | 9 ++++-----
1 file changed, 4 insertions(+), 5 deletions(-)
diff --git a/geomagio/processing/obsrio.py b/geomagio/processing/obsrio.py
index bba6234f6..3a6182037 100644
--- a/geomagio/processing/obsrio.py
+++ b/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
)
--
GitLab