import stat
import put
import time
-#import arvados.command.ws as ws
+import arvados.commands.ws as ws
import subprocess
import logging
arvrun_parser.print_help()
return
+ starting_args = args.args
+
reading_into = 2
slots = [[], [], []]
component["script_parameters"]["command"] = slots[2:]
pipeline = {
- "name": "",
+ "name": " ".join(starting_args),
"components": {
"command": component
},
api = arvados.api('v1')
pi = api.pipeline_instances().create(body=pipeline).execute()
print "Running pipeline %s" % pi["uuid"]
- #ws.main(["--pipeline", pi["uuid"]])
+ ws.main(["--pipeline", pi["uuid"]])
if __name__ == '__main__':
main()