Skip to content
Snippets Groups Projects

Don't send data from before start time to ev44 and don't write any data after stop time for all schemas

Merged Matt Clarke_1 requested to merge prototype_not_sending_buffered_data_for_ev44_2 into main
6 files
+ 13
12
Compare changes
  • Side-by-side
  • Inline
Files
6
@@ -122,20 +122,20 @@
@@ -122,20 +122,20 @@
{
{
"schema": "ev44",
"schema": "ev44",
"topic": "local_detector",
"topic": "local_detector",
"kafka_timestamp": 16000,
"kafka_timestamp": 15000,
"source_name": "detector_events",
"source_name": "detector_events",
"message_id": 669,
"message_id": 669,
"reference_time": 16000,
"reference_time": 15000,
"time_of_flight": [130, 140, 150, 160],
"time_of_flight": [130, 140, 150, 160],
"pixel_ids": [1, 2, 3, 4]
"pixel_ids": [1, 2, 3, 4]
},
},
{
{
"schema": "ev44",
"schema": "ev44",
"topic": "local_detector",
"topic": "local_detector",
"kafka_timestamp": 17000,
"kafka_timestamp": 16000,
"source_name": "detector_events",
"source_name": "detector_events",
"message_id": 670,
"message_id": 670,
"reference_time": 17000,
"reference_time": 16000,
"time_of_flight": [170, 180, 190, 200],
"time_of_flight": [170, 180, 190, 200],
"pixel_ids": [1, 2, 3, 4]
"pixel_ids": [1, 2, 3, 4]
}
}
Loading