Skip to content
Snippets Groups Projects

WIP: Obsrio/PCDCP Processing Pipeline

1 file
+ 10
0
Compare changes
  • Side-by-side
  • Inline
@@ -27,6 +27,16 @@ def prepare(
realtime_interval=realtime_interval,
update_limit=update_limit,
)
copy_channels(
observatory=observatory,
input_channels=["W"],
output_channels=["Z"],
interval="second",
input_factory=input_factory,
output_factory=output_factory,
realtime_interval=realtime_interval,
update_limit=update_limit,
)
copy_channels(
observatory=observatory,
input_channels=["UK1", "UK2", "UK3", "UK4"],
Loading