diff --git a/airbyte-integrations/connectors/source-google-ads/source_google_ads/custom_query_stream.py b/airbyte-integrations/connectors/source-google-ads/source_google_ads/custom_query_stream.py index 2cf6066c4882..9aa8265afaa7 100644 --- a/airbyte-integrations/connectors/source-google-ads/source_google_ads/custom_query_stream.py +++ b/airbyte-integrations/connectors/source-google-ads/source_google_ads/custom_query_stream.py @@ -106,7 +106,10 @@ def insert_segments_date_expr(query: GAQL, start_date: str, end_date: str) -> GA query = query.append_field("segments.date") condition = f"segments.date BETWEEN '{start_date}' AND '{end_date}'" if query.where: - return query.set_where(query.where + " AND " + condition) + if "segments.date" not in query.where: + return query.set_where(query.where + " AND " + condition) + else: + return query.set_where(query.where) return query.set_where(condition)