blub

karabo_devices/shared_mem_processor/src/onlinemid_karabo/processor.py

@@ -179,6 +179,46 @@ class OnlineMIDProcessor(TrainMatcher.TrainMatcher):
 
         # initalize member variable for the q bin array 
         # (Will have shape of 16x512x128)
+        
+        
+
+        if self.schemupdate_test is False and True:
+            print("updating schema")
+            res = Schema()
+            (
+                NODE_ELEMENT(res)
+                .key("data")
+                .displayedName('Data')
+                .commit(),
+
+                IMAGEDATA_ELEMENT(res)
+                .key("data.test_hash")
+                .displayedName('test')
+                .description('test')
+                .commit(),
+
+        #        NODE_ELEMENT(res)
+        #        .key("image")
+        #        .commit(),
+            )
+
+            schema_update = Schema()
+            (
+                OUTPUT_CHANNEL(schema_update)
+                .key("plots")
+                .dataSchema(res)
+                .commit(),
+            )
+
+            self.updateSchema(schema_update)
+            self.assembled_output = self._ss.getOutputChannel("plots")
+            self.schemupdate_test = True
+            print("updating schema done")
+            
+
+
+
+        
         self.assembled_output = self.signalSlotable.getOutputChannel("plots")
         
         if not self.get("enableKaraboOutput"):
@@ -375,38 +415,6 @@ class OnlineMIDProcessor(TrainMatcher.TrainMatcher):
         if numPixelPerGainStage is not None:
             plot_hash = self.onlineImagePlotter.add_to_hash(plot_hash, 'data.accumulating_lit_bunch', GainStagePlotter, train_id, numPixelPerGainStage)
 
-            if self.schemupdate_test is False and True:
-                print("updating schema")
-                res = Schema()
-                (
-                    NODE_ELEMENT(res)
-                    .key("data")
-                    .displayedName('Data')
-                    .commit(),
-
-                    IMAGEDATA_ELEMENT(res)
-                    .key("data.test_hash")
-                    .displayedName('test')
-                    .description('test')
-                    .commit(),
-
-            #        NODE_ELEMENT(res)
-            #        .key("image")
-            #        .commit(),
-                )
-
-                schema_update = Schema()
-                (
-                    OUTPUT_CHANNEL(schema_update)
-                    .key("plots")
-                    .dataSchema(res)
-                    .commit(),
-                )
-
-                self.updateSchema(schema_update)
-                self.assembled_output = self._ss.getOutputChannel("plots")
-                self.schemupdate_test = True
-                print("updating schema done")
             
             plot_hash = self.onlineImagePlotter.add_to_hash(plot_hash, 'data.test_hash', GainStagePlotter, train_id, numPixelPerGainStage)