Struct RunContext

Source

pub struct RunContext {Show 19 fields
    pub run_dir: Arc<RunDir>,
    pub replay_source_run_dir: Option<PathBuf>,
    pub graph_fingerprint: Arc<Mutex<HashMap<String, String>>>,
    pub node_definition_fingerprints: Arc<HashMap<String, String>>,
    pub declared_environment_fingerprints: Arc<HashMap<String, String>>,
    pub params_fingerprints: Arc<HashMap<String, String>>,
    pub command_fingerprints: Arc<HashMap<String, Option<String>>>,
    pub planner_contract_version: String,
    pub execution_fingerprint: String,
    pub evidence_fingerprint: String,
    pub execution_contract_fingerprint: String,
    pub resolved_params: HashMap<String, Value>,
    pub effective_cache_dir: Option<PathBuf>,
    pub fs: Arc<dyn Fs>,
    pub clock: Arc<dyn Clock>,
    pub store: ArtifactStore,
    pub policy: PolicyConfig,
    pub absolute_path_policy: AbsolutePathPolicy,
    pub cancellation_requested: Arc<AtomicBool>,
}

Expand description

Execution-scoped state shared across node adapter invocations for one run.

Fields§

§run_dir: Arc<RunDir>§replay_source_run_dir: Option<PathBuf>§graph_fingerprint: Arc<Mutex<HashMap<String, String>>>§node_definition_fingerprints: Arc<HashMap<String, String>>§declared_environment_fingerprints: Arc<HashMap<String, String>>§params_fingerprints: Arc<HashMap<String, String>>§command_fingerprints: Arc<HashMap<String, Option<String>>>§planner_contract_version: String§execution_fingerprint: String§evidence_fingerprint: String§execution_contract_fingerprint: String§resolved_params: HashMap<String, Value>§effective_cache_dir: Option<PathBuf>§fs: Arc<dyn Fs>§clock: Arc<dyn Clock>§store: ArtifactStore§policy: PolicyConfig§absolute_path_policy: AbsolutePathPolicy§cancellation_requested: Arc<AtomicBool>

Auto Trait Implementations§

§

RunContext

Struct RunContext Copy item path

Fields§

Auto Trait Implementations§

impl !RefUnwindSafe for RunContext

impl !UnwindSafe for RunContext

impl Freeze for RunContext

impl Send for RunContext

impl Sync for RunContext

impl Unpin for RunContext

impl UnsafeUnpin for RunContext

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct RunContext

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,