diff --git a/metadata-ingestion/src/datahub/cli/iceberg_cli.py b/metadata-ingestion/src/datahub/cli/iceberg_cli.py index 5a39d4aeac58e..6ca5d63f1012e 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: "dataPlatform=iceberg", start: $start, count: $count} + input: {type: DATA_PLATFORM_INSTANCE, query: "dataPlatform:iceberg", start: $start, count: $count} ) { start total