diff --git a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/snowflake/SnowflakePlanner.java b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/snowflake/SnowflakePlanner.java
index 989e21b97..545a0595b 100644
--- a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/snowflake/SnowflakePlanner.java
+++ b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/snowflake/SnowflakePlanner.java
@@ -205,9 +205,24 @@ Task<?> warehouseEventsTask() {
   }
 
   Task<?> warehouseMeteringTask() {
-    String view = "SNOWFLAKE.ACCOUNT_USAGE.WAREHOUSE_METERING_HISTORY";
-    String query = String.format("SELECT warehouse_name, count(1) FROM %s GROUP BY ALL", view);
-    ImmutableList<String> header = ImmutableList.of("Name", "Count");
-    return new LiteTimeSeriesTask("warehouse_metering.csv", query, header);
+    ImmutableList<String> selectList =
+        ImmutableList.of(
+            "start_time",
+            "end_time",
+            "warehouse_name",
+            "credits_used_compute",
+            "credits_used_cloud_services");
+    String query =
+        String.format(
+            "SELECT %s FROM SNOWFLAKE.ACCOUNT_USAGE.WAREHOUSE_METERING_HISTORY",
+            String.join(", ", selectList));
+    ImmutableList<String> header =
+        ImmutableList.of(
+            "StartTime",
+            "EndTime",
+            "WarehouseName",
+            "CreditsUsedCompute",
+            "CreditsUsedCloudServices");
+    return new LiteTimeSeriesTask("warehouse_metering_lite.csv", query, header);
   }
 }