Skip to content

Imbrication de pipelines

Objectif : imbriquer des pipelines et mutualiser les ressources.

MD (14/03/2023) Concernant la composition de transfos, si on ne veut pas laisser l'utilisateur le faire alors il faut créer un transfo qui en appelle d'autre, quelque chose dans ce goût là:

from monPaquetA import ma_transfo_A
from monPaquetB import ma_transfo_B

def ma_transfo_C(working_dir: str, logger: logging.Logger, options: dict = None):
    ma_transfo_A(working_dir, logger)
    ma_transfo_B(working_dir, logger)

Charge à la transfo C de redistribuer correctement les options s'il y en a.

Edited by Edith Cannet