RollupRecomputeJobInfoDto
Namespace: Meshmakers.Octo.Sdk.ServiceClient.AssetRepositoryServices.StreamData
SDK projection of a recompute job snapshot returned by IStreamDataServicesClient.RecomputeArchiveAsync(String, String, DateTime, DateTime, String) or IStreamDataServicesClient.ListRecomputeJobsForArchiveAsync(String, String). Mirrors the asset-repo REST payload exactly so the SDK layer stays a thin transport (AB#4184).
public record RollupRecomputeJobInfoDto : IEquatable<RollupRecomputeJobInfoDto>
Inheritance Object → RollupRecomputeJobInfoDto
Implements IEquatable<RollupRecomputeJobInfoDto>
Properties
RtId
Runtime id of the recompute job (string form of OctoObjectId).
public string RtId { get; set; }
Property Value
State
Job lifecycle state — Pending / Running / Swapping / Completed / Failed / Coalesced.
public string State { get; set; }
Property Value
RowsProcessed
Rows written into the staging table; null while pending.
public Nullable<int> RowsProcessed { get; set; }
Property Value
WindowsProcessed
Buckets recomputed; null while pending.
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 milliseconds; null while running.
public Nullable<int> DurationMs { get; set; }
Property Value
ErrorReason
Failure reason when RollupRecomputeJobInfoDto.State is Failed; null otherwise.
public string ErrorReason { get; set; }
Property Value
LastProgressAt
Heartbeat of a non-terminal job (AB#5189): stamped when it is created or starts computing and
after every committed chunk. A Running job whose heartbeat stops advancing is no longer
alive; after the server's stale-job timeout it is failed as "Presumed dead". Null on jobs
written before the field existed, and when talking to an older asset repository.
public Nullable<DateTime> LastProgressAt { get; set; }
Property Value
Remarks:
Deliberately an init property rather than a positional parameter, like
RollupArchiveInfoDto.Sources: appending one to the primary constructor would
change this record's constructor and Deconstruct signature, which breaks consumers
even though the parameter is optional. The addition is meant to be purely additive.
Constructors
RollupRecomputeJobInfoDto(String, String, Nullable<Int32>, Nullable<Int32>, Nullable<DateTime>, Nullable<DateTime>, Nullable<Int32>, String)
SDK projection of a recompute job snapshot returned by IStreamDataServicesClient.RecomputeArchiveAsync(String, String, DateTime, DateTime, String) or IStreamDataServicesClient.ListRecomputeJobsForArchiveAsync(String, String). Mirrors the asset-repo REST payload exactly so the SDK layer stays a thin transport (AB#4184).
public RollupRecomputeJobInfoDto(string RtId, string State, Nullable<int> RowsProcessed, Nullable<int> WindowsProcessed, Nullable<DateTime> StartedAt, Nullable<DateTime> FinishedAt, Nullable<int> DurationMs, string ErrorReason)
Parameters
RtId String
Runtime id of the recompute job (string form of OctoObjectId).
State String
Job lifecycle state — Pending / Running / Swapping / Completed / Failed / Coalesced.
RowsProcessed Nullable<Int32>
Rows written into the staging table; null while pending.
WindowsProcessed Nullable<Int32>
Buckets recomputed; null while pending.
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 milliseconds; null while running.
ErrorReason String
Failure reason when RollupRecomputeJobInfoDto.State is Failed; null otherwise.