diff --git a/koku/reporting/provider/oci/models.py b/koku/reporting/provider/oci/models.py index 72ef61e95a..486d0f2c67 100644 --- a/koku/reporting/provider/oci/models.py +++ b/koku/reporting/provider/oci/models.py @@ -29,6 +29,8 @@ TRINO_LINE_ITEM_TABLE_MAP = {"cost": "oci_cost_line_items", "usage": "oci_usage_line_items"} TRINO_LINE_ITEM_DAILY_TABLE_MAP = {"cost": "oci_cost_line_items_daily", "usage": "oci_usage_line_items_daily"} +# These defaults need to match the numeric & date columns in OCIReportParquetProcessor +# because that is how we build the trino schema TRINO_REQUIRED_COLUMNS = { "lineItem/referenceNo": "", "lineItem/tenantId": "", @@ -42,17 +44,17 @@ "product/availabilityDomain": "", "product/resourceId": "", "usage/consumedQuantity": 0.0, - "usage/billedQuantity": 0.0, - "usage/billedQuantityOverage": 0.0, + "usage/billedQuantity": "", + "usage/billedQuantityOverage": "", "usage/consumedQuantityUnits": "", "usage/consumedQuantityMeasure": "", "cost/subscriptionId": "", "cost/productSku": "", "product/Description": "", - "cost/unitPrice": 0.0, - "cost/unitPriceOverage": 0.0, + "cost/unitPrice": "", + "cost/unitPriceOverage": "", "cost/myCost": 0.0, - "cost/myCostOverage": 0.0, + "cost/myCostOverage": "", "cost/currencyCode": "", "cost/billingUnitReadable": "", "cost/skuUnitDescription": "",