Skip to content

Commit 0845fe9

Browse files
committed
Fix get catalog await
1 parent 3e6779e commit 0845fe9

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

crates/integrations/datafusion/tests/integration_datafusion_test.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -440,7 +440,7 @@ async fn test_metadata_table() -> Result<()> {
440440

441441
#[tokio::test]
442442
async fn test_insert_into() -> Result<()> {
443-
let iceberg_catalog = get_iceberg_catalog();
443+
let iceberg_catalog = get_iceberg_catalog().await;
444444
let namespace = NamespaceIdent::new("test_insert_into".to_string());
445445
set_test_namespace(&iceberg_catalog, &namespace).await?;
446446

@@ -553,7 +553,7 @@ fn get_nested_struct_type() -> StructType {
553553

554554
#[tokio::test]
555555
async fn test_insert_into_nested() -> Result<()> {
556-
let iceberg_catalog = get_iceberg_catalog();
556+
let iceberg_catalog = get_iceberg_catalog().await;
557557
let namespace = NamespaceIdent::new("test_insert_nested".to_string());
558558
set_test_namespace(&iceberg_catalog, &namespace).await?;
559559
let table_name = "nested_table";

0 commit comments

Comments
 (0)