import shutil
import os
import sys
+import time
if len(arvados.current_task()['parameters']) > 0:
p = arvados.current_task()['parameters']
print("arvados-bcbio-nextgen: start writing output to keep")
done = False
+ api = arvados.api('v1')
while not done:
try:
out = arvados.CollectionWriter()