8
8
import numcodecs
9
9
import tabulate
10
10
11
- from . import plink , provenance , vcf , vcf_utils
11
+ from . import icf , plink , provenance , vcf , vcf_utils
12
12
13
13
logger = logging .getLogger (__name__ )
14
14
@@ -167,7 +167,7 @@ def check_overwrite_dir(path, force):
167
167
def get_compressor (cname ):
168
168
if cname is None :
169
169
return None
170
- config = vcf .ICF_DEFAULT_COMPRESSOR .get_config ()
170
+ config = icf .ICF_DEFAULT_COMPRESSOR .get_config ()
171
171
config ["cname" ] = cname
172
172
return numcodecs .get_codec (config )
173
173
@@ -198,7 +198,7 @@ def explode(
198
198
"""
199
199
setup_logging (verbose )
200
200
check_overwrite_dir (icf_path , force )
201
- vcf .explode (
201
+ icf .explode (
202
202
icf_path ,
203
203
vcfs ,
204
204
worker_processes = worker_processes ,
@@ -235,7 +235,7 @@ def dexplode_init(
235
235
"""
236
236
setup_logging (verbose )
237
237
check_overwrite_dir (icf_path , force )
238
- work_summary = vcf .explode_init (
238
+ work_summary = icf .explode_init (
239
239
icf_path ,
240
240
vcfs ,
241
241
target_num_partitions = num_partitions ,
@@ -263,7 +263,7 @@ def dexplode_partition(icf_path, partition, verbose, one_based):
263
263
setup_logging (verbose )
264
264
if one_based :
265
265
partition -= 1
266
- vcf .explode_partition (icf_path , partition )
266
+ icf .explode_partition (icf_path , partition )
267
267
268
268
269
269
@click .command
@@ -274,7 +274,7 @@ def dexplode_finalise(icf_path, verbose):
274
274
Final step for distributed conversion of VCF(s) to intermediate columnar format.
275
275
"""
276
276
setup_logging (verbose )
277
- vcf .explode_finalise (icf_path )
277
+ icf .explode_finalise (icf_path )
278
278
279
279
280
280
@click .command
0 commit comments