ProtectedconstructorStaticInstanceProtectedAttemptedWhether a backfill run attempted every record: it completed, or it ended Failed (a failed record) after
processing every record. A failed run of no records failed before the first record.
ProtectedBackfillThe one backfill of a changed version: over the named records, without the watermark skip (a watermark written
before the change would skip records that need a value under this version). Only a run that attempted every
record with no failure marks the version backfilled; any other run is recorded error and its unfinished records
are retried on the next pass. Deferred (held) while another run of the pipeline is running. The lease is renewed
on a timer while the run is awaited, so its cadence does not depend on how long a batch takes.
ProtectedEvaluateRuns the golden-set test once per version and golden-set content; an earlier run since then is recorded held,
so an evaluation that cannot complete is not repeated every pass.
ProtectedEvaluationThe latest run of the golden-set test since the plan's date or the test's last change, whichever is later, if any. Expects the test engine configured.
The Global Object Store is a place to store global objects that need to be shared across the application. Depending on the execution environment, this could be the window object in a browser, or the global object in a node environment, or something else in other contexts. The key here is that in some cases static variables are not truly shared because it is possible that a given class might have copies of its code in multiple paths in a deployed application. This approach ensures that no matter how many code copies might exist, there is only one instance of the object in question by using the Global Object Store.
ProtectedLoadLoads a single Active Infer Record Process by ID.
ProtectedLoadProtectedOutcomeAn outcome row for a pipeline.
ProtectedPlanThe registry's plan for the pipeline's current pin (registers a new pin as a Candidate).
ProtectedRunningThe non-dry run of the pipeline still in progress, if any: the most recently checkpointed Running run, read
fresh. One not checkpointed within STALE_RUN_MS (so neither is any other) is stale: warned and ignored.
One pass. A pipeline that throws is recorded as error; the others still run.
ProtectedStewardAt most one evaluation and one backfill per pipeline per pass: an evaluation re-plans (a passing version moves
on to its backfill; a failing one is recorded held or refused). One processor serves every plan of the pass,
so the pipeline's lookup constraints are read once.
Runs one steward pass for a single Active Infer Record Process by ID.
A pipeline that is missing or throws is recorded as an error outcome.
Protected StaticgetReturns the singleton instance of the class. If the instance does not exist, it is created and stored in the Global Object Store. If className is provided it will be used as part of the key in the Global Object Store, otherwise the actual class name will be used. NOTE: the class name used by default is the lowest level of the object hierarchy, so if you have a class that extends another class, the lowest level class name will be used.
OptionalclassName: string
The steward of Feature Pipeline version changes.
A version is marked backfilled only by a run in which every named record was attempted and none failed; the next pass re-selects the records whose latest value is still under another version, so it retries exactly the failed ones. A record that fails permanently therefore keeps its version unbackfilled (the executor's circuit breaker covers a systematic failure). A backfill is deferred while another non-dry run of the pipeline is still running, so two runs never write the same scope at once; a
Runningrun not checkpointed for 30 minutes is stale and ignored.