Initial commit

simple_source/run.py

+from ryax_gateway.gateway import RyaxGateway, main
+
+
+class RunOneExecution(RyaxGateway):
+    async def handler(self):
+        text = self.inputs_values["input1"]
+
+        topic = self.inputs_values["mqtt_topic"]
+        mqtt_server = self.inputs_values["mqtt_server"]
+
+        await self.send_execution({"output1":text,"output2":topic,"output3":mqtt_server})
+        
+
+
+if __name__ == "__main__":
+    main(RunOneExecution)

simple_source/ryax_metadata.yml

+apiVersion: "ryax.tech/v1"
+kind: Gateways
+spec:
+  id: one-run
+  human_name: Run one execution
+  type: python3
+  version: "1.0"
+  detail: Launches a single execution of the workflow
+  categories:
+  - Source
+  - Developer tools
+  - Timer
+  - Default Modules
+  inputs:
+    - help: The MQTT server to subscribe on.
+    human_name: MQTT server
+    name: mqtt_server
+    type: string
+    - help: serv
+    human_name: MQTT server
+    name: mqtt_topic
+    type: string
+  outputs:
+    - help: The content of the MQTT message read from the topic.
+    human_name: MQTT message value
+    name: output1
+    type: string
+    - help: The cont.
+    human_name: MQTT message value
+    name: output2
+    type: string
+    - help: The cont.
+    human_name: MQTT message value
+    name: output3
+    type: string
+
+
+