from collection import *
from keep import *
from stream import *
+from arvfile import *
import errors
import util
return
job_input = current_job()['script_parameters']['input']
cr = CollectionReader(job_input)
+ cr.normalize()
for s in cr.all_streams():
for f in s.all_files():
if input_as_path:
body={'success':True}
).execute()
exit(0)
-
-