()
| 1035 | |
| 1036 | #[tokio::test] |
| 1037 | async fn test_write_empty_batch() { |
| 1038 | let file_io = test_file_io(); |
| 1039 | let table_path = "memory:/test_table_write_empty"; |
| 1040 | let table = test_table(&file_io, table_path); |
| 1041 | let mut table_write = TableWrite::new(&table, "test-user".to_string()).unwrap(); |
| 1042 | |
| 1043 | let batch = make_batch(vec![], vec![]); |
| 1044 | table_write.write_arrow_batch(&batch).await.unwrap(); |
| 1045 | |
| 1046 | let messages = table_write.prepare_commit().await.unwrap(); |
| 1047 | assert!(messages.is_empty()); |
| 1048 | } |
| 1049 | |
| 1050 | #[tokio::test] |
| 1051 | async fn test_prepare_commit_reusable() { |
nothing calls this directly
no test coverage detected