fix event identifier

airbytehq · Aug 8, 2024 · 7ee4376 · 7ee4376
1 parent 0e352f1
commit 7ee4376
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 8 deletions.
diff --git a/connectors/source_amplitude/integration_tests/dbt_project.yml b/connectors/source_amplitude/integration_tests/dbt_project.yml
@@ -42,6 +42,5 @@ vars:
   amplitude_database: "airbyte_db_default"
   amplitude_schema: "airbyte_dbt_amplitude"
 
-  using_event_type: False
-
-  amplitude_event_identifier: "events"
+  amplitude_event_identifier: "event"
+  amplitude_event_type_identifier: "events_list"
diff --git a/connectors/source_amplitude/models/fivetran_converter/event.sql b/connectors/source_amplitude/models/fivetran_converter/event.sql
@@ -1,15 +1,15 @@
 WITH tmp AS (
     SELECT
-        $insert_id AS _insert_id,
-        $schema AS schema,
+        "$insert_id" AS _insert_id,
+        "$schema" AS "schema",
         adid AS ad_id,
         amplitude_id,
         app,
         city,
         client_event_time,
         client_upload_time,
         country,
-        data,
+        "data",
         device_brand,
         device_carrier,
         device_family,
@@ -27,7 +27,7 @@ WITH tmp AS (
         idfa,
         ip_address,
         is_attribution_event,
-        language,
+        "language",
         library,
         location_lat,
         location_lng,

diff --git a/connectors/source_amplitude/models/fivetran_converter/event.yml b/connectors/source_amplitude/models/fivetran_converter/event.yml
@@ -4,7 +4,7 @@ models:
   - name: event
     schema: "{{ var('airbyte_schema', target.schema) }}"
     database: "{{ var('airbyte_database', target.database) }}"
-    identifier: "{{ var('amplitude_event_identifier', 'events') }}"
+    identifier: "{{ var('amplitude_event_identifier', 'event') }}"
     description: All fields and field values associated with events.
     config:
       +enabled: "{{ var('using_fivetran_model', False) }}"