diff --git a/tap_google_ads/streams.py b/tap_google_ads/streams.py
index a6bba65..fe270ea 100644
--- a/tap_google_ads/streams.py
+++ b/tap_google_ads/streams.py
@@ -480,7 +480,7 @@ def sync(self, sdk_client, customer, stream, config, state, query_limit, schemal
                             record = transformer.transform(transformed_message, stream["schema"], singer.metadata.to_map(stream_mdata))
                             singer.write_record(stream_name, record)
                         else:
-                            singer.write(stream_name, json_message)
+                            singer.write_record(stream_name, json_message)
                         counter.increment()
                         num_rows = num_rows + 1
                         if stream_name in limit_not_possible:
diff --git a/tap_google_ads/sync.py b/tap_google_ads/sync.py
index 4a64fe0..cf5c765 100644
--- a/tap_google_ads/sync.py
+++ b/tap_google_ads/sync.py
@@ -74,7 +74,7 @@ def do_sync(config, catalog, resource_schema, state):
     # QA ADDED WORKAROUND [START]
 
     try:
-        customers = json.loads(config["customer_ids"])
+        customers = config["customer_ids"]
     except TypeError:  # falling back to raw value
         customers = config["login_customer_ids"]