Skip to main content

JobGraphFactory

Type Alias JobGraphFactory 

Source
pub type JobGraphFactory = dyn Fn(JobContext) -> StreamResult<RunnableGraph<JobMat>> + Send + Sync + 'static;
Expand description

Factory used by JobSpec to build a fresh job blueprint for one generation.

The factory receives a JobContext containing the generation identity and an agent-owned SharedKillSwitch. The factory should build a RunnableGraph<JobMat> and should not materialize it.