Get tests to pass

Author: clrcrl

.circleci/config.yml

@@ -25,7 +25,7 @@ jobs:
             . venv/bin/activate
 
             pip install --upgrade pip setuptools
-            pip install dbt
+            pip install dbt --pre
 
             mkdir -p ~/.dbt
             cp integration_tests/ci/sample.profiles.yml ~/.dbt/profiles.yml

integration_tests/data/sql/data_fetch.csv

@@ -1,4 +1,4 @@
 col_1,col_2,col_3
-1,a,4.0
-2,b,5.0
-3,c,
+1,a,4.1
+2,b,5.2
+3,c,

integration_tests/dbt_project.yml

@@ -4,8 +4,10 @@ version: '1.0'
 
 profile: 'integration_tests'
 
+require-dbt-version: ">=0.15.0"
+
 source-paths: ["models"]
-analysis-paths: ["analysis"] 
+analysis-paths: ["analysis"]
 test-paths: ["tests"]
 data-paths: ["data"]
 macro-paths: ["macros"]
@@ -14,23 +16,23 @@ target-path: "target"  # directory which will store compiled SQL files
 clean-targets:         # directories to be removed by `dbt clean`
     - "target"
     - "dbt_modules"
-    
+
 seeds:
     dbt_utils_integration_tests:
         enabled: true
-        
+
         cross_db:
             data_date_trunc:
                 column_types:
                     updated_at: timestamp
                     day: date
                     month: date
-        
+
             data_dateadd:
                 column_types:
                     from_time: timestamp
                     result: timestamp
-                    
+
             data_datediff:
                 column_types:
                     first_date: timestamp

integration_tests/tests/assert_fetch_objects_equal.sql

@@ -3,51 +3,29 @@
 {% set expected_dictionary={
     'col_1': [1, 2, 3],
     'col_2': ['a', 'b', 'c'],
-    'col_3': [4.0, 5.0, none]
+    'col_3': [4.1, 5.2, none]
 } %}
 
 {% set actual_dictionary=dbt_utils.fetch(
     "select * from " ~ ref('data_fetch')
 ) %}
 
-{% if target.type == 'snowflake' %}
-
-{% if actual_dictionary['COL_1'] | map('int',default=none) | list != expected_dictionary['col_1'] %}
- {# select > 0 rows for test to fail  #}
-    select 1
-
-{% elif actual_dictionary['COL_2'] | list != expected_dictionary['col_2']%}
- {# select > 0 rows for test to fail  #}
-    select 1
-
-{% elif actual_dictionary['COL_3'] | map('float',default=none) | list != expected_dictionary['col_3'] %}
- {# select > 0 rows for test to fail  #}
-    select 1
-
-{% else %}
- {# select 0 rows for test to pass  #}
-    select 1 limit 0
-
-{% endif %}
-
-{% else %}
-
-{% if actual_dictionary['col_1'] | map('int',default=none) | list != expected_dictionary['col_1'] %}
+{% if actual_dictionary['col_1'] | map('int', default=none) | list != expected_dictionary['col_1'] %}
  {# select > 0 rows for test to fail  #}
     select 1
 
 {% elif actual_dictionary['col_2'] | list != expected_dictionary['col_2']%}
  {# select > 0 rows for test to fail  #}
     select 1
 
-{% elif actual_dictionary['col_3']  | list != expected_dictionary['col_3'] %}
+{% elif actual_dictionary['col_3'] | map('float', default=none) | list != expected_dictionary['col_3'] %}
  {# select > 0 rows for test to fail  #}
     select 1
+    {{ log(actual_dictionary['col_3'] | map('float', default=none) | list, info=True) }}
+    {{ log(expected_dictionary['col_3'], info=True) }}
 
 {% else %}
  {# select 0 rows for test to pass  #}
     select 1 limit 0
 
 {% endif %}
-
-{% endif %}