Skip to content

Commit

Permalink
undo changes to pipeline preprocess
Browse files Browse the repository at this point in the history
  • Loading branch information
kevinrue committed Apr 17, 2024
1 parent c0ea041 commit 246ef5c
Showing 1 changed file with 1 addition and 16 deletions.
17 changes: 1 addition & 16 deletions panpipes/panpipes/pipeline_preprocess.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,13 +15,6 @@

# import pandas as pd

L = logging.getLogger('panpipes')
L.setLevel(logging.INFO)
log_handler = logging.FileHandler("pipeline.log")
log_formatter = logging.Formatter('%(asctime)s: %(levelname)s - %(message)s')
log_handler.setFormatter(log_formatter)
L.addHandler(log_handler)

PARAMS = P.get_parameters(
["%s/pipeline.yml" % os.path.splitext(__file__)[0],
"pipeline.yml"])
Expand Down Expand Up @@ -59,16 +52,8 @@ def filter_mudata(outfile):
cmd += " --keep_barcodes %(filtering_keep_barcodes)s"
if PARAMS['intersect_mods'] is not None:
cmd += " --intersect_mods %(intersect_mods)s"
logfile = "logs/filtering.log"
cmd += f" > {logfile}"
cmd += " > logs/filtering.log "
job_kwargs["job_threads"] = PARAMS['resources_threads_low']
L.info(
"Task: 'filter_mudata'" + "\n" +
f"Input file(s): {PARAMS["unfiltered_obj"]}" + "\n" +
f"Output file(s): {outfile}" + "\n" +
f"Log file: {logfile}" + "\n" +
"In case of error, please refer to the log file(s) above for more information."
)
P.run(cmd, **job_kwargs)
else:
try:
Expand Down

0 comments on commit 246ef5c

Please sign in to comment.