use source as test input

medic · Aug 24, 2024 · 167e8c5 · 167e8c5
1 parent 588c48a
commit 167e8c5
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 9 deletions.
diff --git a/models/root/document_metadata.sql b/models/root/document_metadata.sql
@@ -18,7 +18,7 @@ SELECT
   _deleted,
   saved_timestamp,
   doc->>'type' as doc_type
-FROM {{ env_var('POSTGRES_SCHEMA') }}.{{ env_var('POSTGRES_TABLE') }} source_table
+from {{ source('couchdb', env_var('POSTGRES_TABLE')) }} source_table
 {% if is_incremental() %}
 WHERE source_table.saved_timestamp >= {{ max_existing_timestamp('saved_timestamp') }}
 {% endif %}
diff --git a/models/root/tests/document_metadata.yml b/models/root/tests/document_metadata.yml
@@ -8,7 +8,7 @@ unit_tests:
       macros:
         is_incremental: false
     given:
-      - input: ref('test_source_table')
+      - input: source('couchdb', "{{ env_var('POSTGRES_TABLE') }}")
         format: csv
         fixture: contacts_test_source_table_input
     expect:

diff --git a/models/root/tests/test_source_table.sql b/models/root/tests/test_source_table.sql