Bug/string agg limit

CHANGELOG.md

@@ -1,3 +1,18 @@
+# dbt_jira v0.19.0
+[PR #133](https://github.com/fivetran/dbt_jira/pull/133) contains the following updates:
+
+## Breaking Changes
+- This change is marked as breaking due to its impact on Redshift configurations.
+- For Redshift users, comment data aggregated under the `conversations` field in the `jira__issue_enhanced` table is now disabled by default to prevent consistent errors related to Redshift's varchar length limits. 
+  - If you wish to re-enable comments on Redshift, set the `jira_include_comments` variable to `true` in your `dbt_project.yml`.
+
+## Under the Hood
+- Updated the `comment` seed data to ensure comments are correctly disabled for Redshift by default.
+- Updated the `jira_is_databricks_sql_warehouse` macro to `jira_is_incremental_compatible`. This macro now returns `true` if the Databricks runtime is an all-purpose cluster (previously it checked only for a SQL warehouse runtime) or if the target is any other non-Databricks-supported destination.
+  - This update addresses Databricks runtimes (e.g., endpoints and external runtimes) that do not support the `insert_overwrite` incremental strategy used in the `jira__daily_issue_field_history` and `int_jira__pivot_daily_field_history` models.
+- For Databricks users, the `jira__daily_issue_field_history` and `int_jira__pivot_daily_field_history` models will now apply the incremental strategy only if running on an all-purpose cluster. All other Databricks runtimes will not utilize an incremental strategy.
+- Added consistency tests for the `jira__project_enhanced` and `jira__user_enhanced` models.
+
 # dbt_jira v0.18.0
 [PR #131](https://github.com/fivetran/dbt_jira/pull/131) contains the following updates:
 ## Breaking Changes

README.md

@@ -66,7 +66,7 @@ Include the following jira package version in your `packages.yml` file:
 ```yaml
 packages:
   - package: fivetran/jira
-    version: [">=0.18.0", "<0.19.0"]
+    version: [">=0.19.0", "<0.20.0"]
 
 ```
 ### Step 3: Define database and schema variables
@@ -82,11 +82,11 @@ vars:
 Your Jira connector may not sync every table that this package expects. If you do not have the `SPRINT`, `COMPONENT`, or `VERSION` tables synced, add the respective variables to your root `dbt_project.yml` file. Additionally, if you want to remove comment aggregations from your `jira__issue_enhanced` model,  add the `jira_include_comments` variable to your root `dbt_project.yml`:
 ```yml
 vars:
-    jira_using_sprints: false   # Disable if you do not have the sprint table or do not want sprint-related metrics reported
-    jira_using_components: false # Disable if you do not have the component table or do not want component-related metrics reported
-    jira_using_versions: false # Disable if you do not have the versions table or do not want versions-related metrics reported
-    jira_using_priorities: false # disable if you are not using priorities in Jira
-    jira_include_comments: false # This package aggregates issue comments so that you have a single view of all your comments in the jira__issue_enhanced table. This can cause limit errors if you have a large dataset. Disable to remove this functionality.
+    jira_using_sprints: false    # Enabled by default. Disable if you do not have the sprint table or do not want sprint-related metrics reported.
+    jira_using_components: false # Enabled by default. Disable if you do not have the component table or do not want component-related metrics reported.
+    jira_using_versions: false   # Enabled by default. Disable if you do not have the versions table or do not want versions-related metrics reported.
+    jira_using_priorities: false # Enabled by default. Disable if you are not using priorities in Jira.
+    jira_include_comments: false # Disabled by default for Redshift, enabled by default for other supported warehouses. This package aggregates issue comments so that you have a single view of all your comments in the jira__issue_enhanced table. This can cause limit errors if you have a large dataset. Disable to remove this functionality.
 ```
 ### (Optional) Step 5: Additional configurations
 

dbt_project.yml

@@ -1,5 +1,5 @@
 name: 'jira'
-version: '0.18.0'
+version: '0.19.0'
 config-version: 2
 require-dbt-version: [">=1.3.0", "<2.0.0"]
 vars:

integration_tests/dbt_project.yml

@@ -1,9 +1,12 @@
 name: 'jira_integration_tests'
-version: '0.18.0'
+version: '0.19.0'
 config-version: 2
 profile: 'integration_tests'
 
 vars:
+  # Comment out the below when generating docs
+  issue_field_history_columns: ['summary', 'story points', 'components']
+
   jira_source:
     jira_schema: jira_integrations_tests_41
     jira_comment_identifier: "comment"
@@ -28,9 +31,6 @@ vars:
     jira_user_identifier: "user"
     jira_version_identifier: "version"
 
-  # Comment out the below when generating docs
-  issue_field_history_columns: ['summary', 'story points', 'components']
-
 models:
   jira:
     +schema: "{{ 'jira_integrations_tests_sqlw' if target.name == 'databricks-sql' else 'jira' }}"

integration_tests/tests/consistency/consistency_issue_enhanced.sql

@@ -4,13 +4,15 @@
     enabled=var('fivetran_validation_tests_enabled', false)
 ) }}
 
