diff --git a/bob/bio/base/pipelines/vanilla_biometrics/pipelines.py b/bob/bio/base/pipelines/vanilla_biometrics/pipelines.py index 48ba26d81b0604e1ddfde01e806fe145ce962fc4..434c5208cb168d0d02094438e8454f95d17674b6 100644 --- a/bob/bio/base/pipelines/vanilla_biometrics/pipelines.py +++ b/bob/bio/base/pipelines/vanilla_biometrics/pipelines.py @@ -146,28 +146,3 @@ class VanillaBiometricsPipeline(object): # scores is a list of Samples return scores - - -def dask_vanilla_biometrics(pipeline, npartitions=None): - """ - Given a :py:class:`VanillaBiometrics`, wraps :py:meth:`VanillaBiometrics.transformer` and - :py:class:`VanillaBiometrics.biometric_algorithm` with Dask delayeds - - Parameters - ---------- - - pipeline: :py:class:`VanillaBiometrics` - Vanilla Biometrics based pipeline to be dasked - - - npartitions: int - Number of partitions for the initial `Dask.bag` - """ - - from bob.pipelines.mixins import estimator_dask_it, mix_me_up - from bob.bio.base.pipelines.vanilla_biometrics.mixins import BioAlgDaskMixin - - transformer = estimator_dask_it(pipeline.transformer, npartitions=npartitions) - biometric_algorithm = mix_me_up([BioAlgDaskMixin], pipeline.biometric_algorithm) - - return VanillaBiometrics(transformer, biometric_algorithm)