Dispatch

API

from drtoller.framework.processing.dispatch import (
    run_from_manifest,
    register_pattern_runner,
    register_mode_runner,
)

Algorithm

1. Load manifest, merge params, optional setup_metrics.
2. v3: pattern registry → else execution.entry via runtime.import_utils.import_symbol.
3. Legacy: mode registry → else manifest.runner.
4. finalize_metrics in finally.

Builtin registries

Kind	Keys	Runner
pattern	mapping, reduce_merge	run_mapping, run_reduce_merge
mode	partition_loop, mapping, reduce_merge	matching run_*

embed_train usually goes through v3 execution.entry to embed_train.run.

Extending

register_pattern_runner("my_pattern", my_run)
register_mode_runner("my_mode", my_run)

Do not add new if branches in run_from_manifest.