crunch_scripts/test/task_output_dir

   1 #!/usr/bin/env python
   2
   3 import arvados
   4 import arvados.crunch
   5 import hashlib
   6 import os
   7
   8 out = arvados.crunch.TaskOutputDir()
   9
  10 string = open(__file__).read()
  11 with open(os.path.join(out.path, 'example.out'), 'w') as f:
  12     f.write(string)
  13 with open(os.path.join(out.path, 'example.out.SHA1'), 'w') as f:
  14     f.write(hashlib.sha1(string).hexdigest() + "\n")
  15
  16 arvados.current_task().set_output(out.manifest_text())