Struct RunContext

pub struct RunContext<'a, InputT> {
    pub job_id: JobId,
    pub input: &'a InputT,
    pub data_set: &'a DataSet,
    pub schema_set: &'a SchemaSet,
    /* private fields */
}

Fields

job_id: JobId

input: &'a InputT

data_set: &'a DataSet

schema_set: &'a SchemaSet

Implementations

impl<'a, InputT> RunContext<'a, InputT>

pub fn warn<T: Into<String>>(&self, message: T)

pub fn error<T: Into<String>>(&self, message: T)

pub fn asset<T: Record>( &'a self, asset_id: AssetId, ) -> PipelineResult<T::Reader<'a>>

pub fn imported_data<T: Record>( &'a self, asset_id: AssetId, ) -> PipelineResult<T::Reader<'a>>

pub fn enqueue_job<JobProcessorT: JobProcessor>( &self, input: <JobProcessorT as JobProcessor>::InputT, ) -> PipelineResult<JobId>

pub fn produce_artifact<KeyT: Hash + Display, ArtifactT: TypeUuid + Serialize>( &self, asset_id: AssetId, artifact_key: Option<KeyT>, asset: ArtifactT, ) -> PipelineResult<AssetArtifactIdPair>

pub fn produce_artifact_with_handles<KeyT: Hash + Display, ArtifactT: TypeUuid + Serialize, F: FnOnce(HandleFactory<'_>) -> PipelineResult<ArtifactT>>( &self, asset_id: AssetId, artifact_key: Option<KeyT>, asset_fn: F, ) -> PipelineResult<ArtifactId>

pub fn produce_default_artifact<AssetT: TypeUuid + Serialize>( &self, asset_id: AssetId, asset: AssetT, ) -> PipelineResult<ArtifactId>

pub fn produce_default_artifact_with_handles<AssetT: TypeUuid + Serialize, F: FnOnce(HandleFactory<'_>) -> PipelineResult<AssetT>>( &self, asset_id: AssetId, asset_fn: F, ) -> PipelineResult<ArtifactId>

Trait Implementations

impl<'a, InputT: Clone> Clone for RunContext<'a, InputT>

fn clone(&self) -> RunContext<'a, InputT>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a, InputT: Copy> Copy for RunContext<'a, InputT>