Skip to content

Commit

Permalink
Remoce joblib temporary
Browse files Browse the repository at this point in the history
  • Loading branch information
endast committed Dec 6, 2023
1 parent 93fa488 commit f3cba5d
Showing 1 changed file with 12 additions and 5 deletions.
17 changes: 12 additions & 5 deletions deeprvat/preprocessing/preprocess.py
Original file line number Diff line number Diff line change
Expand Up @@ -299,12 +299,19 @@ def process_sparse_gt(

logging.info(f"sparse gt chrom(es) are: {sparse_gt_chrom}")

processed = Parallel(n_jobs=threads, verbose=50)(
delayed(process_sparse_gt_file)(
f.as_posix(), variants_chrom, samples, calls_to_exclude
# processed = Parallel(n_jobs=threads, verbose=50)(
# delayed(process_sparse_gt_file)(
# f.as_posix(), variants_chrom, samples, calls_to_exclude
# )
# for f in sparse_gt_chrom
# )
processed = []
for f in sparse_gt_chrom:
processed.append(
process_sparse_gt_file(
f.as_posix(), variants_chrom, samples, calls_to_exclude
)
)
for f in sparse_gt_chrom
)

postprocessed_gt = postprocess_sparse_gt(processed, 1, len(samples))
postprocessed_variants = postprocess_sparse_gt(processed, 0, len(samples))
Expand Down

0 comments on commit f3cba5d

Please sign in to comment.