agate_to_dict -> dbt_object_to_dict

Author: haritamar

macros/edr/dbt_artifacts/upload_dbt_invocation.sql

@@ -144,7 +144,7 @@
     {% set all_vars = {} %}
     {% set config = elementary.get_runtime_config() %}
     {%- if config.vars -%}
-        {% do all_vars.update(elementary.agate_to_dict(config.vars)) %}
+        {% do all_vars.update(elementary.dbt_object_to_dict(config.vars)) %}
     {%- endif -%}
     {% do all_vars.update(elementary.get_invocation_vars()) %}
     {{- return(all_vars) -}}

macros/utils/graph/get_run_result_dict.sql

@@ -3,13 +3,13 @@
     {% set major = major | int %}
     {% set minor = minor | int %}
     {% if major < 1 or major == 1 and minor < 8 %}
-        {% do return(elementary.agate_to_dict(run_result)) %}
+        {% do return(elementary.dbt_object_to_dict(run_result)) %}
     {% else %}
         {# There's a bug in dbt 1.8 which causes run_result.to_dict to fail on an exception #}
         {% set timing_dicts = [] %}
         {% if run_result.timing %}          
             {% for item in run_result.timing %}
-                {% do timing_dicts.append(elementary.agate_to_dict(item)) %}
+                {% do timing_dicts.append(elementary.dbt_object_to_dict(item)) %}
             {% endfor %}
         {% endif %}
 
@@ -20,7 +20,7 @@
             'failures': run_result.failures,
             'execution_time': run_result.execution_time,
             'timing': timing_dicts,
-            'node': elementary.agate_to_dict(run_result.node) if run_result.node else None,
+            'node': elementary.dbt_object_to_dict(run_result.node) if run_result.node else None,
             'thread_id': run_result.thread_id
         }) %}
     {% endif %}

…cros/utils/run_queries/agate_to_dict.sql …utils/run_queries/dbt_object_to_dict.sqlmacros/utils/run_queries/agate_to_dict.sql renamed to macros/utils/run_queries/dbt_object_to_dict.sql macros/utils/run_queries/agate_to_dict.sql renamed to macros/utils/run_queries/dbt_object_to_dict.sql

@@ -1,4 +1,4 @@
-{% macro agate_to_dict(agate_table) %}
+{% macro dbt_object_to_dict(agate_table) %}
   {% if elementary.is_dbt_fusion() %}
     {% do return(agate_table) %}
   {% endif %}