[ARVADOS] updated: 6d162bfdf0c3cbfc2d723ecff4153f85daa2d003
Git user
git at public.curoverse.com
Fri Aug 19 11:39:20 EDT 2016
Summary of changes:
sdk/python/arvados/commands/put.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
via 6d162bfdf0c3cbfc2d723ecff4153f85daa2d003 (commit)
from fe0d8506f80a7ce5f1d412823a09a5d7324b7161 (commit)
Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.
commit 6d162bfdf0c3cbfc2d723ecff4153f85daa2d003
Author: Lucas Di Pentima <lucas at curoverse.com>
Date: Fri Aug 19 12:38:24 2016 -0300
9463: Setting up the checkpointer thread as a daemon so that it finishes when the command is cancelled through ctrl-c
diff --git a/sdk/python/arvados/commands/put.py b/sdk/python/arvados/commands/put.py
index 4034173..1a27410 100644
--- a/sdk/python/arvados/commands/put.py
+++ b/sdk/python/arvados/commands/put.py
@@ -320,6 +320,7 @@ class ArvPutUploadJob(object):
"""
Start supporting thread & file uploading
"""
+ self._checkpointer.daemon = True
self._checkpointer.start()
try:
for path in self.paths:
@@ -472,7 +473,7 @@ class ArvPutUploadJob(object):
output = self._my_collection().open(filename, 'w')
self._write(source_fd, output)
output.close()
-
+
def _write(self, source_fd, output):
while True:
data = source_fd.read(arvados.config.KEEP_BLOCK_SIZE)
-----------------------------------------------------------------------
hooks/post-receive
--
More information about the arvados-commits
mailing list