Skip to content
Snippets Groups Projects

Copy F (geomag) to F (legacy) fixed:

1 file
+ 18
2
Compare changes
  • Side-by-side
  • Inline
@@ -207,7 +207,6 @@ def realtime_command(
("U", "H"),
("V", "E"),
("W", "Z"),
("F", "F"),
),
interval="second",
input_factory=EdgeFactory(
@@ -223,7 +222,24 @@ def realtime_command(
realtime_interval=realtime_interval,
update_limit=update_limit,
)
# remove the following after data migration is complete
_copy_channels(
observatory=observatory,
channels=(("F", "F"),),
interval="second",
input_factory=MiniSeedFactory(
host=input_host, port=input_port, type="variation", sncl_mode="geomag"
),
output_factory=EdgeFactory(
host=output_host,
port=output_read_port,
write_port=7981, # hard-code port for legacy sncls
type="variation",
sncl_mode="legacy",
),
realtime_interval=realtime_interval,
update_limit=update_limit,
)
minute_filter(
observatory=observatory,
channels=("U", "V", "W"),
Loading