Skip to content

Commit e18946b

Browse files
committed
refactor: remove content hash handling from source executor options and streamline related logic
1 parent 8eccb07 commit e18946b

File tree

9 files changed

+257
-255
lines changed

9 files changed

+257
-255
lines changed

src/execution/dumper.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
use anyhow::Result;
2-
use futures::future::try_join_all;
32
use futures::StreamExt;
3+
use futures::future::try_join_all;
44
use indexmap::IndexMap;
55
use itertools::Itertools;
66
use serde::ser::SerializeSeq;
@@ -172,7 +172,6 @@ impl<'a> Dumper<'a> {
172172

173173
let mut rows_stream = import_op.executor.list(&SourceExecutorListOptions {
174174
include_ordinal: false,
175-
include_content_hash: false,
176175
});
177176
while let Some(rows) = rows_stream.next().await {
178177
for row in rows?.into_iter() {

src/execution/indexing_status.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,8 +37,7 @@ pub async fn get_source_row_indexing_status(
3737
&src_eval_ctx.key,
3838
&interface::SourceExecutorGetOptions {
3939
include_value: false,
40-
include_ordinal: false,
41-
include_content_hash: false,
40+
include_ordinal: true,
4241
},
4342
);
4443
let (last_processed, current) = try_join!(last_processed_fut, current_fut)?;

0 commit comments

Comments
 (0)