Fixes for the V 9.4 snapshot

This commit is contained in:
2015-06-11 16:09:46 -05:00
parent 4b882d8586
commit aa5977f324
7 changed files with 25 additions and 14 deletions

View File

@@ -24,10 +24,10 @@ def call_threaded(func, *args, **kwargs):
def stream_threaded(func, *args, **kwargs):
def new_func(*a, **k):
# try:
func(**k)
# except:
# pub.sendMessage("streamError", session=a[0])
try:
func(**k)
except:
pub.sendMessage("streamError", session=a[0])
thread = threading.Thread(target=new_func, args=args, kwargs=kwargs)
thread.daemon = True
thread.start()