From e1e09d3a4ba27f9fd992cc6497b311e6539f95e3 Mon Sep 17 00:00:00 2001 From: Robert Nishihara Date: Wed, 6 Jul 2016 14:20:57 -0700 Subject: [PATCH] catch type checking exceptions --- lib/python/ray/worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/python/ray/worker.py b/lib/python/ray/worker.py index c67113a8e..60afa4ad9 100644 --- a/lib/python/ray/worker.py +++ b/lib/python/ray/worker.py @@ -289,8 +289,8 @@ def main_loop(worker=global_worker): ray.lib.start_worker_service(worker.handle) def process_task(task): # wrapping these lines in a function should cause the local variables to go out of scope more quickly, which is useful for inspecting reference counts func_name, args, return_objrefs = serialization.deserialize_task(worker.handle, task) - arguments = get_arguments_for_execution(worker.functions[func_name], args, worker) # get args from objstore try: + arguments = get_arguments_for_execution(worker.functions[func_name], args, worker) # get args from objstore outputs = worker.functions[func_name].executor(arguments) # execute the function if len(return_objrefs) == 1: outputs = (outputs,)