marcosmarxm
commented
3 years ago @manavkohli thanks for reporting this. Looks is something with the stream name from Google Ads, did you choose segments.date as the primary key?
Closed manavkohli closed 3 years ago
marcosmarxm
commented
3 years ago @manavkohli thanks for reporting this. Looks is something with the stream name from Google Ads, did you choose segments.date as the primary key?
manavkohli
commented
3 years ago @marcosmarxm Yup that's what I chose!
sherifnada
commented
3 years ago my first guess is that this name is incompatible with normalization somehow. @ChristopheDuong are . allowed in column names?
ChristopheDuong
commented
3 years ago Special characters could be allowed in column names but if it’s failing on:
raise ValueError(f"Unsupported nested path {'.'.join(path)} for stream {self.stream_name}")
then it’s because the primary key was given as: [['segments', 'date']] instead of [['segments.date']] maybe?
Do you have the catalog.json?
sherifnada
commented
3 years ago hey guys, just a heads up that we're actively figuring out a solution to this issue. Will give an update soon.
Obolrus
commented
3 years ago Hello. Are any updates here?
I have the same issue with Google Ads → Google BigQuery and Facebook → Google BigQuery. Basic normalization doesn't work.
m-ronchi
commented
3 years ago I have the same problem.
basic normalization (with append or overwrite) generates a single table with columns named e.g. customer.id (schema declares them flattened), therefore I would expect a consistent handling of them.
my logs if needed: logs-306-2.txt
https://airbytehq.slack.com/archives/C01MFR03D5W/p1629733295044200
marcosmarxm
commented
3 years ago I tried to created a sync using Google Ads Integration Credentials.
The resulting catalog is, from source should be customer.id and becomes ["customer", "id"]:
"cursor_field": [
"segments.date"
],
"destination_sync_mode": "append_dedup",
"primary_key": [
[
"customer",
"id"
]
]
}I looked in the CDK code and there is no function splitting the primary key. So I tried to check the request from the webapp and looks there is a function splitting the primary key and also the cursor field using var.split(".")
This is not happening with the cursor field because is sourceDefined.
@Jamakase WDYT?
manavkohli
commented
3 years ago @sherifnada @marcosmarxm do you know if there's any update here possibly?
jamakase
commented
3 years ago @manavkohli this issue is in my todo list for this week. We hope to get it done within next few days.
manavkohli
commented
3 years ago @Jamakase amazing, thanks!
manavkohli
commented
3 years ago @cgardens do you have an idea of when this will go out? At this point this is blocking us from being able to use any bookmarking capabilities with the Google Ads source
jamakase
commented
3 years ago @manavkohli we already have a quick fix and it will be merged today.
LOG
``` 2021-07-29 21:34:21 INFO () WorkerRun(call):62 - Executing worker wrapper. Airbyte version: 0.29.0-alpha 2021-07-29 21:34:21 INFO () TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.29.0-alpha 2021-07-29 21:34:21 INFO () DefaultReplicationWorker(run):102 - start sync worker. job id: 149 attempt id: 1 2021-07-29 21:34:21 INFO () DefaultReplicationWorker(run):111 - configured sync modes: {null.ad_group_ads=full_refresh - overwrite, null.account_performance_report=incremental - append_dedup, null.accounts=full_refresh - overwrite, null.ad_groups=full_refresh - append, null.campaigns=full_refresh - overwrite, null.ad_group_ad_report=incremental - append_dedup, null.shopping_performance_report=incremental - append_dedup} 2021-07-29 21:34:21 INFO () DefaultAirbyteDestination(start):78 - Running destination... 2021-07-29 21:34:21 INFO () LineGobbler(voidCall):85 - Checking if airbyte/destination-postgres:0.3.6 exists... 2021-07-29 21:34:21 INFO () LineGobbler(voidCall):85 - airbyte/destination-postgres:0.3.6 was found locally. 2021-07-29 21:34:21 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/149/1 --network host --log-driver none airbyte/destination-postgres:0.3.6 write --config destination_config.json --catalog destination_catalog.json 2021-07-29 21:34:21 INFO () LineGobbler(voidCall):85 - Checking if airbyte/source-google-ads:0.1.4 exists... 2021-07-29 21:34:21 INFO () LineGobbler(voidCall):85 - airbyte/source-google-ads:0.1.4 was found locally. 2021-07-29 21:34:21 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/149/1 --network host --log-driver none airbyte/source-google-ads:0.1.4 read --config source_config.json --catalog source_catalog.json 2021-07-29 21:34:21 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):246 - Destination output thread started. 2021-07-29 21:34:21 INFO () DefaultReplicationWorker(run):139 - Waiting for source thread to join. 2021-07-29 21:34:21 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):210 - Replication thread started. 2021-07-29 21:34:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:34:22 [32mINFO[m i.a.i.d.p.PostgresDestination(main):83 - {} - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination 2021-07-29 21:34:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:34:22 [32mINFO[m i.a.i.b.IntegrationRunner(run):78 - {} - Running integration: io.airbyte.integrations.destination.postgres.PostgresDestination 2021-07-29 21:34:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:34:22 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):135 - {} - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json} 2021-07-29 21:34:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:34:22 [32mINFO[m i.a.i.b.IntegrationRunner(run):82 - {} - Command: WRITE 2021-07-29 21:34:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:34:22 [32mINFO[m i.a.i.b.IntegrationRunner(run):83 - {} - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'} 2021-07-29 21:34:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:34:22 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(startTracked):120 - {} - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started. 2021-07-29 21:34:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:34:22 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):145 - {} - Preparing tmp tables in destination started for 7 streams 2021-07-29 21:34:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:34:22 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream google_ads_account_performance_report. schema: aswemove, tmp table name: _airbyte_1627594462366__airbyte__raw_google_ads_account_performa 2021-07-29 21:34:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:34:22 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream google_ads_accounts. schema: aswemove, tmp table name: _airbyte_1627594462369__airbyte_raw_google_ads_accounts 2021-07-29 21:34:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:34:22 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream google_ads_ad_group_ad_report. schema: aswemove, tmp table name: _airbyte_1627594462369__airbyte__raw_google_ads_ad_group_ad_repo 2021-07-29 21:34:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:34:22 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream google_ads_ad_group_ads. schema: aswemove, tmp table name: _airbyte_1627594462369__airbyte_raw_google_ads_ad_group_ads 2021-07-29 21:34:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:34:22 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream google_ads_ad_groups. schema: aswemove, tmp table name: _airbyte_1627594462369__airbyte_raw_google_ads_ad_groups 2021-07-29 21:34:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:34:22 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream google_ads_campaigns. schema: aswemove, tmp table name: _airbyte_1627594462370__airbyte_raw_google_ads_campaigns 2021-07-29 21:34:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:34:22 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream google_ads_shopping_performance_report. schema: aswemove, tmp table name: _airbyte_1627594462370__airbyte__raw_google_ads_shopping_perform 2021-07-29 21:34:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:34:22 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):155 - {} - Preparing tables in destination completed. 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Starting syncing SourceGoogleAds 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Syncing stream: account_performance_report 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:33 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {} 2021-07-29 21:34:36 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {'segments.date': '2021-05-03'} 2021-07-29 21:34:37 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {'segments.date': '2021-06-03'} 2021-07-29 21:34:38 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {'segments.date': '2021-07-03'} 2021-07-29 21:34:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 1000 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of account_performance_report stream to {'segments.date': '2021-07-27'} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Read 1143 records from account_performance_report stream 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Syncing stream: accounts 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Read 1 records from accounts stream 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Syncing stream: ad_group_ad_report 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:00 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {} 2021-07-29 21:35:01 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {'segments.date': '2021-05-03'} 2021-07-29 21:35:03 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {'segments.date': '2021-06-03'} 2021-07-29 21:35:05 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {'segments.date': '2021-07-03'} 2021-07-29 21:35:06 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of ad_group_ad_report stream to {'segments.date': '2021-07-27'} 2021-07-29 21:35:06 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Read 378 records from ad_group_ad_report stream 2021-07-29 21:35:06 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Syncing stream: ad_group_ads 2021-07-29 21:35:06 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Read 8 records from ad_group_ads stream 2021-07-29 21:35:07 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Syncing stream: ad_groups 2021-07-29 21:35:07 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Read 8 records from ad_groups stream 2021-07-29 21:35:07 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Syncing stream: campaigns 2021-07-29 21:35:10 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Read 7 records from campaigns stream 2021-07-29 21:35:10 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Syncing stream: shopping_performance_report 2021-07-29 21:35:10 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:10 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {} 2021-07-29 21:35:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 2000 2021-07-29 21:35:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 3000 2021-07-29 21:35:34 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {'segments.date': '2021-05-03'} 2021-07-29 21:35:34 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 4000 2021-07-29 21:35:36 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 5000 2021-07-29 21:35:39 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {'segments.date': '2021-06-03'} 2021-07-29 21:35:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 6000 2021-07-29 21:35:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 7000 2021-07-29 21:35:45 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {'segments.date': '2021-07-03'} 2021-07-29 21:35:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 8000 2021-07-29 21:35:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 9000 2021-07-29 21:35:48 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Setting state of shopping_performance_report stream to {'segments.date': '2021-07-27'} 2021-07-29 21:35:48 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Read 8006 records from shopping_performance_report stream 2021-07-29 21:35:48 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Finished syncing SourceGoogleAds 2021-07-29 21:35:48 INFO () DefaultReplicationWorker(run):141 - Source thread complete. 2021-07-29 21:35:48 INFO () DefaultReplicationWorker(run):142 - Waiting for destination thread to join. 2021-07-29 21:35:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:48 [32mINFO[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):80 - {} - Airbyte message consumer: succeeded. 2021-07-29 21:35:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:48 [32mINFO[m i.a.i.d.b.BufferedStreamConsumer(close):190 - {} - executing on success close procedure. 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):182 - {} - Finalizing tables in destination started for 7 streams 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream google_ads_account_performance_report. schema aswemove, tmp table _airbyte_1627594462366__airbyte__raw_google_ads_account_performa, final table _airbyte_raw_google_ads_account_performance_report 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream google_ads_accounts. schema aswemove, tmp table _airbyte_1627594462369__airbyte_raw_google_ads_accounts, final table _airbyte_raw_google_ads_accounts 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream google_ads_ad_group_ad_report. schema aswemove, tmp table _airbyte_1627594462369__airbyte__raw_google_ads_ad_group_ad_repo, final table _airbyte_raw_google_ads_ad_group_ad_report 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream google_ads_ad_group_ads. schema aswemove, tmp table _airbyte_1627594462369__airbyte_raw_google_ads_ad_group_ads, final table _airbyte_raw_google_ads_ad_group_ads 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream google_ads_ad_groups. schema aswemove, tmp table _airbyte_1627594462369__airbyte_raw_google_ads_ad_groups, final table _airbyte_raw_google_ads_ad_groups 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream google_ads_campaigns. schema aswemove, tmp table _airbyte_1627594462370__airbyte_raw_google_ads_campaigns, final table _airbyte_raw_google_ads_campaigns 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream google_ads_shopping_performance_report. schema aswemove, tmp table _airbyte_1627594462370__airbyte__raw_google_ads_shopping_perform, final table _airbyte_raw_google_ads_shopping_performance_report 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):200 - {} - Executing finalization of tables. 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):202 - {} - Finalizing tables in destination completed. 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):205 - {} - Cleaning tmp tables in destination started for 7 streams 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream google_ads_account_performance_report. schema aswemove, tmp table name: _airbyte_1627594462366__airbyte__raw_google_ads_account_performa 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream google_ads_accounts. schema aswemove, tmp table name: _airbyte_1627594462369__airbyte_raw_google_ads_accounts 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream google_ads_ad_group_ad_report. schema aswemove, tmp table name: _airbyte_1627594462369__airbyte__raw_google_ads_ad_group_ad_repo 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream google_ads_ad_group_ads. schema aswemove, tmp table name: _airbyte_1627594462369__airbyte_raw_google_ads_ad_group_ads 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream google_ads_ad_groups. schema aswemove, tmp table name: _airbyte_1627594462369__airbyte_raw_google_ads_ad_groups 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream google_ads_campaigns. schema aswemove, tmp table name: _airbyte_1627594462370__airbyte_raw_google_ads_campaigns 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream google_ads_shopping_performance_report. schema aswemove, tmp table name: _airbyte_1627594462370__airbyte__raw_google_ads_shopping_perform 2021-07-29 21:35:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-29 21:35:49 [32mINFO[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):214 - {} - Cleaning tmp tables in destination completed. 2021-07-29 21:35:49 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):251 - state in DefaultReplicationWorker from Destination: io.airbyte.protocol.models.AirbyteMessage@6743f193[type=STATE,log=Happy to help - would love to connect with someone more familiar with this source as my first contribution here