@@ -104,6 +104,7 @@ def __call__(self, sensor: Sensor, schedule_entry: dict, task_id: int):
104
104
sample_rate = self .sensor .signal_analyzer .sample_rate
105
105
num_samples = int (sample_rate * duration_ms * 1e-3 )
106
106
measurement_result = super ().acquire_data (num_samples , nskip , cal_adjust )
107
+ logger .debug ("Acquired measurement_result" )
107
108
measurement_result .update (measurement_params )
108
109
end_time = utils .get_datetime_str_now ()
109
110
measurement_result ["end_time" ] = end_time
@@ -138,21 +139,24 @@ def __call__(self, sensor: Sensor, schedule_entry: dict, task_id: int):
138
139
)
139
140
measurement_result ["capture_segment" ] = capture_segment
140
141
142
+ logger .debug ("Creating metadata for measurement result" )
141
143
self .create_metadata (measurement_result , recording_id )
142
- measurement_action_completed .send (
143
- sender = self .__class__ ,
144
- task_id = task_id ,
145
- data = measurement_result ["data" ],
146
- metadata = self .sigmf_builder .metadata ,
147
- )
148
- saved_samples += num_samples
149
144
snapshot = tracemalloc .take_snapshot ()
150
145
if last_snapshot :
151
146
stats = snapshot .compare_to (last_snapshot , 'lineno' )
152
147
logger .debug ("memory snapshot comparison" )
153
148
for stat in stats [:10 ]:
154
149
logger .debug (stat )
155
150
last_snapshot = snapshot
151
+ logger .debug ("sending measurement result to handler" )
152
+ measurement_action_completed .send (
153
+ sender = self .__class__ ,
154
+ task_id = task_id ,
155
+ data = measurement_result ["data" ],
156
+ metadata = self .sigmf_builder .metadata ,
157
+ )
158
+ saved_samples += num_samples
159
+
156
160
157
161
@property
158
162
def description (self ):
0 commit comments