diff options
| author | Luciano Resende <lresende@apache.org> | 2017-01-17 09:52:48 -0800 |
|---|---|---|
| committer | Luciano Resende <lresende@apache.org> | 2017-01-17 09:52:48 -0800 |
| commit | 94a52b4e2564cca7bbf581617e44e764ebdd49d0 (patch) | |
| tree | c5d460ad1bf73031f92075cefbf954cb1432e174 /python | |
| parent | def1f0416fb5ed5753c426deb03a674207cd76c2 (diff) | |
| download | toree-gateway-94a52b4e2564cca7bbf581617e44e764ebdd49d0.tar.gz toree-gateway-94a52b4e2564cca7bbf581617e44e764ebdd49d0.tar.bz2 toree-gateway-94a52b4e2564cca7bbf581617e44e764ebdd49d0.zip | |
Propagate errors as success with error details
Diffstat (limited to 'python')
| -rw-r--r-- | python/toree_kernel.py | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/python/toree_kernel.py b/python/toree_kernel.py index e73d916..4b6266e 100644 --- a/python/toree_kernel.py +++ b/python/toree_kernel.py @@ -19,6 +19,7 @@ import signal import sys import time import io +import logging from os import O_NONBLOCK, read from fcntl import fcntl, F_GETFL, F_SETFL @@ -70,8 +71,8 @@ class ToreeKernel(MetaKernel): self.gateway_proc = Popen(args, stderr=PIPE, stdout=PIPE) time.sleep(1.5) self.gateway = JavaGateway( - start_callback_server=True, - callback_server_parameters=CallbackServerParameters()) + start_callback_server=True, + callback_server_parameters=CallbackServerParameters()) flags = fcntl(self.gateway_proc.stdout, F_GETFL) # get current p.stdout flags fcntl(self.gateway_proc.stdout, F_SETFL, flags | O_NONBLOCK) @@ -128,7 +129,7 @@ class ToreeKernel(MetaKernel): self.handle_output(self.gateway_proc.stderr, self.Error) except Py4JError as e: if not silent: - self.Error(e.cause) + self.Error(format(e)) if retval is None: return @@ -139,3 +140,4 @@ class ToreeKernel(MetaKernel): if __name__ == '__main__': ToreeKernel.run_as_main() + |