MCPcopy Create free account
hub / github.com/apache/datafusion / on_error_scanning_fail

Function on_error_scanning_fail

datafusion/datasource/src/file_stream/mod.rs:432–444  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

430
431 #[tokio::test]
432 async fn on_error_scanning_fail() -> Result<()> {
433 let result = FileStreamTest::new()
434 .with_records(vec![make_partition(3), make_partition(2)])
435 .with_num_files(2)
436 .with_on_error(OnError::Fail)
437 .with_scan_errors(vec![1])
438 .result()
439 .await;
440
441 assert!(result.is_err());
442
443 Ok(())
444 }
445
446 #[tokio::test]
447 async fn on_error_opening_fail() -> Result<()> {

Callers

nothing calls this directly

Calls 6

newFunction · 0.85
resultMethod · 0.80
with_scan_errorsMethod · 0.80
with_num_filesMethod · 0.80
with_recordsMethod · 0.80
with_on_errorMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…