diff --git a/models/intermediate/trades/int_trade_agg_day.sql b/models/intermediate/trades/int_trade_agg_day.sql index 15e8867..c1f5cdb 100644 --- a/models/intermediate/trades/int_trade_agg_day.sql +++ b/models/intermediate/trades/int_trade_agg_day.sql @@ -23,6 +23,7 @@ with , price_d , selling_amount , buying_amount + , CURRENT_TIMESTAMP as now from {{ ref('stg_history_trades') }} where ledger_closed_at < timestamp_add(timestamp_trunc('{{ dbt_airflow_macros.ts() }}', day), interval 1 day )