+{% set exclude_columns = ['open_duration_seconds', 'any_assignment_duration_seconds', 'last_assignment_duration_seconds'] %}
+
 with prod as (
-    select *
+    select {{ dbt_utils.star(from=ref('jira__issue_enhanced'), except=exclude_columns) }}
     from {{ target.schema }}_jira_prod.jira__issue_enhanced
 ),
 
 dev as (
-    select *
+    select {{ dbt_utils.star(from=ref('jira__issue_enhanced'), except=exclude_columns) }}
     from {{ target.schema }}_jira_dev.jira__issue_enhanced
 ),
 

integration_tests/tests/consistency/consistency_project_enhanced.sql

@@ -0,0 +1,48 @@
+
+{{ config(
+    tags="fivetran_validations",
+    enabled=var('fivetran_validation_tests_enabled', false)
+) }}
+
+{% set exclude_columns = ['avg_age_currently_open_seconds', 'avg_age_currently_open_assigned_seconds', 'median_age_currently_open_seconds', 'median_age_currently_open_assigned_seconds', 'epics', 'components'] %}
+
+with prod as (
+    select {{ dbt_utils.star(from=ref('jira__project_enhanced'), except=exclude_columns) }}
+    from {{ target.schema }}_jira_prod.jira__project_enhanced
+),
+
+dev as (
+    select {{ dbt_utils.star(from=ref('jira__project_enhanced'), except=exclude_columns) }}
+    from {{ target.schema }}_jira_dev.jira__project_enhanced
+),
+
+prod_not_in_dev as (
+    -- rows from prod not found in dev
+    select * from prod
+    except distinct
+    select * from dev
+),
+
+dev_not_in_prod as (
+    -- rows from dev not found in prod
+    select * from dev
+    except distinct
+    select * from prod
+),
+
+final as (
+    select
+        *,
+        'from prod' as source
+    from prod_not_in_dev
+
+    union all -- union since we only care if rows are produced
+
+    select
+        *,
+        'from dev' as source
+    from dev_not_in_prod
+)
+
+select *
+from final

integration_tests/tests/consistency/consistency_user_enhanced.sql

@@ -0,0 +1,48 @@
+
+{{ config(
+    tags="fivetran_validations",
+    enabled=var('fivetran_validation_tests_enabled', false)
+) }}
+
+{% set exclude_columns = ['avg_age_currently_open_seconds', 'median_age_currently_open_seconds', 'projects'] %}
+
+with prod as (
+    select {{ dbt_utils.star(from=ref('jira__user_enhanced'), except=exclude_columns) }}
+    from {{ target.schema }}_jira_prod.jira__user_enhanced
+),
+
+dev as (
+    select {{ dbt_utils.star(from=ref('jira__user_enhanced'), except=exclude_columns) }}
+    from {{ target.schema }}_jira_dev.jira__user_enhanced
+),
+
+prod_not_in_dev as (
+    -- rows from prod not found in dev
+    select * from prod
+    except distinct
+    select * from dev
+),
+
+dev_not_in_prod as (
+    -- rows from dev not found in prod
+    select * from dev
+    except distinct
+    select * from prod
+),
+
+final as (
+    select
+        *,
+        'from prod' as source
+    from prod_not_in_dev
+
+    union all -- union since we only care if rows are produced
+
+    select
+        *,
+        'from dev' as source
+    from dev_not_in_prod
+)
+
+select *
+from final

