pub struct AlmanacManifest {
pub schema_version: SchemaVersion,
pub command: String,
pub cadence: Cadence,
pub inputs: Vec<AlmanacTarget>,
pub outputs: Vec<AlmanacTarget>,
pub not_ready_policy: NotReadyPolicy,
pub invalidates: Vec<MeshIdent>,
}Expand description
kind = "almanac" manifest — a declared data-pipeline job.
An almanac job is the generalisation of the OpenRouter refresher
(spawn_almanac_refresher): it declares its I/O contract explicitly so
the orchestrator can enforce preconditions before each run and verify
outputs afterward. The degenerate case (no inputs, no app target, cron
schedule) is exactly the OpenRouter JSON-cache refresher.
Lifecycle:
- Cadence tick fires.
- Scheduler probes every
inputstarget. If any fail → applynot_ready_policy. - Command runs (
sh -c commandfrom the workload directory). - Scheduler probes every
outputstarget. Failure → mark run as failed but do not retry. - Any workloads listed in
invalidatesreceive a cache-bust signal (implementation detail of the orchestrator; in camp this is a rebuild trigger on the mesofact-dev watcher).
Fields§
§schema_version: SchemaVersionWire-format version. Always V1 today.
command: StringShell command executed via sh -c from the workload directory.
cadence: CadenceWhen to run.
inputs: Vec<AlmanacTarget>Input targets that must be reachable before the command runs. Empty list → no precondition checks (degenerate case).
outputs: Vec<AlmanacTarget>Output targets verified after a successful run. Empty list → no post-run verification.
not_ready_policy: NotReadyPolicyWhat to do when a precondition check fails.
Default: WaitWithTimeout { timeout: 5000ms }.
invalidates: Vec<MeshIdent>Mesh identities of workloads to notify after a successful run. The orchestrator sends a cache-bust signal to each entry so downstream consumers can reload their data (e.g. mesofact-dev triggers a rebuild when the OpenRouter cache refreshes). Empty list → no downstream invalidation.
Trait Implementations§
Source§impl Clone for AlmanacManifest
impl Clone for AlmanacManifest
Source§fn clone(&self) -> AlmanacManifest
fn clone(&self) -> AlmanacManifest
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for AlmanacManifest
impl Debug for AlmanacManifest
Source§impl<'de> Deserialize<'de> for AlmanacManifest
impl<'de> Deserialize<'de> for AlmanacManifest
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Source§impl PartialEq for AlmanacManifest
impl PartialEq for AlmanacManifest
Source§impl Serialize for AlmanacManifest
impl Serialize for AlmanacManifest
impl StructuralPartialEq for AlmanacManifest
Source§impl TS for AlmanacManifest
impl TS for AlmanacManifest
Source§type WithoutGenerics = AlmanacManifest
type WithoutGenerics = AlmanacManifest
WithoutGenerics should just be Self.
If the type does have generic parameters, then all generic parameters must be replaced with
a dummy type, e.g ts_rs::Dummy or (). The only requirement for these dummy types is that
EXPORT_TO must be None. Read moreSource§type OptionInnerType = AlmanacManifest
type OptionInnerType = AlmanacManifest
std::option::Option<T>, then this associated type is set to T.
All other implementations of TS should set this type to Self instead.Source§fn docs() -> Option<String>
fn docs() -> Option<String>
TS is derived, docs are
automatically read from your doc comments or #[doc = ".."] attributesSource§fn decl_concrete(cfg: &Config) -> String
fn decl_concrete(cfg: &Config) -> String
TS::decl().
If this type is not generic, then this function is equivalent to TS::decl().Source§fn decl(cfg: &Config) -> String
fn decl(cfg: &Config) -> String
type User = { user_id: number, ... }.
This function will panic if the type has no declaration. Read moreSource§fn inline(cfg: &Config) -> String
fn inline(cfg: &Config) -> String
{ user_id: number }.
This function will panic if the type cannot be inlined.Source§fn inline_flattened(cfg: &Config) -> String
fn inline_flattened(cfg: &Config) -> String
Source§fn visit_generics(v: &mut impl TypeVisitor)where
Self: 'static,
fn visit_generics(v: &mut impl TypeVisitor)where
Self: 'static,
Source§fn output_path() -> Option<PathBuf>
fn output_path() -> Option<PathBuf>
T should be exported, relative to the output directory.
The returned path does not include any base directory. Read moreSource§fn visit_dependencies(v: &mut impl TypeVisitor)where
Self: 'static,
fn visit_dependencies(v: &mut impl TypeVisitor)where
Self: 'static,
Source§fn dependencies(cfg: &Config) -> Vec<Dependency>where
Self: 'static,
fn dependencies(cfg: &Config) -> Vec<Dependency>where
Self: 'static,
Source§fn export(cfg: &Config) -> Result<(), ExportError>where
Self: 'static,
fn export(cfg: &Config) -> Result<(), ExportError>where
Self: 'static,
TS::export_all. Read moreSource§fn export_all(cfg: &Config) -> Result<(), ExportError>where
Self: 'static,
fn export_all(cfg: &Config) -> Result<(), ExportError>where
Self: 'static,
TS::export. Read more