Deborah.EstherThreads

module EstherThreads

Deborah.EstherThreads — Threaded dispatcher for multi-job Deborah.Esther runs.

Deborah.EstherThreads parallelizes multiple Deborah.Esther computations (across LBP/TRP grids) using Julia Threads. It parses a master TOML config into per-job arguments, writes job-specific configs, ensures Deborah.DeborahCore prerequisites for $\text{Tr}\,M^{-n} \; (n=1,2,3,4)$ are present, and launches Deborah.Esther in batches of Base.Threads.nthreads() with per-job logging.

Scope & Responsibilities

• Config expansion: EstherThreadsRunner.parse_config_EstherThreads → list of jobs over labels $\times$ trains.
• Per-job config: EstherThreadsRunner.generate_toml_dict builds a TOML dict for one Deborah.Esther job.
• Dependency check: call Deborah.DeborahEsther.EstherDependencyManager.ensure_TrM_exists to guarantee $\text{Tr}\,M^{-n} \; (n=1,2,3,4)$ inputs exist (auto-invokes Deborah.DeborahCore if needed).
• Threaded execution: spawn tasks in batches; each job writes its own .log file.
• Stable naming: construct overall_name/output_base using either full X_Y or abbreviation codes plus model suffixes.

Public API

• EstherThreadsRunner.run_EstherThreads

File/Path Conventions

• Output base: <location>/<analysis_header>_<ensemble>/<analysis_header>_<ensemble>_<TrM1..TrM4(+model_suffixes)>/
• Per-job directory: .../<overall_name>/
• Per-job config: config_Esther_<overall_name>.toml
• Per-job log: run_Esther_<overall_name>.log

Minimal Usage (REPL)

julia> using Deborah
julia> run_EstherThreads("config_EstherThreads.toml")

Notes

• All column indices are $1$-based.
• Bootstrap method should be "nonoverlapping", "moving", or "circular".
• Parallel width equals Base.Threads.nthreads(); set JULIA_NUM_THREADS to adjust.
• Abbreviation dicts are supported and propagated when use_abbreviation = true.