crunch_scripts/collection-merge

   1 #!/usr/bin/env python
   2
   3 import arvados
   4
   5 inputs = arvados.current_job()['script_parameters']['input']
   6 if not isinstance(inputs, (list,tuple)):
   7     inputs = [inputs]
   8
   9 out_manifest = ''
  10 for locator in inputs:
  11     out_manifest += arvados.CollectionReader(locator).manifest_text()
  12
  13 arvados.current_task().set_output(arvados.Keep.put(out_manifest))