in workspace/src/greengrass-bridge/greengrass_bridge/app.py [0:0]
def execute_publish_thread(self, event: model.IoTCoreMessage):
try:
self.get_logger().info("Kicking off the thread.")
t = threading.Thread(target = self.publish_to_ros2, args=[event])
t.start()
except Exception as ex:
self.get_logger().error(str(ex))