update login_customer_ids

sendinblue · Apr 5, 2022 · 53fc4f3 · 53fc4f3
1 parent f55ed1a
commit 53fc4f3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/tap_google_ads/__init__.py b/tap_google_ads/__init__.py
@@ -32,7 +32,7 @@ def main_impl():
         do_discover(resource_schema)
         LOGGER.info("Discovery complete")
     elif args.catalog:
-        do_sync(args.config, args.catalog.to_dict(), resource_schema, state, args.schemaless)
+        do_sync(args.config, args.catalog.to_dict(), resource_schema, state)
         LOGGER.info("Sync Completed")
     else:
         LOGGER.info("No properties were selected")

diff --git a/tap_google_ads/sync.py b/tap_google_ads/sync.py
@@ -58,9 +58,9 @@ def shuffle(shuffle_list, shuffle_key, current_value, sort_function):
 def do_sync(config, catalog, resource_schema, state):
     # QA ADDED WORKAROUND [START]
     try:
-        customers = json.loads(config["login_customer_ids"])
+        customers = json.loads(config["customer_ids"])
     except TypeError:  # falling back to raw value
-        customers = config["login_customer_ids"]
+        customers = config["customer_ids"]
     # QA ADDED WORKAROUND [END]
     customers = sort_customers(customers)
 
@@ -99,7 +99,7 @@ def do_sync(config, catalog, resource_schema, state):
         singer.messages.write_schema(stream_name, catalog_entry["schema"], primary_key)
 
         for customer in customers:
-            sdk_client = create_sdk_client(config, customer["loginCustomerId"])
+            sdk_client = create_sdk_client(config, customer["customerId"])
 
             LOGGER.info(f"Syncing {stream_name} for customer Id {customer['customerId']}.")