We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7ea85d0 commit 47154bdCopy full SHA for 47154bd
src/execution/indexing_status.rs
@@ -13,7 +13,7 @@ pub struct SourceRowLastProcessedInfo {
13
14
#[derive(Debug, Serialize)]
15
pub struct SourceRowInfo {
16
- pub ordinal: interface::Ordinal,
+ pub ordinal: Option<interface::Ordinal>,
17
}
18
19
@@ -57,9 +57,7 @@ pub async fn get_source_row_indexing_status(
57
.map_or(false, |fp| src_eval_ctx.plan.logic_fingerprint.matches(fp)),
58
});
59
let current = SourceRowInfo {
60
- ordinal: current
61
- .ordinal
62
- .ok_or(anyhow::anyhow!("Ordinal is unavailable for the source"))?,
+ ordinal: current.ordinal,
63
};
64
Ok(SourceRowIndexingStatus {
65
last_processed,
0 commit comments