Skip to content
Snippets Groups Projects
Commit a9851075 authored by John Chilton's avatar John Chilton
Browse files

Improved input logging.

 - When client uploads files, log them.
parent 7f4e5237
No related branches found
No related tags found
No related merge requests found
......@@ -178,10 +178,14 @@ class JobClient(BaseJobClient):
if action_type in ['transfer', 'message']:
if isinstance(contents, string_types):
contents = contents.encode("utf-8")
message = "Uplodaing path [%s] (action_type: [%s])"
log.debug(message, path, action_type)
return self._upload_file(args, contents, input_path)
elif action_type == 'copy':
path_response = self._raw_execute('path', args)
pulsar_path = json_loads(path_response)['path']
message = "Copying path [%s] to [%s]"
log.debug(message, path, pulsar_path)
copy(path, pulsar_path)
return {'path': pulsar_path}
......
......@@ -24,7 +24,7 @@ class LocalShell(BaseShellExec):
True
>>> exec_result.stdout.strip() == u'Hello World'
True
>>> exec_result = exec_python("import time; time.sleep(90)", timeout=1, timeout_check_interval=.1)
>>> exec_result = exec_python("import time; time.sleep(90)", timeout=.3, timeout_check_interval=.1)
>>> exec_result.stdout == u''
True
>>> exec_result.stderr == 'Execution timed out'
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment