Fix linting

Author: NiallRees

models/cost_per_query.sql

@@ -28,7 +28,7 @@ filtered_queries as (
         query_acceleration_bytes_scanned
     from {{ ref('stg_query_history') }}
     where true
-        and end_time <= (select latest_ts from stop_threshold)
+        and end_time <= (select stop_threshold.latest_ts from stop_threshold)
         {% if is_incremental() %}
         -- account for late arriving queries
         and end_time > (select coalesce(dateadd(day, -3, max(end_time)), '1970-01-01') from {{ this }})
@@ -39,7 +39,8 @@ hours_list as (
     select
         dateadd(
             'hour',
-            '-' || row_number() over (order by seq4() asc),
+            '-' || row_number() over (
+order by seq4() asc),
             dateadd('day', '+1', current_date::timestamp_tz)
         ) as hour_start,
         dateadd('hour', '+1', hour_start) as hour_end

models/daily_rates.sql

@@ -64,7 +64,8 @@ latest_remaining_balance_daily as (
         remaining_balance,
         is_account_in_overage
     from remaining_balance_daily
-    qualify row_number() over (order by date desc) = 1
+    qualify row_number() over (
+order by date desc) = 1
 ),
 
 rate_sheet_daily as (
@@ -80,7 +81,7 @@ rates_date_range_w_usage_types as (
         date_range.end_date,
         usage_types.usage_type
     from date_range
-    cross join (select distinct usage_type from rate_sheet_daily) as usage_types
+    cross join (select distinct rate_sheet_daily.usage_type from rate_sheet_daily) as usage_types
 ),
 
 base as (
@@ -98,18 +99,24 @@ rates_w_overage as (
         base.usage_type,
         coalesce(
             rate_sheet_daily.service_type,
-            lag(rate_sheet_daily.service_type) ignore nulls over (partition by base.usage_type order by base.date),
-            lead(rate_sheet_daily.service_type) ignore nulls over (partition by base.usage_type order by base.date)
+            lag(rate_sheet_daily.service_type) ignore nulls over (partition by base.usage_type
+order by base.date),
+            lead(rate_sheet_daily.service_type) ignore nulls over (partition by base.usage_type
+order by base.date)
         ) as service_type,
         coalesce(
             rate_sheet_daily.effective_rate,
-            lag(rate_sheet_daily.effective_rate) ignore nulls over (partition by base.usage_type order by base.date),
-            lead(rate_sheet_daily.effective_rate) ignore nulls over (partition by base.usage_type order by base.date)
+            lag(rate_sheet_daily.effective_rate) ignore nulls over (partition by base.usage_type
+order by base.date),
+            lead(rate_sheet_daily.effective_rate) ignore nulls over (partition by base.usage_type
+order by base.date)
         ) as effective_rate,
         coalesce(
             rate_sheet_daily.currency,
-            lag(rate_sheet_daily.currency) ignore nulls over (partition by base.usage_type order by base.date),
-            lead(rate_sheet_daily.currency) ignore nulls over (partition by base.usage_type order by base.date)
+            lag(rate_sheet_daily.currency) ignore nulls over (partition by base.usage_type
+order by base.date),
+            lead(rate_sheet_daily.currency) ignore nulls over (partition by base.usage_type
+order by base.date)
         ) as currency,
         base.usage_type like 'overage-%' as is_overage_rate,
         replace(base.usage_type, 'overage-', '') as associated_usage_type,
@@ -139,7 +146,8 @@ rates as (
         currency,
         is_overage_rate
     from rates_w_overage
-    qualify row_number() over (partition by date, service_type, associated_usage_type order by rate_priority desc) = 1
+    qualify row_number() over (partition by date, service_type, associated_usage_type
+order by rate_priority desc) = 1
 )
 
 select
@@ -149,6 +157,7 @@ select
     effective_rate,
     currency,
     is_overage_rate,
-    row_number() over (partition by service_type, associated_usage_type order by date desc) = 1 as is_latest_rate
+    row_number() over (partition by service_type, associated_usage_type
+order by date desc) = 1 as is_latest_rate
 from rates
 order by date

models/query_direct_object_access.sql

@@ -54,7 +54,9 @@ with
         group by 1, 2, 3, 4, 5, 6
     )
 
-select md5(concat(query_id, object_name)) as _unique_id, *
+select
+md5(concat(query_id, object_name)) as _unique_id,
+*
 from access_history_flattened_w_columns
 qualify -- added by affinaquest to ensure uniqueness
     row_number() over (

models/query_history_enriched.sql

@@ -144,7 +144,7 @@ select
     cost_per_query.currency,
     query_history.query_retry_time as query_retry_time_ms,
     query_history.query_retry_time / 1000 as query_retry_time_s,
-    query_history.query_retry_cause as query_retry_cause,
+    query_history.query_retry_cause,
     query_history.fault_handling_time as fault_handling_time_ms,
     query_history.fault_handling_time / 1000 as fault_handling_time_s
 

models/remaining_balance_daily_without_contract_view.sql

@@ -13,4 +13,5 @@ from {{ ref('stg_remaining_balance_daily') }}
     Assume the higher contract_number is more recent. Chose not to group by date and aggregate balances in
     case the currency changes..
 #}
-qualify row_number() over (partition by date order by contract_number desc nulls last) = 1
+qualify row_number() over (partition by date
+order by contract_number desc nulls last) = 1

models/staging/stg_serverless_task_history.sql

@@ -1,7 +1,7 @@
 {{ config(
     materialized='incremental',
     unique_key=['start_time', 'task_id'],
-)  }}
+) }}
 
 select
     start_time,

models/warehouses_type2_dimension.sql

@@ -12,8 +12,10 @@ warehouse_snapshots_base as (
         warehouse_size,
         warehouse_name,
         start_time as timestamp,
-        lag(warehouse_size) over (partition by warehouse_id order by start_time) as prev_warehouse_size,
-        lag(warehouse_name) over (partition by warehouse_id order by start_time) as prev_warehouse_name
+        lag(warehouse_size) over (partition by warehouse_id
+order by start_time) as prev_warehouse_size,
+        lag(warehouse_name) over (partition by warehouse_id
+order by start_time) as prev_warehouse_name
     from {{ ref('stg_query_history') }}
     where
         warehouse_size is not null
@@ -25,7 +27,8 @@ warehouse_snapshots as (
         warehouse_name,
         warehouse_size,
         timestamp as valid_from,
-        lead(timestamp) over (partition by warehouse_id order by timestamp) as _valid_to
+        lead(timestamp) over (partition by warehouse_id
+order by timestamp) as _valid_to
     from warehouse_snapshots_base
     where
         warehouse_size != coalesce(prev_warehouse_size, '')