diff --git a/geomagio/processing/factory.py b/geomagio/processing/factory.py index d9a065497d9cf6b0a38c391355e11a9d698795d2..6e741d469110eedcf02993273ffb12ca02b01cc6 100644 --- a/geomagio/processing/factory.py +++ b/geomagio/processing/factory.py @@ -5,23 +5,18 @@ from ..edge import EdgeFactory, MiniSeedFactory def get_edge_factory( - data_type="variation", interval="second", **kwargs + data_type="variation", + host=os.getenv("EDGE_HOST", "127.0.0.1"), + interval="second", + **kwargs ) -> TimeseriesFactory: - return EdgeFactory( - host=os.getenv("EDGE_HOST", "127.0.0.1"), - interval=interval, - type=data_type, - **kwargs - ) + return EdgeFactory(host=host, interval=interval, type=data_type, **kwargs) def get_miniseed_factory( - data_type="variation", interval="second", **kwargs + data_type="variation", + host=os.getenv("EDGE_HOST", "127.0.0.1"), + interval="second", + **kwargs ) -> TimeseriesFactory: - return MiniSeedFactory( - convert_channels=("U", "V", "W"), - host=os.getenv("EDGE_HOST", "127.0.0.1"), - interval=interval, - type=data_type, - **kwargs - ) + return MiniSeedFactory(host=host, interval=interval, type=data_type, **kwargs) diff --git a/geomagio/processing/obsrio.py b/geomagio/processing/obsrio.py index bf0acf2b81687c6a3f590e6b4cd8b902f4730aa3..880a77beceff1898ccdef3bb00940af14ef58e32 100644 --- a/geomagio/processing/obsrio.py +++ b/geomagio/processing/obsrio.py @@ -314,7 +314,8 @@ def obsrio_tenhertz( """Filter 10Hz miniseed U,V,W to 1Hz legacy H,E,Z.""" starttime, endtime = get_realtime_interval(realtime_interval) controller = Controller( - inputFactory=input_factory or get_miniseed_factory(), + inputFactory=input_factory + or get_miniseed_factory(convert_channels=("U", "V", "W")), inputInterval="tenhertz", outputFactory=output_factory or get_edge_factory(), outputInterval="second",