RecomputeJobSnapshot
Namespace: Meshmakers.Octo.Runtime.Contracts.StreamData
Read/write snapshot of a RecomputeJob entity (AB#4184) — the persistent history record of
one recompute run, carrying enough context to debug a failed recompute after the fact. Stores
translate between this record and their concrete entity representation. All timestamps are UTC.
public record RecomputeJobSnapshot : IEquatable<RecomputeJobSnapshot>
Inheritance Object → RecomputeJobSnapshot
Implements IEquatable<RecomputeJobSnapshot>
Properties
RtId
Runtime id of the job entity. for a not-yet-persisted job that IRecomputeJobStore.CreateAsync(RecomputeJobSnapshot) is about to assign an id to.
public OctoObjectId RtId { get; set; }
Property Value
OctoObjectId
ArchiveRtId
The archive this job recomputed.
public OctoObjectId ArchiveRtId { get; set; }
Property Value
OctoObjectId
State
Current lifecycle state.
public RecomputeJobState State { get; set; }
Property Value
Trigger
What initiated the run.
public RecomputeTrigger Trigger { get; set; }
Property Value
RangeStart
Inclusive start of the recomputed range.
public DateTime RangeStart { get; set; }
Property Value
RangeEnd
Exclusive end of the recomputed range.
public DateTime RangeEnd { get; set; }
Property Value
RtIdScope
Optional single rtId the run was scoped to; null means all rtIds.
public Nullable<OctoObjectId> RtIdScope { get; set; }
Property Value
RowsProcessed
Rows written into the staging table; null until known.
public Nullable<int> RowsProcessed { get; set; }
Property Value
WindowsProcessed
Buckets recomputed; null until known.
public Nullable<int> WindowsProcessed { get; set; }
Property Value
StartedAt
When compute started; null while pending.
public Nullable<DateTime> StartedAt { get; set; }
Property Value
FinishedAt
When the job reached a terminal state; null while running.
public Nullable<DateTime> FinishedAt { get; set; }
Property Value
DurationMs
Wall-clock duration in ms; null while running.
public Nullable<int> DurationMs { get; set; }
Property Value
ErrorReason
Failure reason when RecomputeJobSnapshot.State is Failed; null otherwise.
public string ErrorReason { get; set; }
Property Value
StagingTableName
Per-job staging table name, for post-mortem; null once swept.
public string StagingTableName { get; set; }
Property Value
Constructors
RecomputeJobSnapshot(OctoObjectId, OctoObjectId, RecomputeJobState, RecomputeTrigger, DateTime, DateTime, Nullable<OctoObjectId>, Nullable<Int32>, Nullable<Int32>, Nullable<DateTime>, Nullable<DateTime>, Nullable<Int32>, String, String)
Read/write snapshot of a RecomputeJob entity (AB#4184) — the persistent history record of
one recompute run, carrying enough context to debug a failed recompute after the fact. Stores
translate between this record and their concrete entity representation. All timestamps are UTC.
public RecomputeJobSnapshot(OctoObjectId RtId, OctoObjectId ArchiveRtId, RecomputeJobState State, RecomputeTrigger Trigger, DateTime RangeStart, DateTime RangeEnd, Nullable<OctoObjectId> RtIdScope, Nullable<int> RowsProcessed, Nullable<int> WindowsProcessed, Nullable<DateTime> StartedAt, Nullable<DateTime> FinishedAt, Nullable<int> DurationMs, string ErrorReason, string StagingTableName)
Parameters
RtId OctoObjectId
Runtime id of the job entity. for a not-yet-persisted job that
IRecomputeJobStore.CreateAsync(RecomputeJobSnapshot) is about to assign an id to.
ArchiveRtId OctoObjectId
The archive this job recomputed.
State RecomputeJobState
Current lifecycle state.
Trigger RecomputeTrigger
What initiated the run.
RangeStart DateTime
Inclusive start of the recomputed range.
RangeEnd DateTime
Exclusive end of the recomputed range.
RtIdScope Nullable<OctoObjectId>
Optional single rtId the run was scoped to; null means all rtIds.
RowsProcessed Nullable<Int32>
Rows written into the staging table; null until known.
WindowsProcessed Nullable<Int32>
Buckets recomputed; null until known.
StartedAt Nullable<DateTime>
When compute started; null while pending.
FinishedAt Nullable<DateTime>
When the job reached a terminal state; null while running.
DurationMs Nullable<Int32>
Wall-clock duration in ms; null while running.
ErrorReason String
Failure reason when RecomputeJobSnapshot.State is Failed; null otherwise.
StagingTableName String
Per-job staging table name, for post-mortem; null once swept.