Skip to content
Snippets Groups Projects
Commit bd757c5b authored by Erin (Josh) Rigler's avatar Erin (Josh) Rigler
Browse files

Merge branch 'factory-host-config' into 'master'

configure host in factory module

See merge request !124
parents 62101770 52a46586
No related branches found
No related tags found
2 merge requests!146Release CMO metadata to production,!124configure host in factory module
Pipeline #67834 passed
...@@ -5,23 +5,18 @@ from ..edge import EdgeFactory, MiniSeedFactory ...@@ -5,23 +5,18 @@ from ..edge import EdgeFactory, MiniSeedFactory
def get_edge_factory( 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: ) -> TimeseriesFactory:
return EdgeFactory( return EdgeFactory(host=host, interval=interval, type=data_type, **kwargs)
host=os.getenv("EDGE_HOST", "127.0.0.1"),
interval=interval,
type=data_type,
**kwargs
)
def get_miniseed_factory( 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: ) -> TimeseriesFactory:
return MiniSeedFactory( return MiniSeedFactory(host=host, interval=interval, type=data_type, **kwargs)
convert_channels=("U", "V", "W"),
host=os.getenv("EDGE_HOST", "127.0.0.1"),
interval=interval,
type=data_type,
**kwargs
)
...@@ -314,7 +314,8 @@ def obsrio_tenhertz( ...@@ -314,7 +314,8 @@ def obsrio_tenhertz(
"""Filter 10Hz miniseed U,V,W to 1Hz legacy H,E,Z.""" """Filter 10Hz miniseed U,V,W to 1Hz legacy H,E,Z."""
starttime, endtime = get_realtime_interval(realtime_interval) starttime, endtime = get_realtime_interval(realtime_interval)
controller = Controller( controller = Controller(
inputFactory=input_factory or get_miniseed_factory(), inputFactory=input_factory
or get_miniseed_factory(convert_channels=("U", "V", "W")),
inputInterval="tenhertz", inputInterval="tenhertz",
outputFactory=output_factory or get_edge_factory(), outputFactory=output_factory or get_edge_factory(),
outputInterval="second", outputInterval="second",
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment