diff --git a/metadata-ingestion/src/datahub/cli/iceberg_cli.py b/metadata-ingestion/src/datahub/cli/iceberg_cli.py index f26edf444b7810..6ca5d63f1012e1 100644 --- a/metadata-ingestion/src/datahub/cli/iceberg_cli.py +++ b/metadata-ingestion/src/datahub/cli/iceberg_cli.py @@ -645,7 +645,7 @@ def get_all_warehouses(client: DataHubGraph) -> Iterator[str]: graph_query = """ query getIcebergWarehouses($start: Int, $count: Int) { search( - input: {type: DATA_PLATFORM_INSTANCE, query: "*", start: $start, count: $count} + input: {type: DATA_PLATFORM_INSTANCE, query: "dataPlatform:iceberg", start: $start, count: $count} ) { start total