From 1f46ff143cd09b689033def850e9feb6890ba6ec Mon Sep 17 00:00:00 2001
From: John Chilton <jmchilton@gmail.com>
Date: Mon, 18 Apr 2016 08:27:41 -0400
Subject: [PATCH] Log more copy actions.
---
pulsar/client/client.py | 12 ++++++++----
1 file changed, 8 insertions(+), 4 deletions(-)
diff --git a/pulsar/client/client.py b/pulsar/client/client.py
index 4624776b..4b9c4df0 100644
--- a/pulsar/client/client.py
+++ b/pulsar/client/client.py
@@ -185,9 +185,7 @@ class JobClient(BaseJobClient):
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)
+ _copy(path, pulsar_path)
return {'path': pulsar_path}
def fetch_output(self, path, name, working_directory, action_type, output_type):
@@ -232,7 +230,7 @@ class JobClient(BaseJobClient):
self.__raw_download_output(name, self.job_id, path_type, output_path)
elif action_type == 'copy':
pulsar_path = self._output_path(name, self.job_id, path_type)['path']
- copy(pulsar_path, output_path)
+ _copy(pulsar_path, output_path)
@parseJson()
def _upload_file(self, args, contents, input_path):
@@ -386,6 +384,12 @@ class InputCachingJobClient(JobClient):
return self._raw_execute("file_available", {"path": path})
+def _copy(from_path, to_path):
+ message = "Copying path [%s] to [%s]"
+ log.debug(message, from_path, to_path)
+ copy(from_path, to_path)
+
+
def _setup_params_from_job_config(job_config):
job_id = job_config.get("job_id", None)
tool_id = job_config.get("tool_id", None)
--
GitLab