6
6
7
7
import click
8
8
9
- from bio2zarr import icf , vcf , verification
9
+ from bio2zarr import vcf2zarr
10
10
11
11
# TODO add support here for split vcfs. Perhaps simplest to take a
12
12
# directory provided as input as indicating this, and then having
@@ -40,11 +40,11 @@ def cli(vcfs, worker_processes, force):
40
40
else :
41
41
files = [f ]
42
42
source_file = f
43
- exploded = tmp_path / (f .name + ".exploded " )
43
+ exploded = tmp_path / (f .name + ".icf " )
44
44
if force and exploded .exists ():
45
45
shutil .rmtree (exploded )
46
46
if not exploded .exists ():
47
- icf .explode (
47
+ vcf2zarr .explode (
48
48
exploded ,
49
49
files ,
50
50
worker_processes = worker_processes ,
@@ -53,21 +53,21 @@ def cli(vcfs, worker_processes, force):
53
53
spec = tmp_path / (f .name + ".schema" )
54
54
if force or not spec .exists ():
55
55
with open (spec , "w" ) as specfile :
56
- vcf .mkschema (exploded , specfile )
56
+ vcf2zarr .mkschema (exploded , specfile )
57
57
58
- zarr = tmp_path / (f .name + ".zarr " )
58
+ zarr = tmp_path / (f .name + ".vcz " )
59
59
if force and zarr .exists ():
60
60
shutil .rmtree (zarr )
61
61
if not zarr .exists ():
62
- vcf .encode (
62
+ vcf2zarr .encode (
63
63
exploded ,
64
64
zarr ,
65
65
spec ,
66
66
worker_processes = worker_processes ,
67
67
show_progress = True ,
68
68
)
69
69
70
- verification . validate (source_file , zarr , show_progress = True )
70
+ vcf2zarr . verify (source_file , zarr , show_progress = True )
71
71
72
72
73
73
if __name__ == "__main__" :
0 commit comments