femic.pipeline.stages

Pipeline stage executors used by workflow wrappers.

Functions

execute_legacy_tsa_stage(*, script_path, ...)	Load one legacy TSA stage module and execute its run_tsa loop.
initialize_legacy_tsa_stage_state()	Create empty state payload used by legacy 01a/01b TSA stages.
initialize_parallel_execution_backend(*, ...)	Initialize ipyparallel backend or fall back to serial execution.
load_legacy_module(*, script_path, module_name)	Load a Python module from a legacy script path.
prepare_tsa_index(*, f_table[, tsa_column])	Ensure legacy table uses TSA code as index for downstream stage lookups.
run_legacy_subprocess(*, execution_plan, ...)	Execute legacy script and stream output while filtering known noisy lines.
run_legacy_tsa_loop(*, tsa_list, ...)	Run one legacy stage per TSA with caller-provided skip logic.
should_skip_if_outputs_exist(*, ...[, print_fn])	Return True when resume mode is on and all required outputs already exist.
stream_filtered_subprocess_output(*, lines, ...)	Forward subprocess output lines, omitting exact known-noise line matches.

Classes

LegacyTSAStageState(vdyp_curves_smooth, ...)	Mutable state maps shared across legacy TSA stages.
ParallelExecutionBackend(use_ipp, rc, lbview)	Parallel execution backend selection for legacy notebook-style loops.
StageResult(exit_code)	Result returned by a stage executor.