vcf_in = os.path.join(arvados.current_task().tmpdir,
os.path.basename(input_file.name()))
vcf_out = re.sub('(.*)\\.vcf', '\\1-filtered.vcf', vcf_in)
vcf_in = os.path.join(arvados.current_task().tmpdir,
os.path.basename(input_file.name()))
vcf_out = re.sub('(.*)\\.vcf', '\\1-filtered.vcf', vcf_in)
vcf_in_file = open(vcf_in, 'w')
for buf in input_file.readall():
vcf_in_file.write(buf)
vcf_in_file = open(vcf_in, 'w')
for buf in input_file.readall():
vcf_in_file.write(buf)
'-R', os.path.join(bundle_path, 'human_g1k_v37.fasta')],
cwd=arvados.current_task().tmpdir)
'-R', os.path.join(bundle_path, 'human_g1k_v37.fasta')],
cwd=arvados.current_task().tmpdir)
with open(vcf_out, 'rb') as f:
out = arvados.CollectionWriter()
while True:
with open(vcf_out, 'rb') as f:
out = arvados.CollectionWriter()
while True: