From 2a98e9ec39808cc22f65151de1271836064245c0 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?St=C3=A9phane=20Burwash?=
 <35510512+SBurwash@users.noreply.github.com>
Date: Wed, 14 Sep 2022 20:16:10 -0400
Subject: [PATCH] DE-506 Investigate table associations_deals_companies (#33)

* Set parent replication key to high

* Changed state partitionning key to id (as opposed to id-toObjectId
---
 tap_hubspot/streams.py | 22 +++++++++++-----------
 1 file changed, 11 insertions(+), 11 deletions(-)

diff --git a/tap_hubspot/streams.py b/tap_hubspot/streams.py
index 9fb9929..3f44a0d 100644
--- a/tap_hubspot/streams.py
+++ b/tap_hubspot/streams.py
@@ -176,12 +176,12 @@ class AssociationsDealsToCompaniesStream(HubspotStream):
     deal_id = ""
     replication_method = "FULL_TABLE"
     primary_keys = ["id", "toObjectId"]
-    state_partitioning_keys = []
+    state_partitioning_keys = ["id"]
     replication_key = ""
     parent_stream_type = DealsStream
     schema_filepath = SCHEMAS_DIR / "associations_all.json"
 
-    ignore_parent_replication_keys = False
+    ignore_parent_replication_keys = True
 
     def get_url_params(
         self, context: Optional[dict], next_page_token: Optional[Any]
@@ -208,12 +208,12 @@ class AssociationsDealsToContactsStream(HubspotStream):
     deal_id = ""
     replication_method = "FULL_TABLE"
     primary_keys = ["id", "toObjectId"]
-    state_partitioning_keys = []
+    state_partitioning_keys = ["id"]
     replication_key = ""
     parent_stream_type = DealsStream
     schema_filepath = SCHEMAS_DIR / "associations_all.json"
 
-    ignore_parent_replication_keys = False
+    ignore_parent_replication_keys = True
 
     def get_url_params(
         self, context: Optional[dict], next_page_token: Optional[Any]
@@ -240,7 +240,7 @@ class AssociationsContactsToDealsStream(HubspotStream):
     deal_id = ""
     replication_method = "FULL_TABLE"
     primary_keys = ["id", "toObjectId"]
-    state_partitioning_keys = []
+    state_partitioning_keys = ["id"]
     replication_key = ""
     parent_stream_type = ContactsStream
     schema_filepath = SCHEMAS_DIR / "associations_all.json"
@@ -272,12 +272,12 @@ class AssociationsContactsToCompaniesStream(HubspotStream):
     deal_id = ""
     replication_method = "FULL_TABLE"
     primary_keys = ["id", "toObjectId"]
-    state_partitioning_keys = []
+    state_partitioning_keys = ["id"]
     replication_key = ""
     parent_stream_type = ContactsStream
     schema_filepath = SCHEMAS_DIR / "associations_all.json"
 
-    ignore_parent_replication_keys = False
+    ignore_parent_replication_keys = True
 
     def get_url_params(
         self, context: Optional[dict], next_page_token: Optional[Any]
@@ -304,12 +304,12 @@ class AssociationsCompaniesToContactsStream(HubspotStream):
     deal_id = ""
     replication_method = "FULL_TABLE"
     primary_keys = ["id", "toObjectId"]
-    state_partitioning_keys = []
+    state_partitioning_keys = ["id"]
     replication_key = ""
     parent_stream_type = CompaniesStream
     schema_filepath = SCHEMAS_DIR / "associations_all.json"
 
-    ignore_parent_replication_keys = False
+    ignore_parent_replication_keys = True
 
     def get_url_params(
         self, context: Optional[dict], next_page_token: Optional[Any]
@@ -336,12 +336,12 @@ class AssociationsCompaniesToDealsStream(HubspotStream):
     deal_id = ""
     replication_method = "FULL_TABLE"
     primary_keys = ["id", "toObjectId"]
-    state_partitioning_keys = []
+    state_partitioning_keys = ["id"]
     replication_key = ""
     parent_stream_type = CompaniesStream
     schema_filepath = SCHEMAS_DIR / "associations_all.json"
 
-    ignore_parent_replication_keys = False
+    ignore_parent_replication_keys = True
 
     def get_url_params(
         self, context: Optional[dict], next_page_token: Optional[Any]