Skip to content

Commit fadfc76

Browse files
committed
fix: unit test
1 parent 5d1aad9 commit fadfc76

File tree

2 files changed

+1
-6
lines changed

2 files changed

+1
-6
lines changed

src/query/ee/tests/it/storages/fuse/operations/vacuum.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -313,13 +313,9 @@ mod test_accessor {
313313

314314
impl Access for AccessorFaultyDeletion {
315315
type Reader = ();
316-
type BlockingReader = ();
317316
type Writer = ();
318-
type BlockingWriter = ();
319317
type Lister = VecLister;
320-
type BlockingLister = ();
321318
type Deleter = MockDeleter;
322-
type BlockingDeleter = ();
323319

324320
fn info(&self) -> Arc<AccessorInfo> {
325321
let info = AccessorInfo::default();

src/query/storages/parquet/src/parquet_reader/row_group.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -550,8 +550,7 @@ mod test {
550550
let builder = Memory::default();
551551
let path = "/tmp/test/merged";
552552
let op = Operator::new(builder).unwrap().finish();
553-
let blocking_op = op.blocking();
554-
blocking_op.write(path, data).unwrap();
553+
op.write(path, data).await.unwrap();
555554

556555
let schema = Type::group_type_builder("schema")
557556
.with_repetition(Repetition::REPEATED)

0 commit comments

Comments
 (0)