diff --git a/crates/flowctl/src/catalog/mod.rs b/crates/flowctl/src/catalog/mod.rs index 7c62240921..0d2438e8bb 100644 --- a/crates/flowctl/src/catalog/mod.rs +++ b/crates/flowctl/src/catalog/mod.rs @@ -6,9 +6,13 @@ mod test; use crate::{ api_exec, api_exec_paginated, controlplane, output::{to_table_row, CliOutput, JsonCell}, + pagination::into_items, }; use anyhow::Context; -use futures::stream::{FuturesUnordered, StreamExt}; +use futures::{ + stream::{FuturesUnordered, StreamExt}, + TryStreamExt, +}; use itertools::Itertools; use models::{CatalogType, RawValue}; use serde::{Deserialize, Serialize}; @@ -260,7 +264,7 @@ where let builder = builder.clone().in_("catalog_name", batch); async move { // No need for pagination because we're paginating the inputs. - api_exec::>(builder).await + into_items::(builder).try_collect::>().await } }) .collect::>();