diff --git a/wrapper.py b/wrapper.py
index c5ce272..4a67585 100644
--- a/wrapper.py
+++ b/wrapper.py
@@ -28,6 +28,7 @@ class ProcessWrapper:
 
     def send(self, msg):
         self.proc.stdin.write(msg)
+        self.proc.stdin.flush()
 
     def wait(self):
         return self.proc.wait()
@@ -55,9 +56,12 @@ def send_process_output(
 def relay_queue_input(
     process: ProcessWrapper, msg_queue: message_queue.MessageQueue
 ):
+    log = LOG.getChild("relay_input")
     for message in msg_queue:
+        log.debug(message)
         if "command" in message:
-            process.send(message["command"])
+            log.debug("forwarding to process")
+            process.send(message["command"] + "\n")
         else:
             LOG.debug(message)