diff --git a/macros/get_activity_change_data_value_columns.sql b/macros/get_activity_change_data_value_columns.sql new file mode 100644 index 0000000..d59234e --- /dev/null +++ b/macros/get_activity_change_data_value_columns.sql @@ -0,0 +1,23 @@ +{% macro get_activity_change_data_value_columns() %} + +{% set columns = [ + {"name": "_fivetran_synced", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_type_id", "datatype": dbt_utils.type_int()}, + {"name": "api_method_name", "datatype": dbt_utils.type_string()}, + {"name": "campaign_id", "datatype": dbt_utils.type_int()}, + {"name": "id", "datatype": dbt_utils.type_string()}, + {"name": "lead_id", "datatype": dbt_utils.type_int()}, + {"name": "modifying_user", "datatype": dbt_utils.type_string()}, + {"name": "new_value", "datatype": dbt_utils.type_string()}, + {"name": "old_value", "datatype": dbt_utils.type_string()}, + {"name": "primary_attribute_value", "datatype": dbt_utils.type_string()}, + {"name": "primary_attribute_value_id", "datatype": dbt_utils.type_int()}, + {"name": "reason", "datatype": dbt_utils.type_string()}, + {"name": "request_id", "datatype": dbt_utils.type_string()}, + {"name": "source", "datatype": dbt_utils.type_string()} +] %} + +{{ return(columns) }} + +{% endmacro %} diff --git a/macros/get_activity_click_email_columns.sql b/macros/get_activity_click_email_columns.sql new file mode 100644 index 0000000..e948c86 --- /dev/null +++ b/macros/get_activity_click_email_columns.sql @@ -0,0 +1,27 @@ +{% macro get_activity_click_email_columns() %} + +{% set columns = [ + {"name": "_fivetran_synced", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_type_id", "datatype": dbt_utils.type_int()}, + {"name": "campaign_id", "datatype": dbt_utils.type_int()}, + {"name": "campaign_run_id", "datatype": dbt_utils.type_int()}, + {"name": "choice_number", "datatype": dbt_utils.type_int()}, + {"name": "device", "datatype": dbt_utils.type_string()}, + {"name": "email_template_id", "datatype": dbt_utils.type_int()}, + {"name": "id", "datatype": dbt_utils.type_string()}, + {"name": "is_mobile_device", "datatype": "boolean"}, + {"name": "lead_id", "datatype": dbt_utils.type_int()}, + {"name": "link", "datatype": dbt_utils.type_string()}, + {"name": "link_id", "datatype": dbt_utils.type_string()}, + {"name": "platform", "datatype": dbt_utils.type_string()}, + {"name": "primary_attribute_value", "datatype": dbt_utils.type_string()}, + {"name": "primary_attribute_value_id", "datatype": dbt_utils.type_int()}, + {"name": "step_id", "datatype": dbt_utils.type_int()}, + {"name": "test_variant", "datatype": dbt_utils.type_int()}, + {"name": "user_agent", "datatype": dbt_utils.type_string()} +] %} + +{{ return(columns) }} + +{% endmacro %} diff --git a/macros/get_activity_delete_lead_columns.sql b/macros/get_activity_delete_lead_columns.sql new file mode 100644 index 0000000..638c8e8 --- /dev/null +++ b/macros/get_activity_delete_lead_columns.sql @@ -0,0 +1,17 @@ +{% macro get_activity_delete_lead_columns() %} + +{% set columns = [ + {"name": "_fivetran_synced", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_type_id", "datatype": dbt_utils.type_int()}, + {"name": "campaign", "datatype": dbt_utils.type_string()}, + {"name": "campaign_id", "datatype": dbt_utils.type_int()}, + {"name": "id", "datatype": dbt_utils.type_string()}, + {"name": "lead_id", "datatype": dbt_utils.type_int()}, + {"name": "primary_attribute_value", "datatype": dbt_utils.type_string()}, + {"name": "primary_attribute_value_id", "datatype": dbt_utils.type_int()} +] %} + +{{ return(columns) }} + +{% endmacro %} diff --git a/macros/get_activity_email_bounced_columns.sql b/macros/get_activity_email_bounced_columns.sql new file mode 100644 index 0000000..f5d70ce --- /dev/null +++ b/macros/get_activity_email_bounced_columns.sql @@ -0,0 +1,25 @@ +{% macro get_activity_email_bounced_columns() %} + +{% set columns = [ + {"name": "_fivetran_synced", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_type_id", "datatype": dbt_utils.type_int()}, + {"name": "campaign_id", "datatype": dbt_utils.type_int()}, + {"name": "campaign_run_id", "datatype": dbt_utils.type_int()}, + {"name": "category", "datatype": dbt_utils.type_int()}, + {"name": "choice_number", "datatype": dbt_utils.type_int()}, + {"name": "details", "datatype": dbt_utils.type_string()}, + {"name": "email", "datatype": dbt_utils.type_string()}, + {"name": "email_template_id", "datatype": dbt_utils.type_int()}, + {"name": "id", "datatype": dbt_utils.type_string()}, + {"name": "lead_id", "datatype": dbt_utils.type_int()}, + {"name": "primary_attribute_value", "datatype": dbt_utils.type_string()}, + {"name": "primary_attribute_value_id", "datatype": dbt_utils.type_int()}, + {"name": "step_id", "datatype": dbt_utils.type_int()}, + {"name": "subcategory", "datatype": dbt_utils.type_int()}, + {"name": "test_variant", "datatype": dbt_utils.type_int()} +] %} + +{{ return(columns) }} + +{% endmacro %} diff --git a/macros/get_activity_email_delivered_columns.sql b/macros/get_activity_email_delivered_columns.sql new file mode 100644 index 0000000..1f572be --- /dev/null +++ b/macros/get_activity_email_delivered_columns.sql @@ -0,0 +1,21 @@ +{% macro get_activity_email_delivered_columns() %} + +{% set columns = [ + {"name": "_fivetran_synced", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_type_id", "datatype": dbt_utils.type_int()}, + {"name": "campaign_id", "datatype": dbt_utils.type_int()}, + {"name": "campaign_run_id", "datatype": dbt_utils.type_int()}, + {"name": "choice_number", "datatype": dbt_utils.type_int()}, + {"name": "email_template_id", "datatype": dbt_utils.type_int()}, + {"name": "id", "datatype": dbt_utils.type_string()}, + {"name": "lead_id", "datatype": dbt_utils.type_int()}, + {"name": "primary_attribute_value", "datatype": dbt_utils.type_string()}, + {"name": "primary_attribute_value_id", "datatype": dbt_utils.type_int()}, + {"name": "step_id", "datatype": dbt_utils.type_int()}, + {"name": "test_variant", "datatype": dbt_utils.type_int()} +] %} + +{{ return(columns) }} + +{% endmacro %} diff --git a/macros/get_activity_merge_leads_columns.sql b/macros/get_activity_merge_leads_columns.sql new file mode 100644 index 0000000..11c4427 --- /dev/null +++ b/macros/get_activity_merge_leads_columns.sql @@ -0,0 +1,20 @@ +{% macro get_activity_merge_leads_columns() %} + +{% set columns = [ + {"name": "_fivetran_synced", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_type_id", "datatype": dbt_utils.type_int()}, + {"name": "campaign_id", "datatype": dbt_utils.type_int()}, + {"name": "id", "datatype": dbt_utils.type_string()}, + {"name": "lead_id", "datatype": dbt_utils.type_int()}, + {"name": "master_updated", "datatype": "boolean"}, + {"name": "merge_ids", "datatype": dbt_utils.type_string()}, + {"name": "merge_source", "datatype": dbt_utils.type_string()}, + {"name": "merged_in_sales", "datatype": "boolean"}, + {"name": "primary_attribute_value", "datatype": dbt_utils.type_string()}, + {"name": "primary_attribute_value_id", "datatype": dbt_utils.type_int()} +] %} + +{{ return(columns) }} + +{% endmacro %} diff --git a/macros/get_activity_open_email_columns.sql b/macros/get_activity_open_email_columns.sql new file mode 100644 index 0000000..f9278b5 --- /dev/null +++ b/macros/get_activity_open_email_columns.sql @@ -0,0 +1,25 @@ +{% macro get_activity_open_email_columns() %} + +{% set columns = [ + {"name": "_fivetran_synced", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_type_id", "datatype": dbt_utils.type_int()}, + {"name": "campaign_id", "datatype": dbt_utils.type_int()}, + {"name": "campaign_run_id", "datatype": dbt_utils.type_int()}, + {"name": "choice_number", "datatype": dbt_utils.type_int()}, + {"name": "device", "datatype": dbt_utils.type_string()}, + {"name": "email_template_id", "datatype": dbt_utils.type_int()}, + {"name": "id", "datatype": dbt_utils.type_string()}, + {"name": "is_mobile_device", "datatype": "boolean"}, + {"name": "lead_id", "datatype": dbt_utils.type_int()}, + {"name": "platform", "datatype": dbt_utils.type_string()}, + {"name": "primary_attribute_value", "datatype": dbt_utils.type_string()}, + {"name": "primary_attribute_value_id", "datatype": dbt_utils.type_int()}, + {"name": "step_id", "datatype": dbt_utils.type_int()}, + {"name": "test_variant", "datatype": dbt_utils.type_int()}, + {"name": "user_agent", "datatype": dbt_utils.type_string()} +] %} + +{{ return(columns) }} + +{% endmacro %} diff --git a/macros/get_activity_send_email_columns.sql b/macros/get_activity_send_email_columns.sql new file mode 100644 index 0000000..953a0d0 --- /dev/null +++ b/macros/get_activity_send_email_columns.sql @@ -0,0 +1,21 @@ +{% macro get_activity_send_email_columns() %} + +{% set columns = [ + {"name": "_fivetran_synced", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_type_id", "datatype": dbt_utils.type_int()}, + {"name": "campaign_id", "datatype": dbt_utils.type_int()}, + {"name": "campaign_run_id", "datatype": dbt_utils.type_int()}, + {"name": "choice_number", "datatype": dbt_utils.type_int()}, + {"name": "email_template_id", "datatype": dbt_utils.type_int()}, + {"name": "id", "datatype": dbt_utils.type_string()}, + {"name": "lead_id", "datatype": dbt_utils.type_int()}, + {"name": "primary_attribute_value", "datatype": dbt_utils.type_string()}, + {"name": "primary_attribute_value_id", "datatype": dbt_utils.type_int()}, + {"name": "step_id", "datatype": dbt_utils.type_int()}, + {"name": "test_variant", "datatype": dbt_utils.type_int()} +] %} + +{{ return(columns) }} + +{% endmacro %} diff --git a/macros/get_activity_unsubscribe_email_columns.sql b/macros/get_activity_unsubscribe_email_columns.sql new file mode 100644 index 0000000..f42a1b2 --- /dev/null +++ b/macros/get_activity_unsubscribe_email_columns.sql @@ -0,0 +1,26 @@ +{% macro get_activity_unsubscribe_email_columns() %} + +{% set columns = [ + {"name": "_fivetran_synced", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "activity_type_id", "datatype": dbt_utils.type_int()}, + {"name": "campaign_id", "datatype": dbt_utils.type_int()}, + {"name": "campaign_run_id", "datatype": dbt_utils.type_int()}, + {"name": "client_ip_address", "datatype": dbt_utils.type_string()}, + {"name": "email_template_id", "datatype": dbt_utils.type_int()}, + {"name": "form_fields", "datatype": dbt_utils.type_string()}, + {"name": "id", "datatype": dbt_utils.type_string()}, + {"name": "lead_id", "datatype": dbt_utils.type_int()}, + {"name": "primary_attribute_value", "datatype": dbt_utils.type_string()}, + {"name": "primary_attribute_value_id", "datatype": dbt_utils.type_int()}, + {"name": "query_parameters", "datatype": dbt_utils.type_string()}, + {"name": "referrer_url", "datatype": dbt_utils.type_string()}, + {"name": "test_variant", "datatype": dbt_utils.type_int()}, + {"name": "user_agent", "datatype": dbt_utils.type_string()}, + {"name": "webform_id", "datatype": dbt_utils.type_int()}, + {"name": "webpage_id", "datatype": dbt_utils.type_int()} +] %} + +{{ return(columns) }} + +{% endmacro %} diff --git a/macros/get_campaign_columns.sql b/macros/get_campaign_columns.sql new file mode 100644 index 0000000..e1fb991 --- /dev/null +++ b/macros/get_campaign_columns.sql @@ -0,0 +1,19 @@ +{% macro get_campaign_columns() %} + +{% set columns = [ + {"name": "_fivetran_synced", "datatype": dbt_utils.type_timestamp()}, + {"name": "active", "datatype": "boolean"}, + {"name": "created_at", "datatype": dbt_utils.type_timestamp()}, + {"name": "description", "datatype": dbt_utils.type_string()}, + {"name": "id", "datatype": dbt_utils.type_int()}, + {"name": "name", "datatype": dbt_utils.type_string()}, + {"name": "program_id", "datatype": dbt_utils.type_int()}, + {"name": "program_name", "datatype": dbt_utils.type_string()}, + {"name": "type", "datatype": dbt_utils.type_string()}, + {"name": "updated_at", "datatype": dbt_utils.type_timestamp()}, + {"name": "workspace_name", "datatype": dbt_utils.type_string()} +] %} + +{{ return(columns) }} + +{% endmacro %} diff --git a/macros/get_email_template_history_columns.sql b/macros/get_email_template_history_columns.sql new file mode 100644 index 0000000..b2ea461 --- /dev/null +++ b/macros/get_email_template_history_columns.sql @@ -0,0 +1,32 @@ +{% macro get_email_template_history_columns() %} + +{% set columns = [ + {"name": "_fivetran_synced", "datatype": dbt_utils.type_timestamp()}, + {"name": "created_at", "datatype": dbt_utils.type_timestamp()}, + {"name": "description", "datatype": dbt_utils.type_string()}, + {"name": "folder_folder_name", "datatype": dbt_utils.type_string()}, + {"name": "folder_id", "datatype": dbt_utils.type_int()}, + {"name": "folder_type", "datatype": dbt_utils.type_string()}, + {"name": "folder_value", "datatype": dbt_utils.type_int()}, + {"name": "from_email", "datatype": dbt_utils.type_string()}, + {"name": "from_name", "datatype": dbt_utils.type_string()}, + {"name": "id", "datatype": dbt_utils.type_int()}, + {"name": "name", "datatype": dbt_utils.type_string()}, + {"name": "operational", "datatype": "boolean"}, + {"name": "program_id", "datatype": dbt_utils.type_int()}, + {"name": "publish_to_msi", "datatype": "boolean"}, + {"name": "reply_email", "datatype": dbt_utils.type_string()}, + {"name": "status", "datatype": dbt_utils.type_string()}, + {"name": "subject", "datatype": dbt_utils.type_string()}, + {"name": "template", "datatype": dbt_utils.type_int()}, + {"name": "text_only", "datatype": "boolean"}, + {"name": "updated_at", "datatype": dbt_utils.type_timestamp()}, + {"name": "url", "datatype": dbt_utils.type_string()}, + {"name": "version", "datatype": dbt_utils.type_int()}, + {"name": "web_view", "datatype": "boolean"}, + {"name": "workspace", "datatype": dbt_utils.type_string()} +] %} + +{{ return(columns) }} + +{% endmacro %} diff --git a/macros/get_lead_columns.sql b/macros/get_lead_columns.sql new file mode 100644 index 0000000..3b37c1c --- /dev/null +++ b/macros/get_lead_columns.sql @@ -0,0 +1,714 @@ +{% macro get_lead_columns() %} + +{% set columns = [ + {"name": "_fivetran_synced", "datatype": dbt_utils.type_timestamp()}, + {"name": "abm_score_c", "datatype": dbt_utils.type_float()}, + {"name": "account_id_c", "datatype": dbt_utils.type_string()}, + {"name": "account_id_url_c", "datatype": dbt_utils.type_string()}, + {"name": "account_legal_name_c", "datatype": dbt_utils.type_string()}, + {"name": "account_level_c", "datatype": dbt_utils.type_string()}, + {"name": "account_notes_c", "datatype": dbt_utils.type_string()}, + {"name": "account_owner_email_c", "datatype": dbt_utils.type_string()}, + {"name": "account_owner_role_c", "datatype": dbt_utils.type_string()}, + {"name": "account_priority_c", "datatype": dbt_utils.type_string()}, + {"name": "account_signed_msa_c", "datatype": "boolean"}, + {"name": "account_source", "datatype": dbt_utils.type_string()}, + {"name": "account_status_c", "datatype": dbt_utils.type_string()}, + {"name": "acquisition_program_id", "datatype": dbt_utils.type_int()}, + {"name": "active_ft_accounts_c", "datatype": dbt_utils.type_int()}, + {"name": "active_in_sequence_c", "datatype": "boolean"}, + {"name": "active_relationship_c", "datatype": "boolean"}, + {"name": "actual_daily_burn_c", "datatype": dbt_utils.type_float()}, + {"name": "ad_words_action_c", "datatype": dbt_utils.type_string()}, + {"name": "address", "datatype": dbt_utils.type_string()}, + {"name": "address_lead", "datatype": dbt_utils.type_string()}, + {"name": "adgroupid_c", "datatype": dbt_utils.type_int()}, + {"name": "ae_paired_csm_c", "datatype": dbt_utils.type_string()}, + {"name": "ae_paired_csm_user_id_c", "datatype": dbt_utils.type_string()}, + {"name": "affectlayer_affect_layer_notes_c", "datatype": dbt_utils.type_string()}, + {"name": "affectlayer_affect_layer_notes_c_account", "datatype": dbt_utils.type_string()}, + {"name": "allbound_id_c", "datatype": dbt_utils.type_int()}, + {"name": "allbound_id_c_contact", "datatype": dbt_utils.type_int()}, + {"name": "allbound_partner_permissions_c", "datatype": dbt_utils.type_string()}, + {"name": "allbound_status_c", "datatype": dbt_utils.type_string()}, + {"name": "analytics_id_c_contact", "datatype": dbt_utils.type_string()}, + {"name": "annual_revenue", "datatype": dbt_utils.type_float()}, + {"name": "anonymous_ip", "datatype": dbt_utils.type_string()}, + {"name": "assigned_ae_c", "datatype": dbt_utils.type_string()}, + {"name": "assigned_ae_id_c", "datatype": dbt_utils.type_string()}, + {"name": "assigned_ae_is_me_c", "datatype": dbt_utils.type_int()}, + {"name": "assigned_am_c", "datatype": dbt_utils.type_string()}, + {"name": "assigned_bdr_c", "datatype": dbt_utils.type_string()}, + {"name": "assigned_bdr_id_c", "datatype": dbt_utils.type_string()}, + {"name": "assigned_se_c", "datatype": dbt_utils.type_string()}, + {"name": "assigned_se_zendesk_c", "datatype": dbt_utils.type_string()}, + {"name": "assigned_tsm_c", "datatype": dbt_utils.type_string()}, + {"name": "associated_account_exec_c", "datatype": dbt_utils.type_string()}, + {"name": "attempting_contact_date_time_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "attended_event_c", "datatype": "boolean"}, + {"name": "auto_renewal_c", "datatype": "boolean"}, + {"name": "automated_communications_suspended_c", "datatype": "boolean"}, + {"name": "automation_tracking_c", "datatype": dbt_utils.type_string()}, + {"name": "ava_blng_is_seller_importer_of_record_c", "datatype": "boolean"}, + {"name": "ava_mapper_exemption_number_c", "datatype": dbt_utils.type_int()}, + {"name": "ava_mapper_is_seller_importer_of_record_c", "datatype": "boolean"}, + {"name": "ava_sfcpq_ava_tax_message_c", "datatype": dbt_utils.type_string()}, + {"name": "ava_sfcpq_email_c", "datatype": dbt_utils.type_string()}, + {"name": "ava_sfcpq_is_seller_importer_of_record_c", "datatype": "boolean"}, + {"name": "bdr_priority_c", "datatype": dbt_utils.type_string()}, + {"name": "behavior_score_marketing", "datatype": dbt_utils.type_int()}, + {"name": "behavioral_score_c", "datatype": dbt_utils.type_int()}, + {"name": "behaviorally_qualified", "datatype": "boolean"}, + {"name": "bill_to_contact_hidden_c", "datatype": "boolean"}, + {"name": "billing_city", "datatype": dbt_utils.type_string()}, + {"name": "billing_contact_first_name_c", "datatype": dbt_utils.type_string()}, + {"name": "billing_contact_last_name_c", "datatype": dbt_utils.type_string()}, + {"name": "billing_country", "datatype": dbt_utils.type_string()}, + {"name": "billing_country_code", "datatype": dbt_utils.type_string()}, + {"name": "billing_email_c", "datatype": dbt_utils.type_string()}, + {"name": "billing_frequency_del_c", "datatype": dbt_utils.type_string()}, + {"name": "billing_postal_code", "datatype": dbt_utils.type_string()}, + {"name": "billing_state", "datatype": dbt_utils.type_string()}, + {"name": "billing_state_code", "datatype": dbt_utils.type_string()}, + {"name": "billing_street", "datatype": dbt_utils.type_string()}, + {"name": "black_listed", "datatype": "boolean"}, + {"name": "blng_bill_to_contact_c", "datatype": dbt_utils.type_string()}, + {"name": "blng_default_payment_type_c", "datatype": dbt_utils.type_string()}, + {"name": "bounce_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "bread_winner_bw_account_status_c", "datatype": dbt_utils.type_string()}, + {"name": "bread_winner_total_amount_credit_c", "datatype": dbt_utils.type_float()}, + {"name": "bread_winner_total_amount_due_c", "datatype": dbt_utils.type_float()}, + {"name": "bread_winner_total_amount_invoiced_c", "datatype": dbt_utils.type_float()}, + {"name": "bread_winner_total_amount_overdue_c", "datatype": dbt_utils.type_float()}, + {"name": "bread_winner_total_amount_paid_c", "datatype": dbt_utils.type_float()}, + {"name": "bread_winner_total_draft_amount_c", "datatype": dbt_utils.type_float()}, + {"name": "bread_winner_total_unallocated_credit_c", "datatype": dbt_utils.type_float()}, + {"name": "business_intelligence_tool_c", "datatype": dbt_utils.type_string()}, + {"name": "business_score_c", "datatype": dbt_utils.type_int()}, + {"name": "campaignid_c", "datatype": dbt_utils.type_string()}, + {"name": "case_study_c", "datatype": dbt_utils.type_string()}, + {"name": "case_study_marketing_use_c", "datatype": dbt_utils.type_string()}, + {"name": "cb_funding_raised_c", "datatype": dbt_utils.type_int()}, + {"name": "cbit_clearbit_c", "datatype": dbt_utils.type_string()}, + {"name": "cbit_clearbit_c_account", "datatype": dbt_utils.type_string()}, + {"name": "cbit_clearbit_domain_c", "datatype": dbt_utils.type_string()}, + {"name": "cbit_clearbit_ready_c", "datatype": "boolean"}, + {"name": "cbit_clearbit_ready_c_account", "datatype": "boolean"}, + {"name": "cbit_clearbit_ready_c_contact", "datatype": "boolean"}, + {"name": "cbit_created_by_clearbit_c", "datatype": "boolean"}, + {"name": "cbit_created_by_clearbit_c_account", "datatype": "boolean"}, + {"name": "cbit_facebook_c", "datatype": dbt_utils.type_string()}, + {"name": "cbit_linked_in_c", "datatype": dbt_utils.type_string()}, + {"name": "cbit_twitter_c", "datatype": dbt_utils.type_string()}, + {"name": "city", "datatype": dbt_utils.type_string()}, + {"name": "city_c", "datatype": dbt_utils.type_string()}, + {"name": "clarus_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "clarus_date_c_contact", "datatype": dbt_utils.type_timestamp()}, + {"name": "clarus_editor_c", "datatype": dbt_utils.type_string()}, + {"name": "clarus_editor_c_contact", "datatype": dbt_utils.type_string()}, + {"name": "clarus_notes_c", "datatype": dbt_utils.type_string()}, + {"name": "clarus_notes_c_contact", "datatype": dbt_utils.type_string()}, + {"name": "clarus_notes_c_lead", "datatype": dbt_utils.type_string()}, + {"name": "clarus_project_c", "datatype": dbt_utils.type_string()}, + {"name": "clarus_project_c_contact", "datatype": dbt_utils.type_string()}, + {"name": "clarus_status_c", "datatype": dbt_utils.type_string()}, + {"name": "clarus_status_c_contact", "datatype": dbt_utils.type_string()}, + {"name": "clawback_trigger_email_alert_c", "datatype": "boolean"}, + {"name": "clearbit_alexa_rank_global_c", "datatype": dbt_utils.type_int()}, + {"name": "clearbit_alexa_rank_us_c", "datatype": dbt_utils.type_int()}, + {"name": "clearbit_billing_city_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_billing_country_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_billing_state_province_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_billing_street_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_billing_zip_postal_code_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_company_type_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_country_code_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_enriched_at", "datatype": dbt_utils.type_timestamp()}, + {"name": "clearbit_form_status", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_founded_year_c", "datatype": dbt_utils.type_float()}, + {"name": "clearbit_industry_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_industry_group_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_province_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_raised_c", "datatype": dbt_utils.type_float()}, + {"name": "clearbit_risk_email_valid", "datatype": "boolean"}, + {"name": "clearbit_risk_risk_level", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_risk_risk_score", "datatype": dbt_utils.type_int()}, + {"name": "clearbit_role_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_sector_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_seniority_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_status", "datatype": dbt_utils.type_int()}, + {"name": "clearbit_sub_industry_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_tags_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_tech_category_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_technologies_c", "datatype": dbt_utils.type_string()}, + {"name": "clearbit_zip_c", "datatype": dbt_utils.type_string()}, + {"name": "cloudingo_agent_sas_c", "datatype": dbt_utils.type_int()}, + {"name": "company", "datatype": dbt_utils.type_string()}, + {"name": "company_country_c", "datatype": dbt_utils.type_string()}, + {"name": "company_postal_code_c", "datatype": dbt_utils.type_string()}, + {"name": "company_province_c", "datatype": dbt_utils.type_string()}, + {"name": "company_type_c", "datatype": dbt_utils.type_string()}, + {"name": "company_type_c_account", "datatype": dbt_utils.type_string()}, + {"name": "competitor_c", "datatype": "boolean"}, + {"name": "competitor_c_account", "datatype": "boolean"}, + {"name": "consumption_rate_c", "datatype": dbt_utils.type_float()}, + {"name": "contact_company", "datatype": dbt_utils.type_int()}, + {"name": "contact_stage_c", "datatype": dbt_utils.type_string()}, + {"name": "contact_status_c", "datatype": dbt_utils.type_string()}, + {"name": "contact_type_c", "datatype": dbt_utils.type_string()}, + {"name": "contract_renewal_45_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "contract_renewal_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "converted_date_time_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "cookies", "datatype": dbt_utils.type_string()}, + {"name": "count_of_accounts_c", "datatype": dbt_utils.type_int()}, + {"name": "countdown_to_end_of_contract_c", "datatype": dbt_utils.type_float()}, + {"name": "country", "datatype": dbt_utils.type_string()}, + {"name": "country_c", "datatype": dbt_utils.type_string()}, + {"name": "country_cc_c", "datatype": dbt_utils.type_string()}, + {"name": "country_code", "datatype": dbt_utils.type_string()}, + {"name": "country_code_c", "datatype": dbt_utils.type_string()}, + {"name": "created_at", "datatype": dbt_utils.type_timestamp()}, + {"name": "creative_c", "datatype": dbt_utils.type_string()}, + {"name": "credits_remaining_c", "datatype": dbt_utils.type_float()}, + {"name": "csi_code_c", "datatype": dbt_utils.type_int()}, + {"name": "csi_code_c_account", "datatype": dbt_utils.type_int()}, + {"name": "csi_description_c", "datatype": dbt_utils.type_string()}, + {"name": "csi_description_c_account", "datatype": dbt_utils.type_string()}, + {"name": "csi_description_del_c", "datatype": dbt_utils.type_string()}, + {"name": "current_fortune_rank_c", "datatype": dbt_utils.type_int()}, + {"name": "current_monthly_subscription_end_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "current_term_customer_value_c", "datatype": dbt_utils.type_float()}, + {"name": "customer_advocate_c", "datatype": dbt_utils.type_string()}, + {"name": "customer_advocate_notes_c", "datatype": dbt_utils.type_string()}, + {"name": "customer_health_engagement_score_c", "datatype": dbt_utils.type_int()}, + {"name": "customer_lifetime_value_c", "datatype": dbt_utils.type_float()}, + {"name": "customer_type_c", "datatype": dbt_utils.type_string()}, + {"name": "daily_credit_projected_burn_c", "datatype": dbt_utils.type_float()}, + {"name": "datawarehouse_used_c", "datatype": dbt_utils.type_string()}, + {"name": "datawarehouse_used_c_lead", "datatype": dbt_utils.type_string()}, + {"name": "date_time_formula_fields_changed_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "days_of_credits_remaining_c", "datatype": dbt_utils.type_float()}, + {"name": "days_since_created_c", "datatype": dbt_utils.type_float()}, + {"name": "days_since_last_manual_ae_activity_date_c", "datatype": dbt_utils.type_float()}, + {"name": "days_since_last_manual_bdr_activity_date_c", "datatype": dbt_utils.type_float()}, + {"name": "days_since_last_sales_activity_date_c", "datatype": dbt_utils.type_int()}, + {"name": "days_without_activity", "datatype": dbt_utils.type_int()}, + {"name": "db_created_date_without_time_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "db_lead_age_c", "datatype": dbt_utils.type_int()}, + {"name": "dbt_package_run_c", "datatype": dbt_utils.type_string()}, + {"name": "delete_text_area", "datatype": dbt_utils.type_string()}, + {"name": "deliveries_after_bounces", "datatype": dbt_utils.type_int()}, + {"name": "demandbase_city_c", "datatype": dbt_utils.type_string()}, + {"name": "demandbase_country_c", "datatype": dbt_utils.type_string()}, + {"name": "demandbase_general_fit_score_c", "datatype": dbt_utils.type_float()}, + {"name": "demandbase_number_of_employees_c", "datatype": dbt_utils.type_int()}, + {"name": "demandbase_overall_score_c", "datatype": dbt_utils.type_float()}, + {"name": "demandbase_sid_c", "datatype": dbt_utils.type_int()}, + {"name": "demandbase_state_c", "datatype": dbt_utils.type_string()}, + {"name": "demandbase_zip_c", "datatype": dbt_utils.type_int()}, + {"name": "demo_interest", "datatype": dbt_utils.type_string()}, + {"name": "demo_scheduled_by_calenderly_c", "datatype": "boolean"}, + {"name": "demographic_score_marketing", "datatype": dbt_utils.type_int()}, + {"name": "demographically_qualified", "datatype": "boolean"}, + {"name": "department", "datatype": dbt_utils.type_string()}, + {"name": "device_c", "datatype": dbt_utils.type_string()}, + {"name": "direct_office_c", "datatype": dbt_utils.type_string()}, + {"name": "district_c", "datatype": dbt_utils.type_string()}, + {"name": "do_not_call", "datatype": "boolean"}, + {"name": "do_not_call_reason", "datatype": dbt_utils.type_string()}, + {"name": "do_not_route_lead_c", "datatype": "boolean"}, + {"name": "do_not_sync_marketo_c", "datatype": "boolean"}, + {"name": "do_not_sync_marketo_c_account", "datatype": "boolean"}, + {"name": "domain_c", "datatype": dbt_utils.type_string()}, + {"name": "dozisf_zoom_info_id_c", "datatype": dbt_utils.type_int()}, + {"name": "drift_content_fulfillment", "datatype": dbt_utils.type_string()}, + {"name": "drift_cql_c", "datatype": dbt_utils.type_int()}, + {"name": "drift_cqlscore", "datatype": dbt_utils.type_float()}, + {"name": "drift_email_reply_text", "datatype": dbt_utils.type_string()}, + {"name": "drift_email_subject_line", "datatype": dbt_utils.type_string()}, + {"name": "drift_email_url", "datatype": dbt_utils.type_string()}, + {"name": "duns_number_c", "datatype": dbt_utils.type_int()}, + {"name": "email", "datatype": dbt_utils.type_string()}, + {"name": "email_bounce_category", "datatype": dbt_utils.type_int()}, + {"name": "email_bounce_details", "datatype": dbt_utils.type_string()}, + {"name": "email_bounced_c", "datatype": "boolean"}, + {"name": "email_bounced_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "email_bounced_reason", "datatype": dbt_utils.type_string()}, + {"name": "email_bounces", "datatype": dbt_utils.type_int()}, + {"name": "email_delivered_after_bounce", "datatype": dbt_utils.type_timestamp()}, + {"name": "email_domain_c", "datatype": dbt_utils.type_string()}, + {"name": "email_invalid", "datatype": "boolean"}, + {"name": "email_invalid_cause", "datatype": dbt_utils.type_string()}, + {"name": "email_opt_in", "datatype": "boolean"}, + {"name": "email_opt_in_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "email_opt_in_explicit_c", "datatype": "boolean"}, + {"name": "email_opt_in_implicit_c", "datatype": "boolean"}, + {"name": "email_quality_c", "datatype": "boolean"}, + {"name": "email_suspended", "datatype": "boolean"}, + {"name": "email_suspended_at", "datatype": dbt_utils.type_timestamp()}, + {"name": "email_suspended_cause", "datatype": dbt_utils.type_string()}, + {"name": "email_validation_c", "datatype": "boolean"}, + {"name": "employee_range_c", "datatype": dbt_utils.type_string()}, + {"name": "employee_range_c_lead", "datatype": dbt_utils.type_string()}, + {"name": "end_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "engagement_score_c", "datatype": dbt_utils.type_int()}, + {"name": "enrichment_request_c", "datatype": "boolean"}, + {"name": "enterprise_target_account_c", "datatype": "boolean"}, + {"name": "es_app_esalexa_rank_c", "datatype": dbt_utils.type_int()}, + {"name": "es_app_esaudience_names_c", "datatype": dbt_utils.type_string()}, + {"name": "es_app_escity_c", "datatype": dbt_utils.type_string()}, + {"name": "es_app_escompany_phone_c", "datatype": dbt_utils.type_string()}, + {"name": "es_app_escountry_c", "datatype": dbt_utils.type_string()}, + {"name": "es_app_escountry_c_account", "datatype": dbt_utils.type_string()}, + {"name": "es_app_escreated_timestamp_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "es_app_esemployees_c", "datatype": dbt_utils.type_string()}, + {"name": "es_app_esemployees_c_account", "datatype": dbt_utils.type_string()}, + {"name": "es_app_esenriched_c", "datatype": "boolean"}, + {"name": "es_app_esenriched_c_contact", "datatype": "boolean"}, + {"name": "es_app_esenriched_timestamp_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "es_app_esenriched_timestamp_c_contact", "datatype": dbt_utils.type_timestamp()}, + {"name": "es_app_esfacebook_c", "datatype": dbt_utils.type_string()}, + {"name": "es_app_esindustry_c", "datatype": dbt_utils.type_string()}, + {"name": "es_app_esintent_aggregate_score_c", "datatype": dbt_utils.type_int()}, + {"name": "es_app_esintent_timestamp_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "es_app_esintent_topics_c", "datatype": dbt_utils.type_string()}, + {"name": "es_app_eskeywords_c", "datatype": dbt_utils.type_string()}, + {"name": "es_app_eslinked_in_c", "datatype": dbt_utils.type_string()}, + {"name": "es_app_esrevenue_c", "datatype": dbt_utils.type_string()}, + {"name": "es_app_esrevenue_c_account", "datatype": dbt_utils.type_string()}, + {"name": "es_app_essource_c", "datatype": "boolean"}, + {"name": "es_app_essource_c_contact", "datatype": "boolean"}, + {"name": "es_app_esstate_c", "datatype": dbt_utils.type_string()}, + {"name": "es_app_esstreet_c", "datatype": dbt_utils.type_string()}, + {"name": "es_app_estwitter_c", "datatype": dbt_utils.type_string()}, + {"name": "es_app_eszipcode_c", "datatype": dbt_utils.type_string()}, + {"name": "es_general_fit_c", "datatype": dbt_utils.type_int()}, + {"name": "es_seniority_c", "datatype": dbt_utils.type_string()}, + {"name": "esraw_2_c", "datatype": dbt_utils.type_float()}, + {"name": "esraw_employee_size_c", "datatype": dbt_utils.type_int()}, + {"name": "estimated_annual_revenue_c", "datatype": dbt_utils.type_string()}, + {"name": "event_date_code", "datatype": dbt_utils.type_string()}, + {"name": "event_date_display", "datatype": dbt_utils.type_string()}, + {"name": "event_speaker_c", "datatype": dbt_utils.type_string()}, + {"name": "exclusive_ownership_c", "datatype": "boolean"}, + {"name": "exclusive_ownership_c_contact", "datatype": "boolean"}, + {"name": "expansion_score_c", "datatype": dbt_utils.type_int()}, + {"name": "external_id_c", "datatype": dbt_utils.type_string()}, + {"name": "fax", "datatype": dbt_utils.type_string()}, + {"name": "first_mql_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "first_name", "datatype": dbt_utils.type_string()}, + {"name": "first_won_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "fivetran_account_association_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "fivetran_account_id_c", "datatype": dbt_utils.type_string()}, + {"name": "fivetran_account_id_c_account", "datatype": dbt_utils.type_string()}, + {"name": "fivetran_account_name_c", "datatype": dbt_utils.type_string()}, + {"name": "fivetran_account_stage_c_account", "datatype": dbt_utils.type_string()}, + {"name": "fivetran_account_status_c", "datatype": dbt_utils.type_string()}, + {"name": "fivetran_account_user_role_s_c", "datatype": dbt_utils.type_string()}, + {"name": "fivetran_connectors_used_c", "datatype": dbt_utils.type_string()}, + {"name": "fivetran_data_warehouses_c", "datatype": dbt_utils.type_string()}, + {"name": "fivetran_first_sync_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "fivetran_fit_score_c", "datatype": dbt_utils.type_int()}, + {"name": "fivetran_industry_category_c", "datatype": dbt_utils.type_string()}, + {"name": "fivetran_industry_category_c_contact", "datatype": dbt_utils.type_string()}, + {"name": "fivetran_last_sync_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "fivetran_referral_id_c", "datatype": dbt_utils.type_string()}, + {"name": "fivetran_sync_status_c", "datatype": dbt_utils.type_string()}, + {"name": "fivetran_trial_begin_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "fivetran_trial_end_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "fivetran_trial_start_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "fivetran_user_id_c", "datatype": dbt_utils.type_string()}, + {"name": "formula_fields_updated_c", "datatype": "boolean"}, + {"name": "free_trial_email_confirmed_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "friction_score_c", "datatype": dbt_utils.type_int()}, + {"name": "ft_account_id_s_verified_c", "datatype": "boolean"}, + {"name": "ft_account_verification_needed_c", "datatype": "boolean"}, + {"name": "funnel_priority_c", "datatype": dbt_utils.type_float()}, + {"name": "funnel_stage_c", "datatype": dbt_utils.type_string()}, + {"name": "funnel_type_c", "datatype": dbt_utils.type_string()}, + {"name": "gclid_c", "datatype": dbt_utils.type_string()}, + {"name": "gdpr_opt_in_explicit_c", "datatype": "boolean"}, + {"name": "gender", "datatype": dbt_utils.type_string()}, + {"name": "geo_city_c", "datatype": dbt_utils.type_string()}, + {"name": "geo_country_c", "datatype": dbt_utils.type_string()}, + {"name": "geo_country_code_c", "datatype": dbt_utils.type_string()}, + {"name": "geo_state_c", "datatype": dbt_utils.type_string()}, + {"name": "has_fivetran_connector_c", "datatype": "boolean"}, + {"name": "has_opted_out_of_fax", "datatype": "boolean"}, + {"name": "health_score_c", "datatype": dbt_utils.type_int()}, + {"name": "hidden_company_name", "datatype": dbt_utils.type_string()}, + {"name": "historical_contact_status_c", "datatype": dbt_utils.type_string()}, + {"name": "hot_contact_c", "datatype": "boolean"}, + {"name": "id", "datatype": dbt_utils.type_int()}, + {"name": "industry", "datatype": dbt_utils.type_string()}, + {"name": "inferred_city", "datatype": dbt_utils.type_string()}, + {"name": "inferred_company", "datatype": dbt_utils.type_string()}, + {"name": "inferred_country", "datatype": dbt_utils.type_string()}, + {"name": "inferred_metropolitan_area", "datatype": dbt_utils.type_string()}, + {"name": "inferred_phone_area_code", "datatype": dbt_utils.type_string()}, + {"name": "inferred_postal_code", "datatype": dbt_utils.type_string()}, + {"name": "inferred_state_region", "datatype": dbt_utils.type_string()}, + {"name": "is_anonymous", "datatype": "boolean"}, + {"name": "is_email_bounced", "datatype": "boolean"}, + {"name": "is_emea_event_routing_c", "datatype": "boolean"}, + {"name": "is_emea_event_routing_c_account", "datatype": "boolean"}, + {"name": "is_eu_resident_c", "datatype": "boolean"}, + {"name": "is_excluded_from_realign", "datatype": "boolean"}, + {"name": "is_lead", "datatype": "boolean"}, + {"name": "is_updated_superset_c", "datatype": "boolean"}, + {"name": "job_function_c", "datatype": dbt_utils.type_string()}, + {"name": "job_level_c", "datatype": dbt_utils.type_string()}, + {"name": "keyword_c", "datatype": dbt_utils.type_string()}, + {"name": "land_arr_c", "datatype": dbt_utils.type_float()}, + {"name": "land_region_2020_h_2_c", "datatype": dbt_utils.type_string()}, + {"name": "last_activity_logged_by_c", "datatype": dbt_utils.type_string()}, + {"name": "last_ae_activity_owner_c", "datatype": dbt_utils.type_string()}, + {"name": "last_bdr_activity_owner_c", "datatype": dbt_utils.type_string()}, + {"name": "last_manual_ae_activity_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "last_manual_bdr_activity_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "last_name", "datatype": dbt_utils.type_string()}, + {"name": "last_re_captchaserver_status", "datatype": "boolean"}, + {"name": "last_referenced_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "last_referenced_date_account", "datatype": dbt_utils.type_timestamp()}, + {"name": "last_rep_activity_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "last_sales_activity_date_time_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "last_viewed_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "last_viewed_date_account", "datatype": dbt_utils.type_timestamp()}, + {"name": "lastre_captchaerror_codes", "datatype": dbt_utils.type_string()}, + {"name": "lead_created_date_time_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "lead_created_date_time_reporting_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "lead_iq_country_c", "datatype": dbt_utils.type_string()}, + {"name": "lead_iq_employee_count_c", "datatype": dbt_utils.type_int()}, + {"name": "lead_iq_employee_range_c", "datatype": dbt_utils.type_string()}, + {"name": "lead_iq_state_c", "datatype": dbt_utils.type_string()}, + {"name": "lead_iq_zip_code_c", "datatype": dbt_utils.type_string()}, + {"name": "lead_number_c", "datatype": dbt_utils.type_int()}, + {"name": "lead_partition_id", "datatype": dbt_utils.type_int()}, + {"name": "lead_person", "datatype": dbt_utils.type_int()}, + {"name": "lead_source", "datatype": dbt_utils.type_string()}, + {"name": "lead_source_c", "datatype": dbt_utils.type_string()}, + {"name": "lead_status", "datatype": dbt_utils.type_string()}, + {"name": "lead_type_c", "datatype": dbt_utils.type_string()}, + {"name": "lean_data_ld_email_domains_c", "datatype": dbt_utils.type_string()}, + {"name": "lean_data_manual_route_trigger_c", "datatype": "boolean"}, + {"name": "lean_data_re_route_c", "datatype": dbt_utils.type_int()}, + {"name": "lean_data_reporting_customer_c", "datatype": "boolean"}, + {"name": "lean_data_reporting_has_opportunity_c", "datatype": "boolean"}, + {"name": "lean_data_reporting_matched_account_c", "datatype": dbt_utils.type_string()}, + {"name": "lean_data_reporting_target_account_c", "datatype": "boolean"}, + {"name": "lean_data_reporting_timestamp_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "lean_data_routing_action_c", "datatype": dbt_utils.type_string()}, + {"name": "lean_data_routing_action_c_contact", "datatype": dbt_utils.type_string()}, + {"name": "lean_data_routing_status_c", "datatype": dbt_utils.type_string()}, + {"name": "lean_data_search_c", "datatype": dbt_utils.type_string()}, + {"name": "lean_data_search_index_c", "datatype": dbt_utils.type_string()}, + {"name": "leandata_contact_owner_override_c", "datatype": dbt_utils.type_string()}, + {"name": "lid_linked_in_member_token_c", "datatype": dbt_utils.type_string()}, + {"name": "linked_in_profile_url", "datatype": dbt_utils.type_string()}, + {"name": "linked_in_url_c", "datatype": dbt_utils.type_string()}, + {"name": "list_import_status", "datatype": dbt_utils.type_string()}, + {"name": "mailing_address", "datatype": dbt_utils.type_string()}, + {"name": "mailing_country_code", "datatype": dbt_utils.type_string()}, + {"name": "mailing_state_code", "datatype": dbt_utils.type_string()}, + {"name": "main_phone", "datatype": dbt_utils.type_string()}, + {"name": "manual_override_country_code_c", "datatype": dbt_utils.type_string()}, + {"name": "manual_override_employee_count_c", "datatype": dbt_utils.type_int()}, + {"name": "manual_override_state_c", "datatype": dbt_utils.type_string()}, + {"name": "manual_override_zip_c", "datatype": dbt_utils.type_string()}, + {"name": "marketing_approval_c", "datatype": dbt_utils.type_string()}, + {"name": "marketing_behavior_score_c", "datatype": dbt_utils.type_int()}, + {"name": "marketing_connector_interest_c", "datatype": dbt_utils.type_string()}, + {"name": "marketing_prospect_routing_rules_c", "datatype": "boolean"}, + {"name": "marketing_suspended", "datatype": "boolean"}, + {"name": "marketing_suspended_reason", "datatype": dbt_utils.type_string()}, + {"name": "marketing_target_account_c", "datatype": "boolean"}, + {"name": "matchtype_c", "datatype": dbt_utils.type_string()}, + {"name": "mc_4_sf_mc_subscriber_c", "datatype": dbt_utils.type_string()}, + {"name": "meta_data_create_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "middle_name", "datatype": dbt_utils.type_string()}, + {"name": "mkto_acquisition_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "mkto_company_notes", "datatype": dbt_utils.type_string()}, + {"name": "mkto_is_customer", "datatype": "boolean"}, + {"name": "mkto_is_partner", "datatype": "boolean"}, + {"name": "mkto_name", "datatype": dbt_utils.type_string()}, + {"name": "mkto_person_notes", "datatype": dbt_utils.type_string()}, + {"name": "mkto_si_add_to_marketo_campaign_c", "datatype": dbt_utils.type_string()}, + {"name": "mkto_si_sales_insight_c", "datatype": dbt_utils.type_string()}, + {"name": "mobile_phone", "datatype": dbt_utils.type_string()}, + {"name": "mobile_phone_c", "datatype": dbt_utils.type_string()}, + {"name": "monthly_customer_no_contract_c", "datatype": "boolean"}, + {"name": "mql_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "mql_reason_c", "datatype": dbt_utils.type_string()}, + {"name": "msa_effective_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "nda_c", "datatype": dbt_utils.type_string()}, + {"name": "netsuite_conn_account_balance_c", "datatype": dbt_utils.type_float()}, + {"name": "netsuite_conn_account_overdue_balance_c", "datatype": dbt_utils.type_float()}, + {"name": "netsuite_conn_celigo_update_c", "datatype": "boolean"}, + {"name": "netsuite_conn_celigo_update_c_account", "datatype": "boolean"}, + {"name": "netsuite_conn_credit_hold_c", "datatype": dbt_utils.type_string()}, + {"name": "netsuite_conn_days_overdue_c", "datatype": dbt_utils.type_int()}, + {"name": "netsuite_conn_net_suite_customer_id_c", "datatype": dbt_utils.type_int()}, + {"name": "netsuite_conn_net_suite_id_c", "datatype": dbt_utils.type_int()}, + {"name": "netsuite_conn_net_suite_id_c_account", "datatype": dbt_utils.type_int()}, + {"name": "netsuite_conn_net_suite_sync_err_c", "datatype": dbt_utils.type_string()}, + {"name": "netsuite_conn_net_suite_sync_err_c_account", "datatype": dbt_utils.type_string()}, + {"name": "netsuite_conn_push_to_net_suite_c", "datatype": "boolean"}, + {"name": "netsuite_conn_push_to_net_suite_c_account", "datatype": "boolean"}, + {"name": "netsuite_conn_pushed_from_opportunity_c", "datatype": "boolean"}, + {"name": "netsuite_conn_pushed_from_opportunity_c_account", "datatype": "boolean"}, + {"name": "netsuite_conn_sync_in_progress_c", "datatype": "boolean"}, + {"name": "netsuite_conn_sync_in_progress_c_contact", "datatype": "boolean"}, + {"name": "netsuite_conn_unbilled_orders_c", "datatype": dbt_utils.type_float()}, + {"name": "network_c", "datatype": dbt_utils.type_string()}, + {"name": "neverbounce_email_status", "datatype": dbt_utils.type_string()}, + {"name": "no_longer_at_company_c", "datatype": "boolean"}, + {"name": "notes_c", "datatype": dbt_utils.type_string()}, + {"name": "notes_cs_c", "datatype": dbt_utils.type_string()}, + {"name": "nps_score_c", "datatype": dbt_utils.type_string()}, + {"name": "number_of_credits_remaining_c", "datatype": dbt_utils.type_float()}, + {"name": "number_of_employees", "datatype": dbt_utils.type_int()}, + {"name": "old_lead_source_c", "datatype": dbt_utils.type_string()}, + {"name": "old_lead_source_detail_c_contact", "datatype": dbt_utils.type_string()}, + {"name": "opp_handoff_ae_c", "datatype": dbt_utils.type_string()}, + {"name": "opportunity_c", "datatype": dbt_utils.type_string()}, + {"name": "original_referrer", "datatype": dbt_utils.type_string()}, + {"name": "original_search_engine", "datatype": dbt_utils.type_string()}, + {"name": "original_search_phrase", "datatype": dbt_utils.type_string()}, + {"name": "original_source_info", "datatype": dbt_utils.type_string()}, + {"name": "original_source_type", "datatype": dbt_utils.type_string()}, + {"name": "original_utm_campaign_c", "datatype": dbt_utils.type_string()}, + {"name": "original_utm_content_c", "datatype": dbt_utils.type_string()}, + {"name": "original_utm_medium_c", "datatype": dbt_utils.type_string()}, + {"name": "original_utm_source_c", "datatype": dbt_utils.type_string()}, + {"name": "original_utm_term_c", "datatype": dbt_utils.type_string()}, + {"name": "other_country_code", "datatype": dbt_utils.type_string()}, + {"name": "owner_id_c", "datatype": dbt_utils.type_string()}, + {"name": "partner_company_c", "datatype": dbt_utils.type_string()}, + {"name": "partner_contact_c", "datatype": "boolean"}, + {"name": "partner_owner_c", "datatype": dbt_utils.type_string()}, + {"name": "partner_rep_email_c", "datatype": dbt_utils.type_string()}, + {"name": "partner_rep_name_c", "datatype": dbt_utils.type_string()}, + {"name": "partner_territory_c", "datatype": dbt_utils.type_string()}, + {"name": "partner_tier_c", "datatype": dbt_utils.type_string()}, + {"name": "partner_type_c", "datatype": dbt_utils.type_string()}, + {"name": "partner_type_c_account", "datatype": dbt_utils.type_string()}, + {"name": "payment_terms_c", "datatype": dbt_utils.type_string()}, + {"name": "pbf_account_c", "datatype": "boolean"}, + {"name": "person_primary_lead_interest", "datatype": dbt_utils.type_int()}, + {"name": "person_time_zone", "datatype": dbt_utils.type_string()}, + {"name": "person_type", "datatype": dbt_utils.type_string()}, + {"name": "phone", "datatype": dbt_utils.type_string()}, + {"name": "phone_extension_c", "datatype": dbt_utils.type_string()}, + {"name": "photo_url", "datatype": dbt_utils.type_string()}, + {"name": "photo_url_account", "datatype": dbt_utils.type_string()}, + {"name": "pi_campaign_c", "datatype": dbt_utils.type_string()}, + {"name": "pi_comments_c", "datatype": dbt_utils.type_string()}, + {"name": "pi_conversion_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "pi_conversion_object_name_c", "datatype": dbt_utils.type_string()}, + {"name": "pi_conversion_object_type_c", "datatype": dbt_utils.type_string()}, + {"name": "pi_created_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "pi_first_activity_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "pi_needs_score_synced_c", "datatype": "boolean"}, + {"name": "pi_utm_campaign_c", "datatype": dbt_utils.type_string()}, + {"name": "pi_utm_content_c", "datatype": dbt_utils.type_string()}, + {"name": "pi_utm_medium_c", "datatype": dbt_utils.type_string()}, + {"name": "pi_utm_source_c", "datatype": dbt_utils.type_string()}, + {"name": "pi_utm_term_c", "datatype": dbt_utils.type_string()}, + {"name": "platform_level_c", "datatype": dbt_utils.type_string()}, + {"name": "podcast_c", "datatype": dbt_utils.type_string()}, + {"name": "postal_code", "datatype": dbt_utils.type_string()}, + {"name": "potential_fivetran_use_case_c", "datatype": dbt_utils.type_string()}, + {"name": "pr_opportunity_c", "datatype": dbt_utils.type_string()}, + {"name": "previouse_fortune_rank_c", "datatype": dbt_utils.type_int()}, + {"name": "primary_contact_c", "datatype": dbt_utils.type_string()}, + {"name": "priority", "datatype": dbt_utils.type_int()}, + {"name": "product_feedback_c", "datatype": dbt_utils.type_string()}, + {"name": "project_based_routing_c", "datatype": "boolean"}, + {"name": "promoter_score_c", "datatype": dbt_utils.type_int()}, + {"name": "promotion_id_c", "datatype": dbt_utils.type_string()}, + {"name": "quick_email_verification_accept_all", "datatype": "boolean"}, + {"name": "quick_email_verification_disposable", "datatype": "boolean"}, + {"name": "quick_email_verification_free", "datatype": "boolean"}, + {"name": "quick_email_verification_reason", "datatype": dbt_utils.type_string()}, + {"name": "quick_email_verification_result", "datatype": dbt_utils.type_string()}, + {"name": "quick_email_verification_role", "datatype": "boolean"}, + {"name": "quick_email_verification_safe_to_send", "datatype": "boolean"}, + {"name": "re_target_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "recent_marketing_campaign_status_c", "datatype": dbt_utils.type_string()}, + {"name": "recommended_connector_c", "datatype": dbt_utils.type_string()}, + {"name": "record_type_id", "datatype": dbt_utils.type_string()}, + {"name": "reference_call_c", "datatype": dbt_utils.type_string()}, + {"name": "referral_account_c", "datatype": dbt_utils.type_string()}, + {"name": "referral_account_c_account", "datatype": dbt_utils.type_string()}, + {"name": "referral_c", "datatype": dbt_utils.type_string()}, + {"name": "referral_contact_c", "datatype": dbt_utils.type_string()}, + {"name": "referral_contact_c_account", "datatype": dbt_utils.type_string()}, + {"name": "referral_contact_email_c", "datatype": dbt_utils.type_string()}, + {"name": "referral_exists_c", "datatype": "boolean"}, + {"name": "referral_firstname_c", "datatype": dbt_utils.type_string()}, + {"name": "referral_last_name_c", "datatype": dbt_utils.type_string()}, + {"name": "region_c", "datatype": dbt_utils.type_string()}, + {"name": "region_c_account", "datatype": dbt_utils.type_string()}, + {"name": "region_c_c", "datatype": dbt_utils.type_string()}, + {"name": "region_deprecate_c", "datatype": dbt_utils.type_string()}, + {"name": "region_terr_c", "datatype": dbt_utils.type_string()}, + {"name": "registration_source_info", "datatype": dbt_utils.type_string()}, + {"name": "registration_source_type", "datatype": dbt_utils.type_string()}, + {"name": "relative_score", "datatype": dbt_utils.type_int()}, + {"name": "relative_urgency", "datatype": dbt_utils.type_int()}, + {"name": "rh_2_formula_test_c", "datatype": dbt_utils.type_float()}, + {"name": "roll_out_group_c", "datatype": dbt_utils.type_string()}, + {"name": "rollout_group_override_c", "datatype": dbt_utils.type_string()}, + {"name": "round_robin_id_c", "datatype": dbt_utils.type_int()}, + {"name": "rybbon_campaign_key", "datatype": dbt_utils.type_string()}, + {"name": "sales_engineer_c", "datatype": dbt_utils.type_string()}, + {"name": "sales_loft_1_active_account_c", "datatype": dbt_utils.type_int()}, + {"name": "sales_loft_1_active_contact_c", "datatype": dbt_utils.type_int()}, + {"name": "sales_loft_1_active_lead_c", "datatype": dbt_utils.type_int()}, + {"name": "sales_loft_1_most_recent_cadence_name_c", "datatype": dbt_utils.type_string()}, + {"name": "sales_loft_1_most_recent_cadence_next_step_due_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "sales_loft_1_most_recent_last_completed_step_c", "datatype": dbt_utils.type_int()}, + {"name": "sales_region_c", "datatype": dbt_utils.type_string()}, + {"name": "sales_segment_c", "datatype": dbt_utils.type_string()}, + {"name": "sales_target_account_c", "datatype": "boolean"}, + {"name": "salesloft_account_name_c", "datatype": dbt_utils.type_string()}, + {"name": "salesloft_cadence_trigger_c", "datatype": dbt_utils.type_string()}, + {"name": "salutation", "datatype": dbt_utils.type_string()}, + {"name": "secondary_email_c", "datatype": dbt_utils.type_string()}, + {"name": "segment_c", "datatype": dbt_utils.type_string()}, + {"name": "self_service_to_annual_c", "datatype": "boolean"}, + {"name": "sfbd_collections_agent_c", "datatype": dbt_utils.type_string()}, + {"name": "sfbd_collections_plan_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "sfbd_collections_status_c", "datatype": dbt_utils.type_string()}, + {"name": "sfbd_dunning_method_c", "datatype": dbt_utils.type_string()}, + {"name": "sfdc_account_id", "datatype": dbt_utils.type_string()}, + {"name": "sfdc_contact_id", "datatype": dbt_utils.type_string()}, + {"name": "sfdc_lead_id", "datatype": dbt_utils.type_string()}, + {"name": "sfdc_lead_owner_id", "datatype": dbt_utils.type_string()}, + {"name": "sfdc_type", "datatype": dbt_utils.type_string()}, + {"name": "shipping_country_code", "datatype": dbt_utils.type_string()}, + {"name": "shipping_state_code", "datatype": dbt_utils.type_string()}, + {"name": "sic_code", "datatype": dbt_utils.type_string()}, + {"name": "siftrock_positive_email_reply", "datatype": "boolean"}, + {"name": "sla_c", "datatype": "boolean"}, + {"name": "source_detail_c", "datatype": dbt_utils.type_string()}, + {"name": "source_detail_c_account", "datatype": dbt_utils.type_string()}, + {"name": "source_every_lead_source_c", "datatype": dbt_utils.type_string()}, + {"name": "source_every_lead_source_category_c", "datatype": dbt_utils.type_string()}, + {"name": "source_every_lead_source_detail_c", "datatype": dbt_utils.type_string()}, + {"name": "source_every_utm_campaign_c", "datatype": dbt_utils.type_string()}, + {"name": "source_every_utm_content_c", "datatype": dbt_utils.type_string()}, + {"name": "source_every_utm_medium_c", "datatype": dbt_utils.type_string()}, + {"name": "source_every_utm_source_c", "datatype": dbt_utils.type_string()}, + {"name": "source_every_utm_term_c", "datatype": dbt_utils.type_string()}, + {"name": "source_first_lead_source_c", "datatype": dbt_utils.type_string()}, + {"name": "source_first_lead_source_category_c", "datatype": dbt_utils.type_string()}, + {"name": "source_first_lead_source_detail_c", "datatype": dbt_utils.type_string()}, + {"name": "source_first_utm_campaign_c", "datatype": dbt_utils.type_string()}, + {"name": "source_first_utm_content_c", "datatype": dbt_utils.type_string()}, + {"name": "source_first_utm_medium_c", "datatype": dbt_utils.type_string()}, + {"name": "source_first_utm_source_c", "datatype": dbt_utils.type_string()}, + {"name": "source_first_utm_term_c", "datatype": dbt_utils.type_string()}, + {"name": "source_last_lead_source_c", "datatype": dbt_utils.type_string()}, + {"name": "source_last_lead_source_c_contact", "datatype": dbt_utils.type_string()}, + {"name": "source_last_lead_source_category_c", "datatype": dbt_utils.type_string()}, + {"name": "source_last_lead_source_category_c_contact", "datatype": dbt_utils.type_string()}, + {"name": "source_last_lead_source_detail_c", "datatype": dbt_utils.type_string()}, + {"name": "source_last_lead_source_detail_c_contact", "datatype": dbt_utils.type_string()}, + {"name": "source_last_utm_campaign_c", "datatype": dbt_utils.type_string()}, + {"name": "source_last_utm_content_c", "datatype": dbt_utils.type_string()}, + {"name": "source_last_utm_medium_c", "datatype": dbt_utils.type_string()}, + {"name": "source_last_utm_source_c", "datatype": dbt_utils.type_string()}, + {"name": "source_last_utm_term_c", "datatype": dbt_utils.type_string()}, + {"name": "source_most_recent", "datatype": dbt_utils.type_string()}, + {"name": "start_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "state", "datatype": dbt_utils.type_string()}, + {"name": "state_c", "datatype": dbt_utils.type_string()}, + {"name": "state_code", "datatype": dbt_utils.type_string()}, + {"name": "stripe_customer_id_c", "datatype": dbt_utils.type_string()}, + {"name": "subscription_length_c", "datatype": dbt_utils.type_float()}, + {"name": "sum_of_future_opportunities_c", "datatype": dbt_utils.type_float()}, + {"name": "sum_of_lost_renewal_opps_c", "datatype": dbt_utils.type_int()}, + {"name": "superset_country_c", "datatype": dbt_utils.type_string()}, + {"name": "superset_country_c_account", "datatype": dbt_utils.type_string()}, + {"name": "superset_employee_count_c", "datatype": dbt_utils.type_int()}, + {"name": "superset_employee_count_c_contact", "datatype": dbt_utils.type_int()}, + {"name": "superset_state_c", "datatype": dbt_utils.type_string()}, + {"name": "superset_state_c_contact", "datatype": dbt_utils.type_string()}, + {"name": "superset_zip_c", "datatype": dbt_utils.type_string()}, + {"name": "superset_zip_c_contact", "datatype": dbt_utils.type_string()}, + {"name": "suppress_billing_c", "datatype": "boolean"}, + {"name": "survey_apps_used", "datatype": dbt_utils.type_string()}, + {"name": "survey_confidencein_data_analysis", "datatype": dbt_utils.type_string()}, + {"name": "survey_datawarehouse", "datatype": dbt_utils.type_string()}, + {"name": "survey_etltools", "datatype": dbt_utils.type_string()}, + {"name": "survey_fivetran_project", "datatype": dbt_utils.type_string()}, + {"name": "survey_hours_spent", "datatype": dbt_utils.type_string()}, + {"name": "survey_project_timeline", "datatype": dbt_utils.type_string()}, + {"name": "survey_what_would_you_rather_do", "datatype": dbt_utils.type_string()}, + {"name": "target_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "territory_c", "datatype": dbt_utils.type_string()}, + {"name": "territory_country_c", "datatype": dbt_utils.type_string()}, + {"name": "territory_employee_count_c", "datatype": dbt_utils.type_int()}, + {"name": "territory_state_c", "datatype": dbt_utils.type_string()}, + {"name": "territory_zip_c", "datatype": dbt_utils.type_string()}, + {"name": "test_email_ccaddress", "datatype": dbt_utils.type_string()}, + {"name": "third_party_payer_c", "datatype": dbt_utils.type_string()}, + {"name": "time_to_conversion_c", "datatype": dbt_utils.type_int()}, + {"name": "title", "datatype": dbt_utils.type_string()}, + {"name": "to_delete_c", "datatype": "boolean"}, + {"name": "total_comp_credits_this_month_c", "datatype": dbt_utils.type_int()}, + {"name": "total_credits_bought_c", "datatype": dbt_utils.type_int()}, + {"name": "total_credits_used_c", "datatype": dbt_utils.type_int()}, + {"name": "trial_contact_start_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "trial_end_date_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "u_fall_assets_downloaded", "datatype": dbt_utils.type_string()}, + {"name": "uberfliphub_116403_articlesviewed", "datatype": dbt_utils.type_int()}, + {"name": "uberfliphub_116403_flipbooksviewed", "datatype": dbt_utils.type_int()}, + {"name": "uberfliphub_116403_videosviewed", "datatype": dbt_utils.type_int()}, + {"name": "uf_conversion_item_id", "datatype": dbt_utils.type_int()}, + {"name": "uf_conversion_item_title", "datatype": dbt_utils.type_string()}, + {"name": "uf_last_visited_item_id", "datatype": dbt_utils.type_int()}, + {"name": "uf_last_visited_item_title", "datatype": dbt_utils.type_string()}, + {"name": "unique_email_c", "datatype": dbt_utils.type_string()}, + {"name": "unqualified_reason_c", "datatype": dbt_utils.type_string()}, + {"name": "unqualified_reason_c_contact", "datatype": dbt_utils.type_string()}, + {"name": "unsubscribed", "datatype": "boolean"}, + {"name": "unsubscribed_reason", "datatype": dbt_utils.type_string()}, + {"name": "updated_at", "datatype": dbt_utils.type_timestamp()}, + {"name": "urgency", "datatype": dbt_utils.type_float()}, + {"name": "usage_ae_c", "datatype": dbt_utils.type_string()}, + {"name": "usage_am_c", "datatype": dbt_utils.type_string()}, + {"name": "usage_csm_c", "datatype": dbt_utils.type_string()}, + {"name": "usage_score_c", "datatype": dbt_utils.type_int()}, + {"name": "user_activity_logged_by_c", "datatype": dbt_utils.type_string()}, + {"name": "user_gems_has_a_user_gem_c", "datatype": "boolean"}, + {"name": "user_gems_has_changed_job_c", "datatype": dbt_utils.type_timestamp()}, + {"name": "user_gems_is_a_user_gem_c", "datatype": "boolean"}, + {"name": "user_gems_linked_in_c", "datatype": dbt_utils.type_string()}, + {"name": "user_gems_past_account_c", "datatype": dbt_utils.type_string()}, + {"name": "user_gems_past_company_c", "datatype": dbt_utils.type_string()}, + {"name": "user_gems_past_contact_c", "datatype": dbt_utils.type_string()}, + {"name": "user_gems_past_title_c", "datatype": dbt_utils.type_string()}, + {"name": "utm_campaign_c", "datatype": dbt_utils.type_string()}, + {"name": "utm_content_c", "datatype": dbt_utils.type_string()}, + {"name": "utm_medium_c", "datatype": dbt_utils.type_string()}, + {"name": "utm_source_c", "datatype": dbt_utils.type_string()}, + {"name": "utm_term_c", "datatype": dbt_utils.type_string()}, + {"name": "verified", "datatype": "boolean"}, + {"name": "video_testimonial_c", "datatype": dbt_utils.type_string()}, + {"name": "warehouse_associated_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "webinar_c", "datatype": dbt_utils.type_string()}, + {"name": "website", "datatype": dbt_utils.type_string()}, + {"name": "won_and_future_open_opportunites_c", "datatype": dbt_utils.type_float()}, + {"name": "zoominfo_country_c", "datatype": dbt_utils.type_string()}, + {"name": "zoominfo_employee_count_c", "datatype": dbt_utils.type_int()}, + {"name": "zoominfo_state_c", "datatype": dbt_utils.type_string()}, + {"name": "zoominfo_technologies_c", "datatype": dbt_utils.type_string()}, + {"name": "zoominfo_technologies_c_account", "datatype": dbt_utils.type_string()}, + {"name": "zoominfo_zip_code_c", "datatype": dbt_utils.type_string()} +] %} + +{{ return(columns) }} + +{% endmacro %} diff --git a/macros/get_lead_describe_columns.sql b/macros/get_lead_describe_columns.sql new file mode 100644 index 0000000..b354fdf --- /dev/null +++ b/macros/get_lead_describe_columns.sql @@ -0,0 +1,17 @@ +{% macro get_lead_describe_columns() %} + +{% set columns = [ + {"name": "_fivetran_synced", "datatype": dbt_utils.type_timestamp()}, + {"name": "data_type", "datatype": dbt_utils.type_string()}, + {"name": "display_name", "datatype": dbt_utils.type_string()}, + {"name": "id", "datatype": dbt_utils.type_int()}, + {"name": "length", "datatype": dbt_utils.type_int()}, + {"name": "restname", "datatype": dbt_utils.type_string()}, + {"name": "restread_only", "datatype": "boolean"}, + {"name": "soapname", "datatype": dbt_utils.type_string()}, + {"name": "soapread_only", "datatype": "boolean"} +] %} + +{{ return(columns) }} + +{% endmacro %} diff --git a/macros/get_program_columns.sql b/macros/get_program_columns.sql new file mode 100644 index 0000000..8830f7d --- /dev/null +++ b/macros/get_program_columns.sql @@ -0,0 +1,23 @@ +{% macro get_program_columns() %} + +{% set columns = [ + {"name": "_fivetran_synced", "datatype": dbt_utils.type_timestamp()}, + {"name": "channel", "datatype": dbt_utils.type_string()}, + {"name": "created_at", "datatype": dbt_utils.type_timestamp()}, + {"name": "description", "datatype": dbt_utils.type_string()}, + {"name": "end_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "id", "datatype": dbt_utils.type_int()}, + {"name": "name", "datatype": dbt_utils.type_string()}, + {"name": "sfdc_id", "datatype": dbt_utils.type_string()}, + {"name": "sfdc_name", "datatype": dbt_utils.type_string()}, + {"name": "start_date", "datatype": dbt_utils.type_timestamp()}, + {"name": "status", "datatype": dbt_utils.type_string()}, + {"name": "type", "datatype": dbt_utils.type_string()}, + {"name": "updated_at", "datatype": dbt_utils.type_timestamp()}, + {"name": "url", "datatype": dbt_utils.type_string()}, + {"name": "workspace", "datatype": dbt_utils.type_string()} +] %} + +{{ return(columns) }} + +{% endmacro %} diff --git a/models/stg_marketo__activity_change_data_value.sql b/models/stg_marketo__activity_change_data_value.sql index 618fce5..b43c014 100644 --- a/models/stg_marketo__activity_change_data_value.sql +++ b/models/stg_marketo__activity_change_data_value.sql @@ -1,7 +1,18 @@ with base as ( select * - from {{ var('activity_change_data_value') }} + from {{ ref('stg_marketo__activity_change_data_value_tmp') }} + +), macro as ( + + select + {{ + fivetran_utils.fill_staging_columns( + source_columns=adapter.get_columns_in_relation(ref('stg_marketo__activity_change_data_value_tmp')), + staging_columns=get_activity_change_data_value_columns() + ) + }} + from base ), fields as ( @@ -20,9 +31,9 @@ with base as ( reason as change_reason, request_id, source as change_source - from base + from macro ) select * -from fields \ No newline at end of file +from fields diff --git a/models/stg_marketo__activity_click_email.sql b/models/stg_marketo__activity_click_email.sql index 427c2f6..abeeec2 100644 --- a/models/stg_marketo__activity_click_email.sql +++ b/models/stg_marketo__activity_click_email.sql @@ -1,7 +1,18 @@ with base as ( select * - from {{ var('activity_click_email') }} + from {{ ref('stg_marketo__activity_click_email_tmp') }} + +), macro as ( + + select + {{ + fivetran_utils.fill_staging_columns( + source_columns=adapter.get_columns_in_relation(ref('stg_marketo__activity_click_email_tmp')), + staging_columns=get_activity_click_email_columns() + ) + }} + from base ), fields as ( @@ -22,7 +33,7 @@ with base as ( primary_attribute_value_id, step_id, user_agent - from base + from macro ), surrogate as ( @@ -34,4 +45,4 @@ with base as ( ) select * -from surrogate \ No newline at end of file +from surrogate diff --git a/models/stg_marketo__activity_delete_lead.sql b/models/stg_marketo__activity_delete_lead.sql index 49be742..817244e 100644 --- a/models/stg_marketo__activity_delete_lead.sql +++ b/models/stg_marketo__activity_delete_lead.sql @@ -1,7 +1,18 @@ with base as ( select * - from {{ var('activity_delete_lead') }} + from {{ ref('stg_marketo__activity_delete_lead_tmp') }} + +), macro as ( + + select + {{ + fivetran_utils.fill_staging_columns( + source_columns=adapter.get_columns_in_relation(ref('stg_marketo__activity_delete_lead_tmp')), + staging_columns=get_activity_delete_lead_columns() + ) + }} + from base ), fields as ( @@ -15,7 +26,7 @@ with base as ( lead_id, primary_attribute_value, primary_attribute_value_id - from base + from macro ) diff --git a/models/stg_marketo__activity_email_bounced.sql b/models/stg_marketo__activity_email_bounced.sql index b6c5367..d8d6c95 100644 --- a/models/stg_marketo__activity_email_bounced.sql +++ b/models/stg_marketo__activity_email_bounced.sql @@ -1,7 +1,18 @@ with base as ( select * - from {{ var('activity_email_bounced') }} + from {{ ref('stg_marketo__activity_email_bounced_tmp') }} + +), macro as ( + + select + {{ + fivetran_utils.fill_staging_columns( + source_columns=adapter.get_columns_in_relation(ref('stg_marketo__activity_email_bounced_tmp')), + staging_columns=get_activity_email_bounced_columns() + ) + }} + from base ), fields as ( @@ -21,7 +32,7 @@ with base as ( primary_attribute_value_id, step_id, subcategory as bounce_subcategory - from base + from macro ), surrogate as ( @@ -33,4 +44,6 @@ with base as ( ) select * -from surrogate \ No newline at end of file +from surrogate + + diff --git a/models/stg_marketo__activity_email_delivered.sql b/models/stg_marketo__activity_email_delivered.sql index bc521a6..d6b6503 100644 --- a/models/stg_marketo__activity_email_delivered.sql +++ b/models/stg_marketo__activity_email_delivered.sql @@ -1,7 +1,18 @@ with base as ( select * - from {{ var('activity_email_delivered') }} + from {{ ref('stg_marketo__activity_email_delivered_tmp') }} + +), macro as ( + + select + {{ + fivetran_utils.fill_staging_columns( + source_columns=adapter.get_columns_in_relation(ref('stg_marketo__activity_email_delivered_tmp')), + staging_columns=get_activity_email_delivered_columns() + ) + }} + from base ), fields as ( @@ -17,7 +28,7 @@ with base as ( primary_attribute_value, primary_attribute_value_id, step_id - from base + from macro ), surrogate as ( @@ -29,4 +40,4 @@ with base as ( ) select * -from surrogate \ No newline at end of file +from surrogate diff --git a/models/stg_marketo__activity_merge_leads.sql b/models/stg_marketo__activity_merge_leads.sql index 5f7137c..3815a80 100644 --- a/models/stg_marketo__activity_merge_leads.sql +++ b/models/stg_marketo__activity_merge_leads.sql @@ -1,7 +1,18 @@ with base as ( select * - from {{ var('activity_merge_leads') }} + from {{ ref('stg_marketo__activity_merge_leads_tmp') }} + +), macro as ( + + select + {{ + fivetran_utils.fill_staging_columns( + source_columns=adapter.get_columns_in_relation(ref('stg_marketo__activity_merge_leads_tmp')), + staging_columns=get_activity_merge_leads_columns() + ) + }} + from base ), fields as ( @@ -18,9 +29,11 @@ with base as ( merged_in_sales, primary_attribute_value, primary_attribute_value_id - from base + from macro ) select * -from fields \ No newline at end of file +from fields + + diff --git a/models/stg_marketo__activity_open_email.sql b/models/stg_marketo__activity_open_email.sql index 94d32f4..5f028da 100644 --- a/models/stg_marketo__activity_open_email.sql +++ b/models/stg_marketo__activity_open_email.sql @@ -1,7 +1,18 @@ with base as ( select * - from {{ var('activity_open_email') }} + from {{ ref('stg_marketo__activity_open_email_tmp') }} + +), macro as ( + + select + {{ + fivetran_utils.fill_staging_columns( + source_columns=adapter.get_columns_in_relation(ref('stg_marketo__activity_open_email_tmp')), + staging_columns=get_activity_open_email_columns() + ) + }} + from base ), fields as ( @@ -21,7 +32,7 @@ with base as ( primary_attribute_value_id, step_id, user_agent - from base + from macro ), surrogate as ( @@ -33,4 +44,6 @@ with base as ( ) select * -from surrogate \ No newline at end of file +from surrogate + + diff --git a/models/stg_marketo__activity_send_email.sql b/models/stg_marketo__activity_send_email.sql index 22f1ee5..f530a58 100644 --- a/models/stg_marketo__activity_send_email.sql +++ b/models/stg_marketo__activity_send_email.sql @@ -1,7 +1,18 @@ with base as ( select * - from {{ var('activity_send_email') }} + from {{ ref('stg_marketo__activity_send_email_tmp') }} + +), macro as ( + + select + {{ + fivetran_utils.fill_staging_columns( + source_columns=adapter.get_columns_in_relation(ref('stg_marketo__activity_send_email_tmp')), + staging_columns=get_activity_send_email_columns() + ) + }} + from base ), fields as ( @@ -17,7 +28,7 @@ with base as ( primary_attribute_value, primary_attribute_value_id, step_id - from base + from macro ), surrogate as ( @@ -29,4 +40,6 @@ with base as ( ) select * -from surrogate \ No newline at end of file +from surrogate + + diff --git a/models/stg_marketo__activity_unsubscribe_email.sql b/models/stg_marketo__activity_unsubscribe_email.sql index d367325..b08c4f4 100644 --- a/models/stg_marketo__activity_unsubscribe_email.sql +++ b/models/stg_marketo__activity_unsubscribe_email.sql @@ -1,7 +1,18 @@ with base as ( select * - from {{ var('activity_unsubscribe_email') }} + from {{ ref('stg_marketo__activity_unsubscribe_email_tmp') }} + +), macro as ( + + select + {{ + fivetran_utils.fill_staging_columns( + source_columns=adapter.get_columns_in_relation(ref('stg_marketo__activity_unsubscribe_email_tmp')), + staging_columns=get_activity_unsubscribe_email_columns() + ) + }} + from base ), fields as ( @@ -22,7 +33,7 @@ with base as ( user_agent, webform_id, webpage_id - from base + from macro ), surrogate as ( @@ -34,4 +45,6 @@ with base as ( ) select * -from surrogate \ No newline at end of file +from surrogate + + diff --git a/models/stg_marketo__campaigns.sql b/models/stg_marketo__campaigns.sql index cc43fc4..6e17f01 100644 --- a/models/stg_marketo__campaigns.sql +++ b/models/stg_marketo__campaigns.sql @@ -1,7 +1,18 @@ with base as ( select * - from {{ var('campaign') }} + from {{ ref('stg_marketo__campaign_tmp') }} + +), macro as ( + + select + {{ + fivetran_utils.fill_staging_columns( + source_columns=adapter.get_columns_in_relation(ref('stg_marketo__campaign_tmp')), + staging_columns=get_campaign_columns() + ) + }} + from base ), fields as ( @@ -16,9 +27,10 @@ with base as ( type as campaign_type, updated_at as updated_timestamp, workspace_name - from base + from macro ) select * -from fields \ No newline at end of file +from fields + diff --git a/models/stg_marketo__email_template_history.sql b/models/stg_marketo__email_template_history.sql index 866429a..6174be8 100644 --- a/models/stg_marketo__email_template_history.sql +++ b/models/stg_marketo__email_template_history.sql @@ -1,7 +1,18 @@ with base as ( select * - from {{ var('email_template_history') }} + from {{ ref('stg_marketo__email_template_history_tmp') }} + +), macro as ( + + select + {{ + fivetran_utils.fill_staging_columns( + source_columns=adapter.get_columns_in_relation(ref('stg_marketo__email_template_history_tmp')), + staging_columns=get_email_template_history_columns() + ) + }} + from base ), fields as ( @@ -29,7 +40,7 @@ with base as ( version as version_type, web_view as has_web_view_enabled, workspace as workspace_name - from base + from macro ), versions as ( @@ -62,3 +73,6 @@ with base as ( select * from surrogate_key + + + diff --git a/models/stg_marketo__lead_adapter.sql b/models/stg_marketo__lead_adapter.sql deleted file mode 100644 index 0042176..0000000 --- a/models/stg_marketo__lead_adapter.sql +++ /dev/null @@ -1,2 +0,0 @@ -select * -from {{ var('lead') }} \ No newline at end of file diff --git a/models/stg_marketo__lead_base.sql b/models/stg_marketo__lead_base.sql index ded79a6..20e7a49 100644 --- a/models/stg_marketo__lead_base.sql +++ b/models/stg_marketo__lead_base.sql @@ -1,7 +1,7 @@ with base as ( select * - from {{ ref('stg_marketo__lead_adapter') }} + from {{ ref('stg_marketo__lead_tmp') }} ), fields as ( @@ -9,7 +9,7 @@ with base as ( id as lead_id, created_at as created_timestamp, updated_at as updated_timestamp, - {{ dbt_utils.star(from=ref('stg_marketo__lead_adapter'), except=['id', 'created_at', 'updated_at']) }} + {{ dbt_utils.star(from=ref('stg_marketo__lead_tmp'), except=['id', 'created_at', 'updated_at']) }} from base ) diff --git a/models/stg_marketo__lead_describe.sql b/models/stg_marketo__lead_describe.sql index cfe1923..dc05bd3 100644 --- a/models/stg_marketo__lead_describe.sql +++ b/models/stg_marketo__lead_describe.sql @@ -1,7 +1,18 @@ with base as ( select * - from {{ var('lead_describe') }} + from {{ ref('stg_marketo__lead_describe_tmp') }} + +), macro as ( + + select + {{ + fivetran_utils.fill_staging_columns( + source_columns=adapter.get_columns_in_relation(ref('stg_marketo__lead_describe_tmp')), + staging_columns=get_lead_describe_columns() + ) + }} + from base ), fields as ( @@ -14,7 +25,7 @@ with base as ( restread_only as is_rest_readonly, soapname as soap_name, soapread_only as is_soap_readonly - from base + from macro ), regex as ( @@ -29,4 +40,6 @@ with base as ( ) select * -from regex \ No newline at end of file +from regex + + diff --git a/models/stg_marketo__program.sql b/models/stg_marketo__program.sql index d1aa1c7..8fb90fc 100644 --- a/models/stg_marketo__program.sql +++ b/models/stg_marketo__program.sql @@ -1,7 +1,18 @@ with base as ( select * - from {{ var('program') }} + from {{ ref('stg_marketo__program_tmp') }} + +), macro as ( + + select + {{ + fivetran_utils.fill_staging_columns( + source_columns=adapter.get_columns_in_relation(ref('stg_marketo__program_tmp')), + staging_columns=get_program_columns() + ) + }} + from base ), fields as ( @@ -20,9 +31,11 @@ with base as ( updated_at as updated_timestamp, url, workspace - from base + from macro ) select * -from fields \ No newline at end of file +from fields + + diff --git a/models/tmp/stg_marketo__activity_change_data_value_tmp.sql b/models/tmp/stg_marketo__activity_change_data_value_tmp.sql new file mode 100644 index 0000000..68091a0 --- /dev/null +++ b/models/tmp/stg_marketo__activity_change_data_value_tmp.sql @@ -0,0 +1,2 @@ +select * +from {{ var('activity_change_data_value') }} diff --git a/models/tmp/stg_marketo__activity_click_email_tmp.sql b/models/tmp/stg_marketo__activity_click_email_tmp.sql new file mode 100644 index 0000000..6db88a6 --- /dev/null +++ b/models/tmp/stg_marketo__activity_click_email_tmp.sql @@ -0,0 +1,2 @@ +select * +from {{ var('activity_click_email') }} diff --git a/models/tmp/stg_marketo__activity_delete_lead_tmp.sql b/models/tmp/stg_marketo__activity_delete_lead_tmp.sql new file mode 100644 index 0000000..519e36e --- /dev/null +++ b/models/tmp/stg_marketo__activity_delete_lead_tmp.sql @@ -0,0 +1,2 @@ +select * +from {{ var('activity_delete_lead') }} diff --git a/models/tmp/stg_marketo__activity_email_bounced_tmp.sql b/models/tmp/stg_marketo__activity_email_bounced_tmp.sql new file mode 100644 index 0000000..e89c0ea --- /dev/null +++ b/models/tmp/stg_marketo__activity_email_bounced_tmp.sql @@ -0,0 +1,2 @@ +select * +from {{ var('activity_email_bounced') }} diff --git a/models/tmp/stg_marketo__activity_email_delivered_tmp.sql b/models/tmp/stg_marketo__activity_email_delivered_tmp.sql new file mode 100644 index 0000000..18132ca --- /dev/null +++ b/models/tmp/stg_marketo__activity_email_delivered_tmp.sql @@ -0,0 +1,2 @@ +select * +from {{ var('activity_email_delivered') }} diff --git a/models/tmp/stg_marketo__activity_merge_leads_tmp.sql b/models/tmp/stg_marketo__activity_merge_leads_tmp.sql new file mode 100644 index 0000000..0a1a7c4 --- /dev/null +++ b/models/tmp/stg_marketo__activity_merge_leads_tmp.sql @@ -0,0 +1,2 @@ +select * +from {{ var('activity_merge_leads') }} diff --git a/models/tmp/stg_marketo__activity_open_email_tmp.sql b/models/tmp/stg_marketo__activity_open_email_tmp.sql new file mode 100644 index 0000000..5f22e3a --- /dev/null +++ b/models/tmp/stg_marketo__activity_open_email_tmp.sql @@ -0,0 +1,2 @@ +select * +from {{ var('activity_open_email') }} diff --git a/models/tmp/stg_marketo__activity_send_email_tmp.sql b/models/tmp/stg_marketo__activity_send_email_tmp.sql new file mode 100644 index 0000000..43c386e --- /dev/null +++ b/models/tmp/stg_marketo__activity_send_email_tmp.sql @@ -0,0 +1,2 @@ +select * +from {{ var('activity_send_email') }} diff --git a/models/tmp/stg_marketo__activity_unsubscribe_email_tmp.sql b/models/tmp/stg_marketo__activity_unsubscribe_email_tmp.sql new file mode 100644 index 0000000..46ef31f --- /dev/null +++ b/models/tmp/stg_marketo__activity_unsubscribe_email_tmp.sql @@ -0,0 +1,2 @@ +select * +from {{ var('activity_unsubscribe_email') }} diff --git a/models/tmp/stg_marketo__campaign_tmp.sql b/models/tmp/stg_marketo__campaign_tmp.sql new file mode 100644 index 0000000..598e0d5 --- /dev/null +++ b/models/tmp/stg_marketo__campaign_tmp.sql @@ -0,0 +1,2 @@ +select * +from {{ var('campaign') }} diff --git a/models/tmp/stg_marketo__email_template_history_tmp.sql b/models/tmp/stg_marketo__email_template_history_tmp.sql new file mode 100644 index 0000000..6426620 --- /dev/null +++ b/models/tmp/stg_marketo__email_template_history_tmp.sql @@ -0,0 +1,2 @@ +select * +from {{ var('email_template_history') }} diff --git a/models/tmp/stg_marketo__lead_describe_tmp.sql b/models/tmp/stg_marketo__lead_describe_tmp.sql new file mode 100644 index 0000000..a8e2aeb --- /dev/null +++ b/models/tmp/stg_marketo__lead_describe_tmp.sql @@ -0,0 +1,2 @@ +select * +from {{ var('lead_describe') }} diff --git a/models/tmp/stg_marketo__lead_tmp.sql b/models/tmp/stg_marketo__lead_tmp.sql new file mode 100644 index 0000000..e084e33 --- /dev/null +++ b/models/tmp/stg_marketo__lead_tmp.sql @@ -0,0 +1,2 @@ +select * +from {{ var('lead') }} diff --git a/models/tmp/stg_marketo__program_tmp.sql b/models/tmp/stg_marketo__program_tmp.sql new file mode 100644 index 0000000..6e7e362 --- /dev/null +++ b/models/tmp/stg_marketo__program_tmp.sql @@ -0,0 +1,2 @@ +select * +from {{ var('program') }} diff --git a/packages.yml b/packages.yml index 908557a..d45e310 100644 --- a/packages.yml +++ b/packages.yml @@ -1,3 +1,6 @@ packages: - package: fishtown-analytics/dbt_utils - version: [">=0.6.0", "<0.7.0"] \ No newline at end of file + version: [">=0.6.0", "<0.7.0"] + + - git: "https://github.com/fivetran/dbt_fivetran_utils.git" + warn-unpinned: false \ No newline at end of file