X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/377dfa814e50bb021ddf2aead4bf08144d74f7da..d65a54bbef464dc47c095c4c03fb4b96d0f13304:/crunch_scripts/run-command

diff --git a/crunch_scripts/run-command b/crunch_scripts/run-command
index 6359ee6032..e6ec889bbc 100755
--- a/crunch_scripts/run-command
+++ b/crunch_scripts/run-command
@@ -49,7 +49,7 @@ subst.default_subs["node.cores"] = sub_cores
 rcode = 1
 
 def machine_progress(bytes_written, bytes_expected):
-    return "run-command: {} written {} total\n".format(
+    return "run-command: wrote {} total {}\n".format(
         bytes_written, -1 if (bytes_expected is None) else bytes_expected)
 
 class SigHandler(object):
@@ -113,7 +113,7 @@ reporter = put.progress_writer(machine_progress)
 bytes_expected = put.expected_bytes_for(".")
 while not done:
     try:
-        out = put.ArvPutCollectionWriter(resume_cache, reporter, bytes_expected)
+        out = put.ArvPutCollectionWriter.from_cache(resume_cache, reporter, bytes_expected)
         out.do_queued_work()
         out.write_directory_tree(".", max_manifest_depth=0)
         outuuid = out.finish()