From 72119995d1a3171581e600744cc425bf5bd80821 Mon Sep 17 00:00:00 2001 From: Mads Jakobsen <mads.jakobsen@xfel.eu> Date: Wed, 12 Mar 2025 11:14:39 +0100 Subject: [PATCH] indent error --- .../src/onlinemid_karabo/processor.py | 82 +++++++++---------- 1 file changed, 41 insertions(+), 41 deletions(-) diff --git a/karabo_devices/shared_mem_processor/src/onlinemid_karabo/processor.py b/karabo_devices/shared_mem_processor/src/onlinemid_karabo/processor.py index 5e866be..36702d0 100644 --- a/karabo_devices/shared_mem_processor/src/onlinemid_karabo/processor.py +++ b/karabo_devices/shared_mem_processor/src/onlinemid_karabo/processor.py @@ -357,16 +357,18 @@ class OnlineMIDProcessor(TrainMatcher.TrainMatcher): def handle_detector_data_list(self, train_id, detector_data_list, numPixelPerGainStage=None): - print("in gandle detector data") - # time_to_handle_list_0 = time.perf_counter() + print("in handle detector data") + + # time_to_handle_list_0 = time.perf_counter() - # self.online_processing_memory, online_output_dict = onlinexpcsutils.compute_xpcs_from_detector_data_list( - # detector_data_list, - # xpcs_processing_memory=self.online_processing_memory, - # xpcs_settings=self.xpcs_settings) - # print("time_to_handle_list 0", time.perf_counter() - time_to_handle_list_0) + # self.online_processing_memory, online_output_dict = onlinexpcsutils.compute_xpcs_from_detector_data_list( + # detector_data_list, + # xpcs_processing_memory=self.online_processing_memory, + # xpcs_settings=self.xpcs_settings) + # print("time_to_handle_list 0", time.perf_counter() - time_to_handle_list_0) - ''' roi = self.xpcs_settings['qbin'] + ''' + roi = self.xpcs_settings['qbin'] self.runningstats_processing_memory, runningstats_output_dict = runningstats.process_detector_data_list( detector_data_list, roi, @@ -378,38 +380,38 @@ class OnlineMIDProcessor(TrainMatcher.TrainMatcher): runningstats_output_dict['numPixelPerGainStage'] = numPixelPerGainStage ''' - # time_to_handle_list_1 = time.perf_counter() + # time_to_handle_list_1 = time.perf_counter() - # selected_module_key = onlinexpcsutils.agipd_source_module_no_to_unique_string_id(self.get('module_number_for_plotting')) + # selected_module_key = onlinexpcsutils.agipd_source_module_no_to_unique_string_id(self.get('module_number_for_plotting')) - # print("time_to_handle_list 1", time.perf_counter() - time_to_handle_list_1) + # print("time_to_handle_list 1", time.perf_counter() - time_to_handle_list_1) # get module related plots from processing memory # this is made via matplotlib, plotting takes time, # the following code ensure plotting is only asked every 0.9 seeconds - # time_to_handle_list_2 = time.perf_counter() + # time_to_handle_list_2 = time.perf_counter() - # self.online_processing_memory, current_image = onlinexpcsutils.xpcs_view_into_processing( - # self.online_processing_memory, - # selected_module_key, - # train_id) - # print("time_to_handle_list 2", time.perf_counter() - time_to_handle_list_2) + # self.online_processing_memory, current_image = onlinexpcsutils.xpcs_view_into_processing( + # self.online_processing_memory, + # selected_module_key, + # train_id) + # print("time_to_handle_list 2", time.perf_counter() - time_to_handle_list_2) # plot accumulating sum and lit pixel counter for panel data - # time_to_handle_list_3 = time.perf_counter() + # time_to_handle_list_3 = time.perf_counter() #plot_hash = Hash() -# npArray_sum = onlinexpcsutils.get_accumulating_sum(self.xpcs_processing_memory, selected_module_key) -# if npArray_sum is not None: -# plot_hash['data.accumulating_sum'] = ImageData(npArray_sum) -# -# npArray_lit_pixel_counter = onlinexpcsutils.get_accumulating_lit_pixel_counter(self.xpcs_processing_memory, selected_module_key) -# if npArray_lit_pixel_counter is not None: -# plot_hash['data.accumulating_lit_bunch'] = ImageData(npArray_lit_pixel_counter) + # npArray_sum = onlinexpcsutils.get_accumulating_sum(self.xpcs_processing_memory, selected_module_key) + # if npArray_sum is not None: + # plot_hash['data.accumulating_sum'] = ImageData(npArray_sum) + # + # npArray_lit_pixel_counter = onlinexpcsutils.get_accumulating_lit_pixel_counter(self.xpcs_processing_memory, selected_module_key) + # if npArray_lit_pixel_counter is not None: + # plot_hash['data.accumulating_lit_bunch'] = ImageData(npArray_lit_pixel_counter) #npArray_currentImage = onlinexpcsutils.get_current_Image(self.online_processing_memory, selected_module_key) #if npArray_currentImage is not None: @@ -417,29 +419,27 @@ class OnlineMIDProcessor(TrainMatcher.TrainMatcher): - # if current_image is not None: - # plot_hash['data.masking_plot'] = ImageData(current_image) + # if current_image is not None: + # plot_hash['data.masking_plot'] = ImageData(current_image) - # print("time_to_handle_list 3", time.perf_counter() - time_to_handle_list_3) + # print("time_to_handle_list 3", time.perf_counter() - time_to_handle_list_3) # send hash - # time_to_handle_list_4 = time.perf_counter() - -# my_timestamp = Timestamp(Epochstamp(), Trainstamp(train_id)) -# myname = self.get('deviceId') -# if self.assembled_output is not None: -# self.assembled_output.write( -# plot_hash, ChannelMetaData(f'{myname}:plots', my_timestamp), copyAllData=False -# ) -# self.assembled_output.update(safeNDArray=True) + # time_to_handle_list_4 = time.perf_counter() + # my_timestamp = Timestamp(Epochstamp(), Trainstamp(train_id)) + # myname = self.get('deviceId') + # if self.assembled_output is not None: + # self.assembled_output.write( + # plot_hash, ChannelMetaData(f'{myname}:plots', my_timestamp), copyAllData=False + # ) + # self.assembled_output.update(safeNDArray=True) - # print("time_to_handle_list _ 4", time.perf_counter() - time_to_handle_list_4) - - # time_to_handle_list_5 = time.perf_counter() + # print("time_to_handle_list _ 4", time.perf_counter() - time_to_handle_list_4) + # time_to_handle_list_5 = time.perf_counter() output_hash = Hash() ''' @@ -458,7 +458,7 @@ class OnlineMIDProcessor(TrainMatcher.TrainMatcher): ) self.output.update(safeNDArray=True) - # print("time_to_handle_list _5", time.perf_counter() - time_to_handle_list_5) + # print("time_to_handle_list _5", time.perf_counter() - time_to_handle_list_5) ''' if runningstats_output_dict is not None: if 'numBins' in runningstats_output_dict and 'numBunches' in runningstats_output_dict: -- GitLab