[COST-4750] Fix regression caused by bad cast in trino (#4977)

project-koku · Mar 15, 2024 · 4f12cbc · 4f12cbc
1 parent 9a88d07
commit 4f12cbc
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/koku/masu/database/trino_sql/reporting_ocpusagelineitem_daily_summary.sql b/koku/masu/database/trino_sql/reporting_ocpusagelineitem_daily_summary.sql
@@ -261,8 +261,8 @@ FROM (
         max(cat_ns.cost_category_id) as cost_category_id,
         li.source as source_uuid,
         map_concat(
-            cast(coalesce(nli.node_labels, CAST('{}' AS JSON)) as map(varchar, varchar)),
-            cast(coalesce(nsli.namespace_labels, CAST('{}' AS JSON)) as map(varchar, varchar)),
+            cast(coalesce(nli.node_labels, cast(map(array[], array[]) as json)) as map(varchar, varchar)),
+            cast(coalesce(nsli.namespace_labels, cast(map(array[], array[]) as json)) as map(varchar, varchar)),
             map_filter(
                 cast(json_parse(li.pod_labels) AS MAP(VARCHAR, VARCHAR)),
                 (k, v) -> CONTAINS(pek.keys, k)
@@ -385,8 +385,8 @@ FROM (
         sli.storageclass,
         date(sli.interval_start) as usage_start,
         map_concat(
-            cast(coalesce(nli.node_labels, CAST('{}' AS JSON)) as map(varchar, varchar)),
-            cast(coalesce(nsli.namespace_labels, CAST('{}' AS JSON)) as map(varchar, varchar)),
+            cast(coalesce(nli.node_labels, cast(map(array[], array[]) as json)) as map(varchar, varchar)),
+            cast(coalesce(nsli.namespace_labels, cast(map(array[], array[]) as json)) as map(varchar, varchar)),
             map_filter(
                 cast(json_parse(sli.persistentvolume_labels) AS MAP(VARCHAR, VARCHAR)),
                 (k, v) -> CONTAINS(pek.keys, k)