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 240ce9572d35dae28e31a5ebbe888d19a68614d2..61c28d7d9045d0d5a32229d488e833768f0e69c8 100644 --- a/karabo_devices/shared_mem_processor/src/onlinemid_karabo/processor.py +++ b/karabo_devices/shared_mem_processor/src/onlinemid_karabo/processor.py @@ -111,11 +111,25 @@ class OnlineMIDProcessor(TrainMatcher.TrainMatcher): .defaultValue(True) .commit(), + NODE_ELEMENT(expected) + .key("debug") + .displayname("Debug") + .commit(), + + SLOT_ELEMENT(expected) + .key("triggerSampleOutput") + .displayedName("send test data over pipeline") + .description("send test data") + .commit(), + + OUTPUT_CHANNEL(expected) .key("plots") .dataSchema(preview_schema()) .commit(), + + ) def __init__(self, config): @@ -130,7 +144,7 @@ class OnlineMIDProcessor(TrainMatcher.TrainMatcher): # expose the get xpcs settings function self.KARABO_SLOT(self.get_OnlineMIDSettings) self.KARABO_SLOT(self.triggerSampleOutput) - + self.registerSlot(self.triggerSampleOutput) ### XPCS specific variables self.online_processing_memory = None @@ -296,6 +310,8 @@ class OnlineMIDProcessor(TrainMatcher.TrainMatcher): my_generated_train_id = 21249888900 def triggerSampleOutput(self): + + self.log.INFO("generating sample output") print("generating sample output") myGroupName = self.get('deviceId')[-2:]