Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Zendesk Talk appears to paginate results #6599

Closed
danieldiamond opened this issue Oct 1, 2021 · 7 comments · Fixed by #7173
Closed

Zendesk Talk appears to paginate results #6599

danieldiamond opened this issue Oct 1, 2021 · 7 comments · Fixed by #7173
Assignees
@keu
Labels
area/connectors Connector related issues connectors/source/zendesk-talk connectors/sources-api type/bug Something isn't working
Milestone
Connectors 2021-1...

Comments

@danieldiamond
Copy link
Contributor

Enviroment

  • Airbyte version: 0.30.2-alpha
  • OS Version / Instance: AWS EC2
  • Deployment: Docker
  • Source Connector and version: Zendesk Talk 0.1.2
  • Destination Connector and version: N/A (Redshift/Snowflake)
  • Severity: High
  • Step where error happened: Sync job

Current Behavior

Only receiving 1000 calls for each sync - the incremental append stream

Expected Behavior

I would expect all calls to be synced

Logs

LOG 

2021-10-01 00:01:34 INFO () WorkerRun(call):42 - Executing worker wrapper. Airbyte version: 0.30.2-alpha
2021-10-01 00:03:50 INFO () TemporalAttemptExecution(get):94 - Executing worker wrapper. Airbyte version: 0.30.2-alpha
2021-10-01 00:03:50 WARN () Databases(createPostgresDatabaseWithRetry):38 - Waiting for database to become available...
2021-10-01 00:03:50 INFO () JobsDatabaseInstance(lambda$static$2):25 - Testing if jobs database is ready...
2021-10-01 00:03:50 INFO () Databases(createPostgresDatabaseWithRetry):55 - Database available!
2021-10-01 00:03:50 INFO () DefaultReplicationWorker(run):82 - start sync worker. job id: 4077 attempt id: 0
2021-10-01 00:03:50 INFO () DefaultReplicationWorker(run):91 - configured sync modes: {null.current_queue_activity=full_refresh - append, null.ivrs=full_refresh - append, null.account_overview=full_refresh - append, null.greetings=full_refresh - append, null.call_legs=incremental - append, null.ivr_menus=full_refresh - append, null.agents_activity=full_refresh - append, null.addresses=full_refresh - append, null.agents_overview=full_refresh - append, null.greeting_categories=full_refresh - append, null.ivr_routes=full_refresh - append, null.calls=incremental - append, null.phone_numbers=full_refresh - append}
2021-10-01 00:03:50 INFO () DefaultAirbyteDestination(start):58 - Running destination...
2021-10-01 00:03:50 INFO () LineGobbler(voidCall):65 - Checking if airbyte/destination-snowflake:0.3.14 exists...
2021-10-01 00:03:51 INFO () LineGobbler(voidCall):65 - airbyte/destination-snowflake:0.3.14 was found locally.
2021-10-01 00:03:51 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/4077/0 --network host --log-driver none airbyte/destination-snowflake:0.3.14 write --config destination_config.json --catalog destination_catalog.json
2021-10-01 00:03:51 INFO () LineGobbler(voidCall):65 - Checking if airbyte/source-zendesk-talk:0.1.2 exists...
2021-10-01 00:03:51 INFO () LineGobbler(voidCall):65 - airbyte/source-zendesk-talk:0.1.2 was found locally.
2021-10-01 00:03:51 INFO () DockerProcessFactory(create):127 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/4077/0 --network host --log-driver none airbyte/source-zendesk-talk:0.1.2 read --config source_config.json --catalog source_catalog.json --state input_state.json
2021-10-01 00:03:51 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):226 - Destination output thread started.
2021-10-01 00:03:51 INFO () DefaultReplicationWorker(run):119 - Waiting for source thread to join.
2021-10-01 00:03:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):190 - Replication thread started.
2021-10-01 00:03:55 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:55 �[32mINFO�[m i.a.i.d.s.SnowflakeDestination(main):81 - {} - starting destination: class io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2021-10-01 00:03:55 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:55 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):96 - {} - Running integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2021-10-01 00:03:55 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:55 �[32mINFO�[m i.a.i.b.IntegrationCliParser(parseOptions):135 - {} - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2021-10-01 00:03:55 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:55 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):100 - {} - Command: WRITE
2021-10-01 00:03:55 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:55 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):101 - {} - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2021-10-01 00:03:55 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:55 �[33mWARN�[m c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-10-01 00:03:55 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:55 �[33mWARN�[m c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-10-01 00:03:55 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:55 �[33mWARN�[m c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-10-01 00:03:55 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:55 �[33mWARN�[m c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2021-10-01 00:03:55 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:55 �[32mINFO�[m i.a.i.d.j.c.SwitchingDestination(getConsumer):83 - {} - Using destination type: COPY_S3
2021-10-01 00:03:55 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:55 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(<init>):142 - {} - S3 upload part size: 10 MB
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/rvp_account_overview with full ID xQYW554MyR_sIM508r8bxxEszRUgQlt5v7Yl6IoG1rFFUr7l6tqlWOpqjUdyHkadGaAIgcVOh2zOhrkvf2672zodLA6uVuLf4Qr1UA1tr09ec2F6obnnwAsbRNm6HzWw
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(<init>):142 - {} - S3 upload part size: 10 MB
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/ded_addresses with full ID blu345.0BZcDqvSPikngGGzzhm2c4zk5BQf48ZsgS8hn7DgVS5tFzlR5zZL6Vef_bPqGHk1e5L8Q9SVBlAXlO.IarNBL4_IzzMhYl_9sWbK7i1ArMGfurks75YTRYvy.
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(<init>):142 - {} - S3 upload part size: 10 MB
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/sec_agents_activity with full ID LdjBHjuQsL9_eXlEYL_lFtRIe_6.2HBR0NwXKBM0hmDGEA5M16LGhUwuLUq2DjkIRNzA6lbW1u9DoKeQpOGqloj3hJ0BTkmDKI1R9Ft5FzDoGXKEnjYBkyB7Ewm5.bJW
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(<init>):142 - {} - S3 upload part size: 10 MB
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Starting syncing SourceZendeskTalk
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing account_overview stream
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing addresses stream
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing agents_activity stream
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/jat_agents_overview with full ID QrN8Knl1Z6LqLZtPTOkoPvlPbyJQi.QBC5tCaK8zcZF3iTqOEckNFO8KnetkcggJCtQI8c5zWsSkVuyMoGGOWvqhmy4re2SREM2QlhgIQuFq_alv17nvuq_qDCKA8exY
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(<init>):142 - {} - S3 upload part size: 10 MB
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/zwf_call_legs with full ID 9yiUC2PCgXvORgmtMciYzr9tEm5p5YNbXp8jWTONK1gp2gMZuOaGOymBwS9Ut69kjehTCkT0LIx.6BjcEHIWZMiyqymi0DFDkQjrGdAB4kqrOcnIhcIeUIVeOqEweBO0
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(<init>):142 - {} - S3 upload part size: 10 MB
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/xwa_calls with full ID kjTUvIC6pyn9jHt_LUcFAChgt7a1z2gzej53SCJm97rADoSNkUGr.D_ML9dE7g4S0vzK20nS5kUBk8cPc.VQbb1mIqeufwOwKp4tUC9UAC2m5u.kL1GHogILm1k6dYn.
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(<init>):142 - {} - S3 upload part size: 10 MB
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/uzp_current_queue_activity with full ID PDhCdS2S8x8TFxTR840jtN6pL00q17KTcjjPxlcClTjG6LOLbVtidLUM_12KbJaFSEvAp621OFA08HfzMyaerRhxHO.e6pXfN6gyyKEAU62HVllxSy0SYmtLVliIDR6o
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(<init>):142 - {} - S3 upload part size: 10 MB
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/beh_greeting_categories with full ID 1Wk3ZBUlBeTR4xU_O70rojvLh10ZUI4rLZ6880I98vc.l.t73vcdkSKnKT89aq8jWHDRT1KXql2zG_QwadSqfxyPfo3tqhtQEEgdZSs_2REoC2v3GbX6RaBV7x3dvp98
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(<init>):142 - {} - S3 upload part size: 10 MB
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/zqf_greetings with full ID X1z553D05PQ3xIRDZ45KHFLF9jvAm_P1EAHrlOA8emobJZ1wrZaI9dxtcRkTOTbgp4ZAAhR_4WFz2972SWNuSxbtmtlR0xAW0eiCQqZah93ohCmAL1pNxs2m6BMv8cFo
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(<init>):142 - {} - S3 upload part size: 10 MB
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/fln_ivr_menus with full ID x.Uz5R7.ovb6qUYTzQPezcpOJK8SAGgzDaMM030g7SuhaaBRivGielJUX3UKaH5nyclyf58DVXRfxuwJu93oYVMQ_XiAAvporK8bwtJerCym1k1ZLjObBcEN.AvHBqa6
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(<init>):142 - {} - S3 upload part size: 10 MB
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/ryg_ivr_routes with full ID gALpARzfUJkGoc6Gjvszwu4lc.hrG5QmnvNKrl8k9xC5IV4.mgSaHUGLZMaWzy0piTxlcf3dBF1M6tZhOwK_lIcoSN8fpjwV4WmFVJo9GnONffgLiVlSU._UcJ_PyQ1K
2021-10-01 00:03:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(<init>):142 - {} - S3 upload part size: 10 MB
2021-10-01 00:03:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:57 �[32mINFO�[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/wgm_ivrs with full ID 8C_d9zfW9vH51mZm0hnN4GF9k7dImwpkIrR2mal9OrPlN6jUkxfZWKoaW_xXFcDXi7EQ.0UzB0SbpQv0U27q1tuUtTPt0XAO10yjiz66WKHSjnF7NcyxMcvAeHZuCBib
2021-10-01 00:03:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:57 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(<init>):142 - {} - S3 upload part size: 10 MB
2021-10-01 00:03:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:57 �[32mINFO�[m a.m.s.StreamTransferManager(getMultiPartOutputStreams):329 - {} - Initiated multipart upload to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/dtb_phone_numbers with full ID hTsI0qgs2GuTejl4xfH_RwGBAyTXyVFNm2eQU3eRok_ExEnA3mrPwSRpRi0ULEmJDTyVYOIhzVKqJHcXKF0URcYlZwd9R4FA52dJhCcOh_6jJipbkdgoTVmZfFh99wsq
2021-10-01 00:03:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:03:57 �[32mINFO�[m i.a.i.d.b.BufferedStreamConsumer(startTracked):143 - {} - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2021-10-01 00:03:58 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing agents_overview stream
2021-10-01 00:03:58 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Set state of call_legs stream to {'timestamp': '2020-01-27T23:05:45+00:00'}
2021-10-01 00:03:58 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing call_legs stream
2021-10-01 00:03:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 1000
2021-10-01 00:04:01 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Advancing bookmark for CallLegs stream from 2020-01-27T23:05:45+00:00 to 2020-01-29T14:31:19+00:00
2021-10-01 00:04:01 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Set state of calls stream to {'timestamp': '2020-02-15T06:18:48+00:00'}
2021-10-01 00:04:01 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing calls stream
2021-10-01 00:04:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):203 - Records read: 2000
2021-10-01 00:04:02 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Advancing bookmark for Calls stream from 2020-02-15T06:18:48+00:00 to 2020-02-18T20:49:59+00:00
2021-10-01 00:04:02 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing current_queue_activity stream
2021-10-01 00:04:02 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing greeting_categories stream
2021-10-01 00:04:04 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing greetings stream
2021-10-01 00:04:05 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing ivr_menus stream
2021-10-01 00:04:11 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing ivr_routes stream
2021-10-01 00:04:11 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing ivrs stream
2021-10-01 00:04:16 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Syncing phone_numbers stream
2021-10-01 00:04:16 INFO () DefaultAirbyteStreamFactory(internalLog):90 - Finished syncing SourceZendeskTalk
2021-10-01 00:04:17 INFO () DefaultReplicationWorker(run):121 - Source thread complete.
2021-10-01 00:04:17 INFO () DefaultReplicationWorker(run):122 - Waiting for destination thread to join.
2021-10-01 00:04:17 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:17 �[32mINFO�[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):80 - {} - Airbyte message consumer: succeeded.
2021-10-01 00:04:17 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:17 �[32mINFO�[m i.a.i.d.b.BufferedStreamConsumer(close):212 - {} - executing on success close procedure.
2021-10-01 00:04:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:18 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):237 - {} - Uploading remaining data for call_legs stream.
2021-10-01 00:04:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:18 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:18 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:18 �[33mWARN�[m a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-10-01 00:04:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:18 �[32mINFO�[m a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/zwf_call_legs with id 9yiUC2PCg...eOqEweBO0]: Uploading leftover stream [Part number 1 containing 0.65 MB]
2021-10-01 00:04:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:18 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/zwf_call_legs with id 9yiUC2PCg...eOqEweBO0]: Finished uploading [Part number 1 containing 0.65 MB]
2021-10-01 00:04:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:18 �[32mINFO�[m a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/zwf_call_legs with id 9yiUC2PCg...eOqEweBO0]: Completed
2021-10-01 00:04:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:18 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):241 - {} - All data for call_legs stream uploaded.
2021-10-01 00:04:18 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:18 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):177 - {} - Creating schema in destination if it doesn't exist: zendesk_talk
2021-10-01 00:04:19 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:19 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):183 - {} - Preparing tmp table in destination for stream: call_legs, schema: zendesk_talk, tmp table name: _airbyte_tmp_gur_call_legs.
2021-10-01 00:04:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:20 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):189 - {} - Starting copy to tmp table: _airbyte_tmp_gur_call_legs in destination for stream: call_legs, schema: zendesk_talk, .
2021-10-01 00:04:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:25 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):191 - {} - Copy to tmp table _airbyte_tmp_gur_call_legs in destination for stream call_legs complete.
2021-10-01 00:04:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:25 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):197 - {} - Preparing table _airbyte_raw_call_legs in destination.
2021-10-01 00:04:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:25 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):199 - {} - Table _airbyte_tmp_gur_call_legs in destination prepared.
2021-10-01 00:04:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:25 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):206 - {} - Preparing to merge tmp table _airbyte_tmp_gur_call_legs to dest table: _airbyte_raw_call_legs, schema: zendesk_talk, in destination.
2021-10-01 00:04:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:25 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):237 - {} - Uploading remaining data for greetings stream.
2021-10-01 00:04:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:25 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:25 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:25 �[33mWARN�[m a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-10-01 00:04:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:25 �[32mINFO�[m a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/zqf_greetings with id X1z553D05...m6BMv8cFo]: Uploading leftover stream [Part number 1 containing 0.07 MB]
2021-10-01 00:04:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:25 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/zqf_greetings with id X1z553D05...m6BMv8cFo]: Finished uploading [Part number 1 containing 0.07 MB]
2021-10-01 00:04:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:25 �[32mINFO�[m a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/zqf_greetings with id X1z553D05...m6BMv8cFo]: Completed
2021-10-01 00:04:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:25 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):241 - {} - All data for greetings stream uploaded.
2021-10-01 00:04:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:25 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):177 - {} - Creating schema in destination if it doesn't exist: zendesk_talk
2021-10-01 00:04:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:26 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):183 - {} - Preparing tmp table in destination for stream: greetings, schema: zendesk_talk, tmp table name: _airbyte_tmp_bbf_greetings.
2021-10-01 00:04:27 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:27 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):189 - {} - Starting copy to tmp table: _airbyte_tmp_bbf_greetings in destination for stream: greetings, schema: zendesk_talk, .
2021-10-01 00:04:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:29 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):191 - {} - Copy to tmp table _airbyte_tmp_bbf_greetings in destination for stream greetings complete.
2021-10-01 00:04:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:29 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):197 - {} - Preparing table _airbyte_raw_greetings in destination.
2021-10-01 00:04:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:29 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):199 - {} - Table _airbyte_tmp_bbf_greetings in destination prepared.
2021-10-01 00:04:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:29 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):206 - {} - Preparing to merge tmp table _airbyte_tmp_bbf_greetings to dest table: _airbyte_raw_greetings, schema: zendesk_talk, in destination.
2021-10-01 00:04:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:29 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):237 - {} - Uploading remaining data for phone_numbers stream.
2021-10-01 00:04:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:29 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:29 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:29 �[33mWARN�[m a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-10-01 00:04:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:29 �[32mINFO�[m a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/dtb_phone_numbers with id hTsI0qgs2...ZfFh99wsq]: Uploading leftover stream [Part number 1 containing 0.04 MB]
2021-10-01 00:04:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:29 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/dtb_phone_numbers with id hTsI0qgs2...ZfFh99wsq]: Finished uploading [Part number 1 containing 0.04 MB]
2021-10-01 00:04:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:29 �[32mINFO�[m a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/dtb_phone_numbers with id hTsI0qgs2...ZfFh99wsq]: Completed
2021-10-01 00:04:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:29 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):241 - {} - All data for phone_numbers stream uploaded.
2021-10-01 00:04:29 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:29 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):177 - {} - Creating schema in destination if it doesn't exist: zendesk_talk
2021-10-01 00:04:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:30 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):183 - {} - Preparing tmp table in destination for stream: phone_numbers, schema: zendesk_talk, tmp table name: _airbyte_tmp_dqz_phone_numbers.
2021-10-01 00:04:30 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:30 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):189 - {} - Starting copy to tmp table: _airbyte_tmp_dqz_phone_numbers in destination for stream: phone_numbers, schema: zendesk_talk, .
2021-10-01 00:04:32 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:32 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):191 - {} - Copy to tmp table _airbyte_tmp_dqz_phone_numbers in destination for stream phone_numbers complete.
2021-10-01 00:04:32 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:32 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):197 - {} - Preparing table _airbyte_raw_phone_numbers in destination.
2021-10-01 00:04:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:33 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):199 - {} - Table _airbyte_tmp_dqz_phone_numbers in destination prepared.
2021-10-01 00:04:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:33 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):206 - {} - Preparing to merge tmp table _airbyte_tmp_dqz_phone_numbers to dest table: _airbyte_raw_phone_numbers, schema: zendesk_talk, in destination.
2021-10-01 00:04:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:33 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):237 - {} - Uploading remaining data for account_overview stream.
2021-10-01 00:04:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:33 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:33 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:33 �[33mWARN�[m a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-10-01 00:04:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:33 �[32mINFO�[m a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/rvp_account_overview with id xQYW554My...bRNm6HzWw]: Uploading leftover stream [Part number 1 containing 0.00 MB]
2021-10-01 00:04:33 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:33 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/rvp_account_overview with id xQYW554My...bRNm6HzWw]: Finished uploading [Part number 1 containing 0.00 MB]
2021-10-01 00:04:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:34 �[32mINFO�[m a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/rvp_account_overview with id xQYW554My...bRNm6HzWw]: Completed
2021-10-01 00:04:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:34 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):241 - {} - All data for account_overview stream uploaded.
2021-10-01 00:04:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:34 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):177 - {} - Creating schema in destination if it doesn't exist: zendesk_talk
2021-10-01 00:04:34 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:34 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):183 - {} - Preparing tmp table in destination for stream: account_overview, schema: zendesk_talk, tmp table name: _airbyte_tmp_xbe_account_overview.
2021-10-01 00:04:35 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:35 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):189 - {} - Starting copy to tmp table: _airbyte_tmp_xbe_account_overview in destination for stream: account_overview, schema: zendesk_talk, .
2021-10-01 00:04:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:37 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):191 - {} - Copy to tmp table _airbyte_tmp_xbe_account_overview in destination for stream account_overview complete.
2021-10-01 00:04:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:37 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):197 - {} - Preparing table _airbyte_raw_account_overview in destination.
2021-10-01 00:04:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:37 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):199 - {} - Table _airbyte_tmp_xbe_account_overview in destination prepared.
2021-10-01 00:04:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:37 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):206 - {} - Preparing to merge tmp table _airbyte_tmp_xbe_account_overview to dest table: _airbyte_raw_account_overview, schema: zendesk_talk, in destination.
2021-10-01 00:04:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:37 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):237 - {} - Uploading remaining data for addresses stream.
2021-10-01 00:04:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:37 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:37 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:37 �[33mWARN�[m a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-10-01 00:04:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:37 �[32mINFO�[m a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/ded_addresses with id blu345.0B...75YTRYvy.]: Uploading leftover stream [Part number 1 containing 0.00 MB]
2021-10-01 00:04:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:37 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/ded_addresses with id blu345.0B...75YTRYvy.]: Finished uploading [Part number 1 containing 0.00 MB]
2021-10-01 00:04:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:38 �[32mINFO�[m a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/ded_addresses with id blu345.0B...75YTRYvy.]: Completed
2021-10-01 00:04:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:38 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):241 - {} - All data for addresses stream uploaded.
2021-10-01 00:04:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:38 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):177 - {} - Creating schema in destination if it doesn't exist: zendesk_talk
2021-10-01 00:04:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:38 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):183 - {} - Preparing tmp table in destination for stream: addresses, schema: zendesk_talk, tmp table name: _airbyte_tmp_jxm_addresses.
2021-10-01 00:04:39 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:39 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):189 - {} - Starting copy to tmp table: _airbyte_tmp_jxm_addresses in destination for stream: addresses, schema: zendesk_talk, .
2021-10-01 00:04:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:40 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):191 - {} - Copy to tmp table _airbyte_tmp_jxm_addresses in destination for stream addresses complete.
2021-10-01 00:04:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:40 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):197 - {} - Preparing table _airbyte_raw_addresses in destination.
2021-10-01 00:04:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:41 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):199 - {} - Table _airbyte_tmp_jxm_addresses in destination prepared.
2021-10-01 00:04:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:41 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):206 - {} - Preparing to merge tmp table _airbyte_tmp_jxm_addresses to dest table: _airbyte_raw_addresses, schema: zendesk_talk, in destination.
2021-10-01 00:04:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:41 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):237 - {} - Uploading remaining data for calls stream.
2021-10-01 00:04:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:41 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:41 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:41 �[33mWARN�[m a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-10-01 00:04:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:41 �[32mINFO�[m a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/xwa_calls with id kjTUvIC6p...Lm1k6dYn.]: Uploading leftover stream [Part number 1 containing 1.13 MB]
2021-10-01 00:04:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:41 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/xwa_calls with id kjTUvIC6p...Lm1k6dYn.]: Finished uploading [Part number 1 containing 1.13 MB]
2021-10-01 00:04:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:41 �[32mINFO�[m a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/xwa_calls with id kjTUvIC6p...Lm1k6dYn.]: Completed
2021-10-01 00:04:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:41 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):241 - {} - All data for calls stream uploaded.
2021-10-01 00:04:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:41 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):177 - {} - Creating schema in destination if it doesn't exist: zendesk_talk
2021-10-01 00:04:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:41 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):183 - {} - Preparing tmp table in destination for stream: calls, schema: zendesk_talk, tmp table name: _airbyte_tmp_ebs_calls.
2021-10-01 00:04:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:42 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):189 - {} - Starting copy to tmp table: _airbyte_tmp_ebs_calls in destination for stream: calls, schema: zendesk_talk, .
2021-10-01 00:04:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:44 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):191 - {} - Copy to tmp table _airbyte_tmp_ebs_calls in destination for stream calls complete.
2021-10-01 00:04:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:44 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):197 - {} - Preparing table _airbyte_raw_calls in destination.
2021-10-01 00:04:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:45 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):199 - {} - Table _airbyte_tmp_ebs_calls in destination prepared.
2021-10-01 00:04:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:45 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):206 - {} - Preparing to merge tmp table _airbyte_tmp_ebs_calls to dest table: _airbyte_raw_calls, schema: zendesk_talk, in destination.
2021-10-01 00:04:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:45 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):237 - {} - Uploading remaining data for ivr_menus stream.
2021-10-01 00:04:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:45 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:45 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:45 �[33mWARN�[m a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-10-01 00:04:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:45 �[32mINFO�[m a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/fln_ivr_menus with id x.Uz5R7.o...N.AvHBqa6]: Uploading leftover stream [Part number 1 containing 0.00 MB]
2021-10-01 00:04:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:45 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/fln_ivr_menus with id x.Uz5R7.o...N.AvHBqa6]: Finished uploading [Part number 1 containing 0.00 MB]
2021-10-01 00:04:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:45 �[32mINFO�[m a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/fln_ivr_menus with id x.Uz5R7.o...N.AvHBqa6]: Completed
2021-10-01 00:04:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:45 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):241 - {} - All data for ivr_menus stream uploaded.
2021-10-01 00:04:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:45 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):177 - {} - Creating schema in destination if it doesn't exist: zendesk_talk
2021-10-01 00:04:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:46 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):183 - {} - Preparing tmp table in destination for stream: ivr_menus, schema: zendesk_talk, tmp table name: _airbyte_tmp_lzt_ivr_menus.
2021-10-01 00:04:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:46 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):189 - {} - Starting copy to tmp table: _airbyte_tmp_lzt_ivr_menus in destination for stream: ivr_menus, schema: zendesk_talk, .
2021-10-01 00:04:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:48 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):191 - {} - Copy to tmp table _airbyte_tmp_lzt_ivr_menus in destination for stream ivr_menus complete.
2021-10-01 00:04:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:48 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):197 - {} - Preparing table _airbyte_raw_ivr_menus in destination.
2021-10-01 00:04:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:48 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):199 - {} - Table _airbyte_tmp_lzt_ivr_menus in destination prepared.
2021-10-01 00:04:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:48 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):206 - {} - Preparing to merge tmp table _airbyte_tmp_lzt_ivr_menus to dest table: _airbyte_raw_ivr_menus, schema: zendesk_talk, in destination.
2021-10-01 00:04:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:48 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):237 - {} - Uploading remaining data for agents_activity stream.
2021-10-01 00:04:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:48 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:48 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:48 �[33mWARN�[m a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-10-01 00:04:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:48 �[32mINFO�[m a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/sec_agents_activity with id LdjBHjuQs...7Ewm5.bJW]: Uploading leftover stream [Part number 1 containing 0.03 MB]
2021-10-01 00:04:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:49 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/sec_agents_activity with id LdjBHjuQs...7Ewm5.bJW]: Finished uploading [Part number 1 containing 0.03 MB]
2021-10-01 00:04:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:49 �[32mINFO�[m a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/sec_agents_activity with id LdjBHjuQs...7Ewm5.bJW]: Completed
2021-10-01 00:04:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:49 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):241 - {} - All data for agents_activity stream uploaded.
2021-10-01 00:04:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:49 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):177 - {} - Creating schema in destination if it doesn't exist: zendesk_talk
2021-10-01 00:04:49 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:49 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):183 - {} - Preparing tmp table in destination for stream: agents_activity, schema: zendesk_talk, tmp table name: _airbyte_tmp_vug_agents_activity.
2021-10-01 00:04:50 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:50 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):189 - {} - Starting copy to tmp table: _airbyte_tmp_vug_agents_activity in destination for stream: agents_activity, schema: zendesk_talk, .
2021-10-01 00:04:52 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:52 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):191 - {} - Copy to tmp table _airbyte_tmp_vug_agents_activity in destination for stream agents_activity complete.
2021-10-01 00:04:52 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:52 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):197 - {} - Preparing table _airbyte_raw_agents_activity in destination.
2021-10-01 00:04:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:53 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):199 - {} - Table _airbyte_tmp_vug_agents_activity in destination prepared.
2021-10-01 00:04:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:53 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):206 - {} - Preparing to merge tmp table _airbyte_tmp_vug_agents_activity to dest table: _airbyte_raw_agents_activity, schema: zendesk_talk, in destination.
2021-10-01 00:04:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:53 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):237 - {} - Uploading remaining data for current_queue_activity stream.
2021-10-01 00:04:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:53 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:53 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:53 �[33mWARN�[m a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-10-01 00:04:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:53 �[32mINFO�[m a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/uzp_current_queue_activity with id PDhCdS2S8...LVliIDR6o]: Uploading leftover stream [Part number 1 containing 0.00 MB]
2021-10-01 00:04:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:53 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/uzp_current_queue_activity with id PDhCdS2S8...LVliIDR6o]: Finished uploading [Part number 1 containing 0.00 MB]
2021-10-01 00:04:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:53 �[32mINFO�[m a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/uzp_current_queue_activity with id PDhCdS2S8...LVliIDR6o]: Completed
2021-10-01 00:04:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:53 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):241 - {} - All data for current_queue_activity stream uploaded.
2021-10-01 00:04:53 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:53 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):177 - {} - Creating schema in destination if it doesn't exist: zendesk_talk
2021-10-01 00:04:54 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:54 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):183 - {} - Preparing tmp table in destination for stream: current_queue_activity, schema: zendesk_talk, tmp table name: _airbyte_tmp_vlz_current_queue_activity.
2021-10-01 00:04:54 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:54 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):189 - {} - Starting copy to tmp table: _airbyte_tmp_vlz_current_queue_activity in destination for stream: current_queue_activity, schema: zendesk_talk, .
2021-10-01 00:04:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):191 - {} - Copy to tmp table _airbyte_tmp_vlz_current_queue_activity in destination for stream current_queue_activity complete.
2021-10-01 00:04:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):197 - {} - Preparing table _airbyte_raw_current_queue_activity in destination.
2021-10-01 00:04:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):199 - {} - Table _airbyte_tmp_vlz_current_queue_activity in destination prepared.
2021-10-01 00:04:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):206 - {} - Preparing to merge tmp table _airbyte_tmp_vlz_current_queue_activity to dest table: _airbyte_raw_current_queue_activity, schema: zendesk_talk, in destination.
2021-10-01 00:04:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:56 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):237 - {} - Uploading remaining data for ivr_routes stream.
2021-10-01 00:04:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:56 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:56 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:04:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:56 �[33mWARN�[m a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-10-01 00:04:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:56 �[32mINFO�[m a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/ryg_ivr_routes with id gALpARzfU...UcJ_PyQ1K]: Uploading leftover stream [Part number 1 containing 0.00 MB]
2021-10-01 00:04:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:57 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/ryg_ivr_routes with id gALpARzfU...UcJ_PyQ1K]: Finished uploading [Part number 1 containing 0.00 MB]
2021-10-01 00:04:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:57 �[32mINFO�[m a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/ryg_ivr_routes with id gALpARzfU...UcJ_PyQ1K]: Completed
2021-10-01 00:04:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:57 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):241 - {} - All data for ivr_routes stream uploaded.
2021-10-01 00:04:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:57 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):177 - {} - Creating schema in destination if it doesn't exist: zendesk_talk
2021-10-01 00:04:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:57 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):183 - {} - Preparing tmp table in destination for stream: ivr_routes, schema: zendesk_talk, tmp table name: _airbyte_tmp_xyp_ivr_routes.
2021-10-01 00:04:58 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:04:58 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):189 - {} - Starting copy to tmp table: _airbyte_tmp_xyp_ivr_routes in destination for stream: ivr_routes, schema: zendesk_talk, .
2021-10-01 00:05:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:00 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):191 - {} - Copy to tmp table _airbyte_tmp_xyp_ivr_routes in destination for stream ivr_routes complete.
2021-10-01 00:05:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:00 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):197 - {} - Preparing table _airbyte_raw_ivr_routes in destination.
2021-10-01 00:05:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:00 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):199 - {} - Table _airbyte_tmp_xyp_ivr_routes in destination prepared.
2021-10-01 00:05:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:00 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):206 - {} - Preparing to merge tmp table _airbyte_tmp_xyp_ivr_routes to dest table: _airbyte_raw_ivr_routes, schema: zendesk_talk, in destination.
2021-10-01 00:05:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:00 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):237 - {} - Uploading remaining data for agents_overview stream.
2021-10-01 00:05:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:00 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:05:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:00 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:05:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:00 �[33mWARN�[m a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-10-01 00:05:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:00 �[32mINFO�[m a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/jat_agents_overview with id QrN8Knl1Z...qDCKA8exY]: Uploading leftover stream [Part number 1 containing 0.00 MB]
2021-10-01 00:05:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:00 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/jat_agents_overview with id QrN8Knl1Z...qDCKA8exY]: Finished uploading [Part number 1 containing 0.00 MB]
2021-10-01 00:05:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:00 �[32mINFO�[m a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/jat_agents_overview with id QrN8Knl1Z...qDCKA8exY]: Completed
2021-10-01 00:05:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:00 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):241 - {} - All data for agents_overview stream uploaded.
2021-10-01 00:05:00 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:00 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):177 - {} - Creating schema in destination if it doesn't exist: zendesk_talk
2021-10-01 00:05:01 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:01 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):183 - {} - Preparing tmp table in destination for stream: agents_overview, schema: zendesk_talk, tmp table name: _airbyte_tmp_yvp_agents_overview.
2021-10-01 00:05:02 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:02 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):189 - {} - Starting copy to tmp table: _airbyte_tmp_yvp_agents_overview in destination for stream: agents_overview, schema: zendesk_talk, .
2021-10-01 00:05:03 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:03 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):191 - {} - Copy to tmp table _airbyte_tmp_yvp_agents_overview in destination for stream agents_overview complete.
2021-10-01 00:05:03 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:03 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):197 - {} - Preparing table _airbyte_raw_agents_overview in destination.
2021-10-01 00:05:04 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:04 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):199 - {} - Table _airbyte_tmp_yvp_agents_overview in destination prepared.
2021-10-01 00:05:04 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:04 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):206 - {} - Preparing to merge tmp table _airbyte_tmp_yvp_agents_overview to dest table: _airbyte_raw_agents_overview, schema: zendesk_talk, in destination.
2021-10-01 00:05:04 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:04 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):237 - {} - Uploading remaining data for ivrs stream.
2021-10-01 00:05:04 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:04 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:05:04 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:04 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:05:04 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:04 �[33mWARN�[m a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-10-01 00:05:04 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:04 �[32mINFO�[m a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/wgm_ivrs with id 8C_d9zfW9...AeHZuCBib]: Uploading leftover stream [Part number 1 containing 0.00 MB]
2021-10-01 00:05:04 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:04 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/wgm_ivrs with id 8C_d9zfW9...AeHZuCBib]: Finished uploading [Part number 1 containing 0.00 MB]
2021-10-01 00:05:04 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:04 �[32mINFO�[m a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/wgm_ivrs with id 8C_d9zfW9...AeHZuCBib]: Completed
2021-10-01 00:05:04 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:04 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):241 - {} - All data for ivrs stream uploaded.
2021-10-01 00:05:04 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:04 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):177 - {} - Creating schema in destination if it doesn't exist: zendesk_talk
2021-10-01 00:05:05 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:05 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):183 - {} - Preparing tmp table in destination for stream: ivrs, schema: zendesk_talk, tmp table name: _airbyte_tmp_lzt_ivrs.
2021-10-01 00:05:05 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:05 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):189 - {} - Starting copy to tmp table: _airbyte_tmp_lzt_ivrs in destination for stream: ivrs, schema: zendesk_talk, .
2021-10-01 00:05:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:07 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):191 - {} - Copy to tmp table _airbyte_tmp_lzt_ivrs in destination for stream ivrs complete.
2021-10-01 00:05:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:07 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):197 - {} - Preparing table _airbyte_raw_ivrs in destination.
2021-10-01 00:05:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:07 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):199 - {} - Table _airbyte_tmp_lzt_ivrs in destination prepared.
2021-10-01 00:05:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:07 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):206 - {} - Preparing to merge tmp table _airbyte_tmp_lzt_ivrs to dest table: _airbyte_raw_ivrs, schema: zendesk_talk, in destination.
2021-10-01 00:05:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:07 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):237 - {} - Uploading remaining data for greeting_categories stream.
2021-10-01 00:05:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:07 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:05:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:07 �[32mINFO�[m a.m.s.MultiPartOutputStream(close):158 - {} - Called close() on [MultipartOutputStream for parts 1 - 10000]
2021-10-01 00:05:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:07 �[33mWARN�[m a.m.s.MultiPartOutputStream(close):160 - {} - [MultipartOutputStream for parts 1 - 10000] is already closed
2021-10-01 00:05:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:07 �[32mINFO�[m a.m.s.StreamTransferManager(complete):367 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/beh_greeting_categories with id 1Wk3ZBUlB...V7x3dvp98]: Uploading leftover stream [Part number 1 containing 0.00 MB]
2021-10-01 00:05:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:07 �[32mINFO�[m a.m.s.StreamTransferManager(uploadStreamPart):558 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/beh_greeting_categories with id 1Wk3ZBUlB...V7x3dvp98]: Finished uploading [Part number 1 containing 0.00 MB]
2021-10-01 00:05:08 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:08 �[32mINFO�[m a.m.s.StreamTransferManager(complete):395 - {} - [Manager uploading to mybucket/eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/beh_greeting_categories with id 1Wk3ZBUlB...V7x3dvp98]: Completed
2021-10-01 00:05:08 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:08 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(closeAndWaitForUpload):241 - {} - All data for greeting_categories stream uploaded.
2021-10-01 00:05:08 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:08 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationSchema):177 - {} - Creating schema in destination if it doesn't exist: zendesk_talk
2021-10-01 00:05:08 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:08 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createTemporaryTable):183 - {} - Preparing tmp table in destination for stream: greeting_categories, schema: zendesk_talk, tmp table name: _airbyte_tmp_efu_greeting_categories.
2021-10-01 00:05:09 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:09 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):189 - {} - Starting copy to tmp table: _airbyte_tmp_efu_greeting_categories in destination for stream: greeting_categories, schema: zendesk_talk, .
2021-10-01 00:05:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:25 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(copyStagingFileToTemporaryTable):191 - {} - Copy to tmp table _airbyte_tmp_efu_greeting_categories in destination for stream greeting_categories complete.
2021-10-01 00:05:25 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:25 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):197 - {} - Preparing table _airbyte_raw_greeting_categories in destination.
2021-10-01 00:05:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:26 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(createDestinationTable):199 - {} - Table _airbyte_tmp_efu_greeting_categories in destination prepared.
2021-10-01 00:05:26 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:26 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(generateMergeStatement):206 - {} - Preparing to merge tmp table _airbyte_tmp_efu_greeting_categories to dest table: _airbyte_raw_greeting_categories, schema: zendesk_talk, in destination.
2021-10-01 00:05:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:40 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):218 - {} - Begin cleaning s3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/zwf_call_legs.
2021-10-01 00:05:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:40 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):222 - {} - S3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/zwf_call_legs cleaned.
2021-10-01 00:05:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:40 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):224 - {} - Begin cleaning _airbyte_tmp_gur_call_legs tmp table in destination.
2021-10-01 00:05:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:41 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):226 - {} - _airbyte_tmp_gur_call_legs tmp table in destination cleaned.
2021-10-01 00:05:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:41 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):218 - {} - Begin cleaning s3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/zqf_greetings.
2021-10-01 00:05:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:41 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):222 - {} - S3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/zqf_greetings cleaned.
2021-10-01 00:05:41 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:41 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):224 - {} - Begin cleaning _airbyte_tmp_bbf_greetings tmp table in destination.
2021-10-01 00:05:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:42 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):226 - {} - _airbyte_tmp_bbf_greetings tmp table in destination cleaned.
2021-10-01 00:05:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:42 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):218 - {} - Begin cleaning s3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/dtb_phone_numbers.
2021-10-01 00:05:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:42 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):222 - {} - S3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/dtb_phone_numbers cleaned.
2021-10-01 00:05:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:42 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):224 - {} - Begin cleaning _airbyte_tmp_dqz_phone_numbers tmp table in destination.
2021-10-01 00:05:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:42 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):226 - {} - _airbyte_tmp_dqz_phone_numbers tmp table in destination cleaned.
2021-10-01 00:05:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:42 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):218 - {} - Begin cleaning s3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/rvp_account_overview.
2021-10-01 00:05:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:42 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):222 - {} - S3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/rvp_account_overview cleaned.
2021-10-01 00:05:42 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:42 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):224 - {} - Begin cleaning _airbyte_tmp_xbe_account_overview tmp table in destination.
2021-10-01 00:05:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:43 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):226 - {} - _airbyte_tmp_xbe_account_overview tmp table in destination cleaned.
2021-10-01 00:05:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:43 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):218 - {} - Begin cleaning s3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/ded_addresses.
2021-10-01 00:05:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:43 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):222 - {} - S3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/ded_addresses cleaned.
2021-10-01 00:05:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:43 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):224 - {} - Begin cleaning _airbyte_tmp_jxm_addresses tmp table in destination.
2021-10-01 00:05:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:43 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):226 - {} - _airbyte_tmp_jxm_addresses tmp table in destination cleaned.
2021-10-01 00:05:43 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:43 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):218 - {} - Begin cleaning s3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/xwa_calls.
2021-10-01 00:05:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:44 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):222 - {} - S3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/xwa_calls cleaned.
2021-10-01 00:05:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:44 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):224 - {} - Begin cleaning _airbyte_tmp_ebs_calls tmp table in destination.
2021-10-01 00:05:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:44 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):226 - {} - _airbyte_tmp_ebs_calls tmp table in destination cleaned.
2021-10-01 00:05:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:44 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):218 - {} - Begin cleaning s3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/fln_ivr_menus.
2021-10-01 00:05:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:44 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):222 - {} - S3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/fln_ivr_menus cleaned.
2021-10-01 00:05:44 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:44 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):224 - {} - Begin cleaning _airbyte_tmp_lzt_ivr_menus tmp table in destination.
2021-10-01 00:05:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:45 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):226 - {} - _airbyte_tmp_lzt_ivr_menus tmp table in destination cleaned.
2021-10-01 00:05:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:45 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):218 - {} - Begin cleaning s3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/sec_agents_activity.
2021-10-01 00:05:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:45 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):222 - {} - S3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/sec_agents_activity cleaned.
2021-10-01 00:05:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:45 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):224 - {} - Begin cleaning _airbyte_tmp_vug_agents_activity tmp table in destination.
2021-10-01 00:05:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:45 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):226 - {} - _airbyte_tmp_vug_agents_activity tmp table in destination cleaned.
2021-10-01 00:05:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:45 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):218 - {} - Begin cleaning s3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/uzp_current_queue_activity.
2021-10-01 00:05:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:45 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):222 - {} - S3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/uzp_current_queue_activity cleaned.
2021-10-01 00:05:45 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:45 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):224 - {} - Begin cleaning _airbyte_tmp_vlz_current_queue_activity tmp table in destination.
2021-10-01 00:05:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:46 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):226 - {} - _airbyte_tmp_vlz_current_queue_activity tmp table in destination cleaned.
2021-10-01 00:05:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:46 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):218 - {} - Begin cleaning s3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/ryg_ivr_routes.
2021-10-01 00:05:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:46 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):222 - {} - S3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/ryg_ivr_routes cleaned.
2021-10-01 00:05:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:46 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):224 - {} - Begin cleaning _airbyte_tmp_xyp_ivr_routes tmp table in destination.
2021-10-01 00:05:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:46 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):226 - {} - _airbyte_tmp_xyp_ivr_routes tmp table in destination cleaned.
2021-10-01 00:05:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:46 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):218 - {} - Begin cleaning s3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/jat_agents_overview.
2021-10-01 00:05:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:46 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):222 - {} - S3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/jat_agents_overview cleaned.
2021-10-01 00:05:46 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:46 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):224 - {} - Begin cleaning _airbyte_tmp_yvp_agents_overview tmp table in destination.
2021-10-01 00:05:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:47 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):226 - {} - _airbyte_tmp_yvp_agents_overview tmp table in destination cleaned.
2021-10-01 00:05:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:47 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):218 - {} - Begin cleaning s3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/wgm_ivrs.
2021-10-01 00:05:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:47 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):222 - {} - S3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/wgm_ivrs cleaned.
2021-10-01 00:05:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:47 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):224 - {} - Begin cleaning _airbyte_tmp_lzt_ivrs tmp table in destination.
2021-10-01 00:05:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:47 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):226 - {} - _airbyte_tmp_lzt_ivrs tmp table in destination cleaned.
2021-10-01 00:05:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:47 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):218 - {} - Begin cleaning s3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/beh_greeting_categories.
2021-10-01 00:05:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:47 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):222 - {} - S3 staging file eb7c8f8e-89ab-43b5-8be7-846694097787/zendesk_talk/beh_greeting_categories cleaned.
2021-10-01 00:05:47 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:47 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):224 - {} - Begin cleaning _airbyte_tmp_efu_greeting_categories tmp table in destination.
2021-10-01 00:05:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:48 �[32mINFO�[m i.a.i.d.j.c.s.S3StreamCopier(removeFileAndDropTmpTable):226 - {} - _airbyte_tmp_efu_greeting_categories tmp table in destination cleaned.
2021-10-01 00:05:48 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):231 - state in DefaultReplicationWorker from Destination: io.airbyte.protocol.models.AirbyteMessage@52c4fc27[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@5c03180f[data={"calls":{"timestamp":"2020-02-18T20:49:59+00:00"},"call_legs":{"timestamp":"2020-01-29T14:31:19+00:00"}},additionalProperties={}],additionalProperties={}]
2021-10-01 00:05:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:48 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):153 - {} - Completed integration: io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2021-10-01 00:05:48 INFO () DefaultAirbyteStreamFactory(lambda$create$0):53 - 2021-10-01 00:05:48 �[32mINFO�[m i.a.i.d.s.SnowflakeDestination(main):83 - {} - completed destination: class io.airbyte.integrations.destination.snowflake.SnowflakeDestination
2021-10-01 00:05:51 INFO () DefaultReplicationWorker(run):124 - Destination thread complete.
2021-10-01 00:05:51 INFO () DefaultReplicationWorker(run):152 - sync summary: io.airbyte.config.ReplicationAttemptSummary@74bf65bc[status=completed,recordsSynced=2294,bytesSynced=1710784,startTime=1633046630964,endTime=1633046751067]
2021-10-01 00:05:51 INFO () DefaultReplicationWorker(run):159 - Source output at least one state message
2021-10-01 00:05:51 INFO () DefaultReplicationWorker(run):165 - State capture: Updated state to: Optional[io.airbyte.config.State@21e0dd82[state={"calls":{"timestamp":"2020-02-18T20:49:59+00:00"},"call_legs":{"timestamp":"2020-01-29T14:31:19+00:00"}}]]
2021-10-01 00:05:51 INFO () TemporalAttemptExecution(get):115 - Stopping cancellation check scheduling...
2021-10-01 00:05:51 INFO () SyncWorkflow$ReplicationActivityImpl(replicate):177 - sync summary: io.airbyte.config.StandardSyncOutput@6e1d9b92[standardSyncSummary=io.airbyte.config.StandardSyncSummary@7b02bdf2[status=completed,recordsSynced=2294,bytesSynced=1710784,startTime=1633046630964,endTime=1633046751067],state=io.airbyte.config.State@21e0dd82[state={"calls":{"timestamp":"2020-02-18T20:49:59+00:00"},"call_legs":{"timestamp":"2020-01-29T14:31:19+00:00"}}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@78d675c4[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@7c90bdbe[stream=io.airbyte.protocol.models.AirbyteStream@7e5368b5[name=account_overview,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"total_calls":{"type":["null","integer"]},"total_hold_time":{"type":["null","integer"]},"total_voicemails":{"type":["null","integer"]},"average_hold_time":{"type":["null","integer"]},"max_calls_waiting":{"type":["null","integer"]},"total_wrap_up_time":{"type":["null","integer"]},"max_queue_wait_time":{"type":["null","integer"]},"total_call_duration":{"type":["null","integer"]},"total_inbound_calls":{"type":["null","integer"]},"average_wrap_up_time":{"type":["null","integer"]},"total_callback_calls":{"type":["null","integer"]},"total_outbound_calls":{"type":["null","integer"]},"average_call_duration":{"type":["null","integer"]},"average_time_to_answer":{"type":["null","integer"]},"average_queue_wait_time":{"type":["null","integer"]},"total_textback_requests":{"type":["null","integer"]},"average_callback_wait_time":{"type":["null","integer"]},"total_calls_abandoned_in_queue":{"type":["null","integer"]},"total_embeddable_callback_calls":{"type":["null","integer"]},"total_calls_outside_business_hours":{"type":["null","integer"]},"total_calls_with_requested_voicemail":{"type":["null","integer"]},"total_calls_with_exceeded_queue_wait_time":{"type":["null","integer"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=zendesk_talk,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@10d0b7a0[stream=io.airbyte.protocol.models.AirbyteStream@5b63882b[name=addresses,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"zip":{"type":["null","string"]},"city":{"type":["null","string"]},"name":{"type":["null","string"]},"state":{"type":["null","string"]},"street":{"type":["null","string"]},"province":{"type":["null","string"]},"country_code":{"type":["null","string"]},"provider_reference":{"type":["null","string"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=zendesk_talk,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2267b3b4[stream=io.airbyte.protocol.models.AirbyteStream@4714618d[name=agents_activity,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"via":{"type":["null","string"]},"name":{"type":["null","string"]},"agent_id":{"type":["null","string"]},"away_time":{"type":["null","integer"]},"avatar_url":{"type":["null","string"]},"agent_state":{"type":["null","string"]},"call_status":{"type":["null","string"]},"online_time":{"type":["null","integer"]},"calls_denied":{"type":["null","integer"]},"calls_missed":{"type":["null","integer"]},"available_time":{"type":["null","integer"]},"calls_accepted":{"type":["null","integer"]},"total_hold_time":{"type":["null","integer"]},"total_talk_time":{"type":["null","integer"]},"average_hold_time":{"type":["null","integer"]},"average_talk_time":{"type":["null","integer"]},"calls_put_on_hold":{"type":["null","integer"]},"forwarding_number":{"type":["null","string"]},"started_transfers":{"type":["null","integer"]},"accepted_transfers":{"type":["null","integer"]},"total_wrap_up_time":{"type":["null","integer"]},"total_call_duration":{"type":["null","integer"]},"average_wrap_up_time":{"type":["null","integer"]},"started_third_party_conferences":{"type":["null","integer"]},"accepted_third_party_conferences":{"type":["null","integer"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=zendesk_talk,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@526cb378[stream=io.airbyte.protocol.models.AirbyteStream@15094bce[name=agents_overview,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"total_hold_time":{"type":["null","integer"]},"total_talk_time":{"type":["null","integer"]},"average_away_time":{"type":["null","integer"]},"average_hold_time":{"type":["null","integer"]},"average_talk_time":{"type":["null","integer"]},"total_calls_denied":{"type":["null","integer"]},"total_calls_missed":{"type":["null","integer"]},"total_wrap_up_time":{"type":["null","integer"]},"average_online_time":{"type":["null","integer"]},"average_calls_denied":{"type":["null","integer"]},"average_calls_missed":{"type":["null","integer"]},"average_wrap_up_time":{"type":["null","integer"]},"total_calls_accepted":{"type":["null","integer"]},"average_available_time":{"type":["null","integer"]},"average_calls_accepted":{"type":["null","integer"]},"total_calls_put_on_hold":{"type":["null","integer"]},"total_started_transfers":{"type":["null","integer"]},"total_accepted_transfers":{"type":["null","integer"]},"average_calls_put_on_hold":{"type":["null","integer"]},"average_started_transfers":{"type":["null","integer"]},"average_accepted_transfers":{"type":["null","integer"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=zendesk_talk,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@aeca0c8[stream=io.airbyte.protocol.models.AirbyteStream@6e10b011[name=call_legs,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"type":{"type":["null","string"]},"call_id":{"type":["null","integer"]},"user_id":{"type":["null","integer"]},"agent_id":{"type":["null","integer"]},"duration":{"type":["null","integer"]},"hold_time":{"type":["null","integer"]},"talk_time":{"type":["null","integer"]},"created_at":{"type":["null","string"]},"updated_at":{"type":["null","string"]},"call_charge":{"type":["null","string"]},"forwarded_to":{"type":["null","string"]},"wrap_up_time":{"type":["null","integer"]},"available_via":{"type":["null","string"]},"conference_to":{"type":["null","integer"]},"minutes_billed":{"type":["null","integer"]},"quality_issues":{"type":["null","array"]},"transferred_to":{"type":["null","integer"]},"conference_from":{"type":["null","integer"]},"conference_time":{"type":["null","integer"]},"consultation_to":{"type":["null","integer"]},"transferred_from":{"type":["null","integer"]},"completion_status":{"type":["null","string"]},"consultation_from":{"type":["null","integer"]},"consultation_time":{"type":["null","integer"]}}},supportedSyncModes=[incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=zendesk_talk,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@59d029d8[stream=io.airbyte.protocol.models.AirbyteStream@6d85e17[name=calls,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"agent_id":{"type":["null","integer"]},"callback":{"type":["null","boolean"]},"duration":{"type":["null","integer"]},"ivr_hops":{"type":["null","integer"]},"direction":{"type":["null","string"]},"hold_time":{"type":["null","integer"]},"talk_time":{"type":["null","integer"]},"ticket_id":{"type":["null","integer"]},"voicemail":{"type":["null","boolean"]},"wait_time":{"type":["null","integer"]},"created_at":{"type":["null","string"]},"ivr_action":{"type":["null","string"]},"overflowed":{"type":["null","boolean"]},"updated_at":{"type":["null","string"]},"call_charge":{"type":["null","string"]},"phone_number":{"type":["null","string"]},"wrap_up_time":{"type":["null","integer"]},"call_group_id":{"type":["null","integer"]},"default_group":{"type":["null","boolean"]},"ivr_routed_to":{"type":["null","string"]},"overflowed_to":{"type":["null","string"]},"ivr_time_spent":{"type":["null","integer"]},"minutes_billed":{"type":["null","integer"]},"quality_issues":{"type":["null","array"]},"recording_time":{"type":["null","integer"]},"time_to_answer":{"type":["null","integer"]},"callback_source":{"type":["null","string"]},"phone_number_id":{"type":["null","integer"]},"completion_status":{"type":["null","string"]},"consultation_time":{"type":["null","integer"]},"not_recording_time":{"type":["null","integer"]},"exceeded_queue_time":{"type":["null","boolean"]},"call_recording_consent":{"type":["null","string"]},"outside_business_hours":{"type":["null","boolean"]},"ivr_destination_group_name":{"type":["null","string"]},"customer_requested_voicemail":{"type":["null","boolean"]},"call_recording_consent_action":{"type":["null","string"]},"recording_control_interactions":{"type":["null","integer"]},"call_recording_consent_keypress":{"type":["null","string"]}}},supportedSyncModes=[incremental],sourceDefinedCursor=true,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=zendesk_talk,additionalProperties={}],syncMode=incremental,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@695d44e4[stream=io.airbyte.protocol.models.AirbyteStream@2a6f1e6[name=current_queue_activity,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"agents_online":{"type":["null","integer"]},"calls_waiting":{"type":["null","integer"]},"average_wait_time":{"type":["null","integer"]},"callbacks_waiting":{"type":["null","integer"]},"longest_wait_time":{"type":["null","integer"]},"embeddable_callbacks_waiting":{"type":["null","integer"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=zendesk_talk,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@5a609683[stream=io.airbyte.protocol.models.AirbyteStream@1e0c433e[name=greeting_categories,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=zendesk_talk,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@1d754e7f[stream=io.airbyte.protocol.models.AirbyteStream@28e9b5f6[name=greetings,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","string"]},"name":{"type":["null","string"]},"active":{"type":["null","boolean"]},"default":{"type":["null","boolean"]},"ivr_ids":{"type":["null","array"],"items":{"type":["string","integer"]}},"pending":{"type":["null","boolean"]},"audio_url":{"type":["null","string"]},"upload_id":{"type":["null","integer"]},"audio_name":{"type":["null","string"]},"category_id":{"type":["null","integer"]},"default_lang":{"type":["null","boolean"]},"has_sub_settings":{"type":["null","boolean"]},"phone_number_ids":{"type":["null","array"],"items":{"type":["string","integer"]}}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=zendesk_talk,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@76e3eae6[stream=io.airbyte.protocol.models.AirbyteStream@a0a52b7[name=ivr_menus,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"ivr_id":{"type":["null","integer"]},"routes":{"type":["array","null"],"items":{"type":"object","properties":{"id":{"type":["null","integer"]},"action":{"type":["null","string"]},"options":{"type":["null","object"]},"greeting":{"type":["null","string"]},"keypress":{"type":["null","string"]},"option_text":{"type":["null","string"]},"overflow_options":{"type":["null","object"]}}}},"default":{"type":["null","boolean"]},"greeting_id":{"type":["null","integer"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=zendesk_talk,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3d3be33f[stream=io.airbyte.protocol.models.AirbyteStream@5818a76b[name=ivr_routes,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"action":{"type":["null","string"]},"ivr_id":{"type":["null","integer"]},"options":{"type":["null","object"]},"greeting":{"type":["null","string"]},"keypress":{"type":["null","string"]},"ivr_menu_id":{"type":["null","integer"]},"option_text":{"type":["null","string"]},"overflow_options":{"type":["null","object"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=zendesk_talk,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@3145c254[stream=io.airbyte.protocol.models.AirbyteStream@6982a121[name=ivrs,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"menus":{"type":["null","array"],"items":{"type":"object","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"ivr_id":{"type":["null","integer"]},"routes":{"type":["array","null"],"items":{"type":"object","properties":{"id":{"type":["null","integer"]},"action":{"type":["null","string"]},"options":{"type":["null","object"]},"greeting":{"type":["null","string"]},"keypress":{"type":["null","string"]},"option_text":{"type":["null","string"]},"overflow_options":{"type":["null","object"]}}}},"default":{"type":["null","boolean"]},"greeting_id":{"type":["null","integer"]}}}},"phone_number_ids":{"type":["null","array"],"items":{"type":["string","integer"]}},"phone_number_names":{"type":["null","array"],"items":{"type":["integer","string"]}}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=zendesk_talk,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@b428535[stream=io.airbyte.protocol.models.AirbyteStream@16fc58c9[name=phone_numbers,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"name":{"type":["null","string"]},"token":{"type":["null","string"]},"ivr_id":{"type":["null","integer"]},"number":{"type":["null","string"]},"external":{"type":["null","boolean"]},"location":{"type":["null","string"]},"nickname":{"type":["null","string"]},"priority":{"type":["null","integer"]},"recorded":{"type":["null","boolean"]},"group_ids":{"type":["null","array"]},"line_type":{"type":["null","string"]},"toll_free":{"type":["null","boolean"]},"created_at":{"type":["null","string"]},"schedule_id":{"type":["null","integer"]},"sms_enabled":{"type":["null","boolean"]},"capabilities":{"type":["null","object"],"properties":{"mms":{"type":["null","boolean"]},"sms":{"type":["null","boolean"]},"voice":{"type":["null","boolean"]}}},"country_code":{"type":["null","string"]},"greeting_ids":{"type":["null","array"]},"sms_group_id":{"type":["null","integer"]},"transcription":{"type":["null","boolean"]},"voice_enabled":{"type":["null","boolean"]},"display_number":{"type":["null","string"]},"failover_number":{"type":["null","string"]},"default_group_id":{"type":["null","integer"]},"outbound_enabled":{"type":["null","boolean"]},"default_greeting_ids":{"type":["null","array"],"items":{"type":"string"}},"categorised_greetings":{"type":["null","object"]},"call_recording_consent":{"type":["null","string"]},"categorised_greetings_with_sub_settings":{"type":["null","object"]}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=zendesk_talk,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}]]
2021-10-01 00:05:51 INFO () LoggingTrackingClient(track):41 - track. version: null, userId: null, action: Success Notification, metadata: {connector_source_definition_id=c8630570-086d-4a40-99ae-ea5b18673071, notification_type=slack, connection_id=6a997f1c-7c32-4909-a1f2-9d3981ad6ce1, connector_source_version=0.1.2, connector_destination_version=0.3.14, connector_source=Zendesk Talk, connector_destination=Snowflake, connector_destination_definition_id=424892c4-daac-4491-b35d-c6688ba547ba}
2021-10-01 00:05:51 WARN () JobNotifier(notifyJob):113 - Failed to successfully notify success: io.airbyte.config.Notification@6f6e076e[notificationType=slack,sendOnSuccess=false,sendOnFailure=false,slackConfiguration=io.airbyte.config.SlackNotificationConfiguration@2d703a31[webhook=https://hooks.slack.com/services/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],additionalProperties={}]

Steps to Reproduce

  1. Create connection
  2. Sync

Are you willing to submit a PR?

Sure
@danieldiamond danieldiamond added the type/bug Something isn't working label Oct 1, 2021
@sherifnada sherifnada added the area/connectors Connector related issues label Oct 1, 2021
@marcosmarxm
Copy link
Member

Thanks @danieldiamond for reporting this. Sherif added it to the connector roadmap (estimated to 15-oct). Do you want to work on this issue? I can assign it to you.

@eliziario eliziario self-assigned this Oct 4, 2021
@gaart gaart assigned gaart and unassigned eliziario Oct 11, 2021
@danieldiamond
Copy link
Contributor Author

@gaart
more specific context on this issue. loading the calls and call_legs tables into the destination. I only see exactly 1000 records in each table. looking further at the calls, i noticed created_at dates are not necessarily recent, with some as far back as 2019

@danieldiamond
Copy link
Contributor Author

bringing private slack conversation here for visibility. the specific issue is pagination. apparently airbyte's test account does not have enough data to verify this. as mentioned above, i am seeing exactly 1k of calls records coming through (we have more than that on our account). the issue here is to investigate why the sync loads 1k of records and moves on.

@gaart gaart linked a pull request Oct 19, 2021 that will close this issue
🐛 Source Zendesk Talk: migrate to CDK #7173
Merged
15 tasks
@danieldiamond
Copy link
Contributor Author

@gaart do you identify the issue? Can we publish the updated connector you in PR please?

@gaart
Copy link
Contributor

gaart commented Oct 22, 2021

@danieldiamond still working on it, quite complicated to prepare a testing dataset on this API, so it takes time

@gaart gaart mentioned this issue Oct 31, 2021
Merged
15 tasks
@VasylLazebnyk VasylLazebnyk assigned keu and unassigned gaart Nov 5, 2021
@danieldiamond
Copy link
Contributor Author

Is there any updates on this?
From what i can tell the exact same issue was resolved for zendesk chat: #7210
Can we not just use the same solution here?

@keu
Copy link
Contributor

keu commented Nov 11, 2021

Hi @danieldiamond , sorry for the late response.
You are completely right, Zendesk Chat had the same fix already (and also was migrated to CDK).
To guarantee a minimum level of quality the fix for Zendesk Talk required migration to CDK as well.
The fix is ready, it awaits internal review and soon will be merged and published.

@keu keu closed this as completed in #7173 Nov 13, 2021
@keu keu mentioned this issue Nov 13, 2021
Closed
36 tasks
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees

@keu keu

Labels
area/connectors Connector related issues connectors/source/zendesk-talk connectors/sources-api type/bug Something isn't working
Projects
None yet
Milestone
Connectors 2021-11-12
Development

Successfully merging a pull request may close this issue.

🐛 Source Zendesk Talk: migrate to CDK airbytehq/airbyte
7 participants
@eliziario @gaart @keu @marcosmarxm @sherifnada @danieldiamond @igrankova