{% macro export_alerts(start_date, end_date, alerts_path=None, monitored_path=None) %} {% set alerts_query %} select type as {{ f2dq.quote_column('type') }}, model as {{ f2dq.quote_column('model') }}, message as {{ f2dq.quote_column('message') }}, value as {{ f2dq.quote_column('value') }}, {{ format_timestamp('time_window_end')}} as {{ f2dq.quote_column('time_window_end') }} from {{ ref('f2dq_alerts') }} where case when type = 'anomaly' then {{ in_date_window('time_window_end', start_date, end_date) }} else {{ in_date_window('time_window_end', start_date, none) }} end order by time_window_end desc {% endset %} {% set query_result = run_query(alerts_query) %} {% set alerts_file_path = alerts_path or 'target/f2dq/alerts.json' %} {% do query_result.to_json(alerts_file_path) %} {{ save_monitored(monitored_path) }} {% endmacro %}