src/chug/task_pipeline/pipeline_gtparse.py [47:65]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            image_key=tuple(cfg.image_input_feat.input_key.split(';')),
            text_key=tuple(cfg.text_input_feat.input_key.split(';')),
        )
        pipe += [
            wds.select(filter_fn)
        ]

    if cfg.decode_and_process_fn:
        pipe += [
            wds.map(cfg.decode_and_process_fn)
        ]
    else:
        decode_fn = create_image_decoder(
            cfg.decode_fn,
            image_mode=cfg.image_input_feat.image_mode,
            handler=handler,
        )

        rename_dict = {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/chug/task_pipeline/pipeline_image_text.py [45:63]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            image_key=tuple(cfg.image_input_feat.input_key.split(';')),
            text_key=tuple(cfg.text_input_feat.input_key.split(';')),
        )
        pipe += [
            wds.select(filter_fn)
        ]

    if cfg.decode_and_process_fn:
        pipe += [
            wds.map(cfg.decode_and_process_fn)
        ]
    else:
        decode_fn = create_image_decoder(
            cfg.decode_fn,
            image_mode=cfg.image_input_feat.image_mode,
            handler=handler,
        )

        rename_dict = {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -