1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
//! Centralized, parallel-safe progress and terminal reporting.
//!
//! [`ProgressReporter`] registers every project task under an exact
//! parameter-derived [`TaskIdentity`], assigns ordering from configuration, and
//! becomes the sole human-facing terminal writer for its lifetime. Worker
//! threads receive non-clone [`TaskProgress`] handles and synchronize absolute
//! iteration from their authoritative scientific state.
//!
//! Iteration updates use per-task atomics. One renderer thread polls them at a
//! bounded frequency, so numerical workers never draw progress bars or contend
//! on terminal locks. Interactive stderr receives a multi-progress display;
//! redirected stderr receives stable lifecycle lines. Tests and embedding
//! applications may retain tracking while selecting hidden output.
//!
//! # Minimal parallel use
//!
//! ```no_run
//! use scientific_workflow::prelude::*;
//!
//! # fn main() -> Result<(), Box<dyn std::error::Error>> {
//! let project = ScientificProject::load("project-root")?;
//! let reporter = ProgressReporter::for_project(&project)
//! .identify_tasks_by(["temperature", "seed"])
//! .start()?;
//! # let task = project.task_config(0)?;
//! let progress = reporter.start_task(&task, 0, Some(1_000))?;
//! progress.set_iteration(1_000)?;
//! progress.complete()?;
//! # for task in project.task_configs().skip(1) {
//! # reporter.start_task(&task, 0, Some(0))?.complete()?;
//! # }
//! let summary = reporter.complete("scientific work completed")?;
//! assert!(summary.is_success());
//! # Ok(())
//! # }
//! ```
pub use ReportingError;
pub use ;