macros/jira_is_databricks_sql_warehouse.sql → macros/jira_is_incremental_compatible.sql

@@ -1,14 +1,16 @@
-{% macro jira_is_databricks_sql_warehouse() %}
+{% macro jira_is_incremental_compatible() %}
     {% if target.type in ('databricks') %}
         {% set re = modules.re %}
         {% set path_match = target.http_path %}
-        {% set regex_pattern = "sql/.+/warehouses/" %}
+        {% set regex_pattern = "sql/protocol" %}
         {% set match_result = re.search(regex_pattern, path_match) %}
         {% if match_result %}
             {{ return(True) }}
         {% else %}
             {{ return(False) }}
         {% endif %}
+    {% elif target.type in ('bigquery','snowflake','postgres','redshift','sqlserver') %}
+        {{ return(True) }}
     {% else %}
         {{ return(False) }}
     {% endif %}

models/intermediate/field_history/int_jira__pivot_daily_field_history.sql

@@ -1,6 +1,6 @@
 {{
     config(
-        materialized='table' if jira.jira_is_databricks_sql_warehouse() else 'incremental',
+        materialized='incremental' if jira_is_incremental_compatible() else 'table',
         partition_by = {'field': 'valid_starting_at_week', 'data_type': 'date'}
             if target.type not in ['spark','databricks'] else ['valid_starting_at_week'],
         cluster_by = ['valid_starting_at_week'],
@@ -176,4 +176,4 @@ final as (
 )
 
 select *
-from final 
+from final 

models/intermediate/int_jira__issue_comments.sql

@@ -1,4 +1,4 @@
-{{ config(enabled=var('jira_include_comments', True)) }}
+{{ config(enabled=var('jira_include_comments', False if target.type == 'redshift' else True)) }}
 
 with comment as (
 

models/intermediate/int_jira__issue_join.sql

@@ -51,7 +51,7 @@ issue_sprint as (
 ),
 {% endif %}
 
-{% if var('jira_include_comments', True) %}
+{% if var('jira_include_comments', False if target.type == 'redshift' else True) %}
 issue_comments as (
 
     select * 
@@ -109,7 +109,7 @@ join_issue as (
         ,issue_versions.affects_versions
         {% endif %}
 
-        {% if var('jira_include_comments', True) %}
+        {% if var('jira_include_comments', False if target.type == 'redshift' else True) %}
         ,issue_comments.conversation
         ,coalesce(issue_comments.count_comments, 0) as count_comments
         {% endif %}
@@ -132,7 +132,7 @@ join_issue as (
     left join issue_sprint on issue_sprint.issue_id = issue.issue_id
     {% endif %}
 
-    {% if var('jira_include_comments', True) %}
+    {% if var('jira_include_comments', False if target.type == 'redshift' else True) %}
     left join issue_comments on issue_comments.issue_id = issue.issue_id
     {% endif %}
 )

models/jira__daily_issue_field_history.sql

@@ -1,6 +1,6 @@
 {{
     config(
-        materialized='table' if jira.jira_is_databricks_sql_warehouse() else 'incremental',
+        materialized='incremental' if jira_is_incremental_compatible() else 'table',
         partition_by = {'field': 'date_week', 'data_type': 'date'}
             if target.type not in ['spark', 'databricks'] else ['date_week'],
         cluster_by = ['date_week'],