moved VALID_DASK_CLIENT_STRINGS to bob.pipelines

parent 0ee60e58
Pipeline #46365 passed with stage
in 4 minutes and 27 seconds
"""Executes PAD pipeline"""
from bob.bio.base.script.vanilla_biometrics import VALID_DASK_CLIENT_STRINGS
from bob.pipelines.distributed import VALID_DASK_CLIENT_STRINGS
import click
from bob.extension.scripts.click_helper import ConfigCommand
from bob.extension.scripts.click_helper import ResourceOption
......@@ -69,7 +69,9 @@ from bob.extension.scripts.click_helper import verbosity_option
)
@verbosity_option(cls=ResourceOption)
@click.pass_context
def vanilla_pad(ctx, pipeline, database, dask_client, groups, output, checkpoint, **kwargs):
def vanilla_pad(
ctx, pipeline, database, dask_client, groups, output, checkpoint, **kwargs
):
"""Runs the simplest PAD pipeline."""
import gzip
......@@ -125,7 +127,9 @@ def vanilla_pad(ctx, pipeline, database, dask_client, groups, output, checkpoint
os.makedirs(os.path.dirname(prefix), exist_ok=True)
logger.info("Writing bag results into files ...")
resources = get_resource_requirements(pipeline)
result.to_textfiles(pattern, last_endline=True, scheduler=dask_client, resources=resources)
result.to_textfiles(
pattern, last_endline=True, scheduler=dask_client, resources=resources
)
with open(scores_path, "w") as f:
# concatenate scores into one score file
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment