ASCEE/pyqtgraph
5
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

add warnings for remote exceptions

Browse Source
This commit is contained in:
Pieter 2017-02-16 12:40:21 +01:00
parent dd5a8bf9d1
commit b9aea3daf1
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pyqtgraph/multiprocess/remoteproxy.py
View File

@ -1,6 +1,7 @@
import os, time, sys, traceback, weakref import os, time, sys, traceback, weakref
import numpy as np import numpy as np
import threading import threading
import warnings
try: try:
import __builtin__ as builtins import __builtin__ as builtins
import cPickle as pickle import cPickle as pickle
@ -21,6 +22,9 @@ class NoResultError(Exception):
because the call has not yet returned.""" because the call has not yet returned."""
pass pass
class RemoteExceptionWarning(UserWarning):
"""Emitted when a request to a remote object results in an Exception """
pass
class RemoteEventHandler(object): class RemoteEventHandler(object):
""" """
@ -502,9 +506,9 @@ class RemoteEventHandler(object):
#print ''.join(result) #print ''.join(result)
exc, excStr = result exc, excStr = result
if exc is not None: if exc is not None:
print("===== Remote process raised exception on request: =====") warnings.warn("===== Remote process raised exception on request: =====", RemoteExceptionWarning)
print(''.join(excStr)) warnings.warn(''.join(excStr), RemoteExceptionWarning)
print("===== Local Traceback to request follows: =====") warnings.warn("===== Local Traceback to request follows: =====", RemoteExceptionWarning)
raise exc raise exc
else: else:
print(''.join(excStr)) print(''.join(excStr))