Merge branch '30_fix_wait_method' into 'master'

Fix wait method

Closes #30

See merge request !67

beat/backend/python/execution/database.py

@@ -223,7 +223,12 @@ class DBExecutor(object):
     def wait(self):
         """Wait for the message handle to finish"""
 
-        self.message_handler.join()
+        try:
+            self.message_handler.join()
+        except RuntimeError:
+            # tried to join the handler before it has started.
+            pass
+
         self.message_handler = None
 
     def __str__(self):

beat/backend/python/execution/loop.py

@@ -291,7 +291,12 @@ class LoopExecutor(object):
     def wait(self):
         """Wait for the message handle to finish"""
 
-        self.message_handler.join()
+        try:
+            self.message_handler.join()
+        except RuntimeError:
+            # tried to join the handler before it has started.
+            pass
+
         self.message_handler = None
 
     def close(self):