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

Function on_error_opening_fail

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

Source from the content-addressed store, hash-verified

445
446 #[tokio::test]
447 async fn on_error_opening_fail() -> Result<()> {
448 let result = FileStreamTest::new()
449 .with_records(vec![make_partition(3), make_partition(2)])
450 .with_num_files(2)
451 .with_on_error(OnError::Fail)
452 .with_open_errors(vec![1])
453 .result()
454 .await;
455
456 assert!(result.is_err());
457
458 Ok(())
459 }
460
461 #[tokio::test]
462 async fn on_error_scanning() -> Result<()> {

Callers

nothing calls this directly

Calls 6

newFunction · 0.85
resultMethod · 0.80
with_open_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…