Function collect_with_empty_batch 

async fn collect_with_empty_batch(
    df: DataFrame,
) -> Result<Vec<RecordBatch>, ReadStatError>