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

Source Slack: using wrong field name for cursor field 'float_ts' #4681

Closed
marcosmarxm opened this issue Jul 10, 2021 · 0 comments · Fixed by #4683
Closed

Source Slack: using wrong field name for cursor field 'float_ts' #4681

marcosmarxm opened this issue Jul 10, 2021 · 0 comments · Fixed by #4683
Labels
area/connectors Connector related issues connectors/source/slack connectors/sources-api type/bug Something isn't working

Comments

@marcosmarxm
Copy link
Member

Enviroment

  • Airbyte version: 0.27.1-alpha
  • OS Version / Instance: Ubuntu 18.04
  • Deployment: Docker
  • Source Connector and version: Slack 0.1.7
  • Destination Connector and version: Postgres 0.3.6
  • Severity: Very Low / Low / Medium / High / Critical
  • Step where error happened: Sync job

Current Behavior

Trying to sync data using the native Slack connector using incremental + dedup when possible.
The sync failed because is using the wrong field name as cursor field.

2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.8/site-packages/normalization/transform_catalog/stream_processor.py", line 526, in get_cursor_field
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -     return column_names[self.cursor_field[0]][0]
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 - KeyError: 'float_ts'

Expected Behavior

Sync should work.

Logs

If applicable, please upload the logs from the failing operation.
For sync jobs, you can download the full logs from the UI by going to the sync attempt page and
clicking the download logs button at the top right of the logs display window.

LOG 

2021-07-10 17:35:32 INFO () WorkerRun(call):62 - Executing worker wrapper. Airbyte version: 0.27.1-alpha
2021-07-10 17:35:32 INFO () TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.27.1-alpha
2021-07-10 17:35:32 INFO () DefaultReplicationWorker(run):102 - start sync worker. job id: 1 attempt id: 2
2021-07-10 17:35:32 INFO () DefaultReplicationWorker(run):111 - configured sync modes: {null.channels=full_refresh - append, null.channel_messages=incremental - append_dedup, null.channel_members=full_refresh - append, null.users=full_refresh - append, null.threads=incremental - append_dedup}
2021-07-10 17:35:32 INFO () DefaultAirbyteDestination(start):78 - Running destination...
2021-07-10 17:35:32 INFO () LineGobbler(voidCall):85 - Checking if airbyte/destination-postgres:0.3.6 exists...
2021-07-10 17:35:32 INFO () LineGobbler(voidCall):85 - airbyte/destination-postgres:0.3.6 was found locally.
2021-07-10 17:35:32 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/1/2 --network host --log-driver none airbyte/destination-postgres:0.3.6 write --config destination_config.json --catalog destination_catalog.json
2021-07-10 17:35:32 INFO () LineGobbler(voidCall):85 - Checking if airbyte/source-slack:0.1.7 exists...
2021-07-10 17:35:32 INFO () LineGobbler(voidCall):85 - airbyte/source-slack:0.1.7 was found locally.
2021-07-10 17:35:32 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/1/2 --network host --log-driver none airbyte/source-slack:0.1.7 read --config source_config.json --catalog source_catalog.json
2021-07-10 17:35:32 INFO () DefaultReplicationWorker(run):139 - Waiting for source thread to join.
2021-07-10 17:35:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):210 - Replication thread started.
2021-07-10 17:35:32 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):246 - Destination output thread started.
2021-07-10 17:35:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:35:37 �[32mINFO�[m i.a.i.d.p.PostgresDestination(main):83 - {} - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2021-07-10 17:35:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:35:37 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):78 - {} - Running integration: io.airbyte.integrations.destination.postgres.PostgresDestination
2021-07-10 17:35:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:35:37 �[32mINFO�[m i.a.i.b.IntegrationCliParser(parseOptions):135 - {} - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2021-07-10 17:35:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:35:37 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):82 - {} - Command: WRITE
2021-07-10 17:35:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:35:37 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):83 - {} - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2021-07-10 17:35:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:35:37 �[32mINFO�[m i.a.i.d.b.BufferedStreamConsumer(startTracked):120 - {} - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2021-07-10 17:35:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:35:37 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):145 - {} - Preparing tmp tables in destination started for 5 streams
2021-07-10 17:35:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:35:37 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream channel_members. schema: public, tmp table name: _airbyte_1625938537652__airbyte_raw_channel_members
2021-07-10 17:35:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:35:38 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream channel_messages. schema: public, tmp table name: _airbyte_1625938537657__airbyte_raw_channel_messages
2021-07-10 17:35:39 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:35:39 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream channels. schema: public, tmp table name: _airbyte_1625938537658__airbyte_raw_channels
2021-07-10 17:35:39 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:35:39 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream threads. schema: public, tmp table name: _airbyte_1625938537658__airbyte_raw_threads
2021-07-10 17:35:39 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:35:39 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream users. schema: public, tmp table name: _airbyte_1625938537659__airbyte_raw_users
2021-07-10 17:35:40 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:35:40 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):155 - {} - Preparing tables in destination completed.
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Starting syncing SourceSlack
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - joining Slack channels
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: dev
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: feedback-and-requests
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: announcements
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: editorial
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: good-reads
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: github-updates
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: random
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: integrations
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: dev-frontend
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: website
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: testing-0_1_0
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: release_v0_2_0
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: troubleshooting
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: test-73
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: airflow
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: introductions
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: connector_builds
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: lifesight--narrative
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: connector-development
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: getting-started
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: memes-and-banter
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: users-brazil
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: shameless-plugs
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: write-for-airbyte
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: careers
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: understanding-airbyte
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: acceptance-test
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: contributing-to-airbyte
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: cdk
2021-07-10 17:35:46 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Syncing stream: channel_members 
2021-07-10 17:35:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 1000
2021-07-10 17:35:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 2000
2021-07-10 17:35:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 3000
2021-07-10 17:35:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 4000
2021-07-10 17:35:58 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 5000
2021-07-10 17:36:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 6000
2021-07-10 17:36:04 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 7000
2021-07-10 17:36:07 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 8000
2021-07-10 17:36:09 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 9000
2021-07-10 17:36:12 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 10000
2021-07-10 17:36:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 11000
2021-07-10 17:36:17 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 12000
2021-07-10 17:36:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 13000
2021-07-10 17:36:23 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 14000
2021-07-10 17:36:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 15000
2021-07-10 17:36:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 16000
2021-07-10 17:36:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 17000
2021-07-10 17:36:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 18000
2021-07-10 17:36:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 19000
2021-07-10 17:36:38 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 20000
2021-07-10 17:36:40 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 21000
2021-07-10 17:36:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 22000
2021-07-10 17:36:53 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Read 22187 records from channel_members stream
2021-07-10 17:36:53 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Syncing stream: channel_messages 
2021-07-10 17:36:53 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:36:53 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:36:53 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:36:53 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 - Traceback (most recent call last):
2021-07-10 17:36:53 ERROR () DefaultAirbyteStreamFactory(internalLog):108 - Max retry limit reached. Request: <PreparedRequest [GET]>, Response: <Response [429]>
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -   File "/airbyte/integration_code/main.py", line 33, in <module>
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -     launch(source, sys.argv[1:])
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py", line 115, in launch
2021-07-10 17:36:53 ERROR () DefaultAirbyteStreamFactory(internalLog):108 - Encountered an exception while reading stream SourceSlack
Traceback (most recent call last):
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 108, in read
    logger=logger, stream_instance=stream_instance, configured_stream=configured_stream, connector_state=connector_state
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 133, in _read_stream
    for record in record_iterator:
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 164, in _read_incremental
    for record_data in records:
  File "/airbyte/integration_code/source_slack/source.py", line 191, in read_records
    yield from super().read_records(stream_slice=stream_slice, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 226, in read_records
    response = self._send_request(request)
  File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry
    ret = target(*args, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry
    ret = target(*args, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 196, in _send_request
    raise UserDefinedBackoffException(backoff=custom_backoff_time, request=request, response=response)
airbyte_cdk.sources.streams.http.exceptions.UserDefinedBackoffException

2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -     for message in source_entrypoint.run(parsed_args):
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py", line 106, in run
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -     for message in generator:
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 112, in read
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -     raise e
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 108, in read
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -     logger=logger, stream_instance=stream_instance, configured_stream=configured_stream, connector_state=connector_state
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 133, in _read_stream
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -     for record in record_iterator:
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 164, in _read_incremental
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -     for record_data in records:
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -   File "/airbyte/integration_code/source_slack/source.py", line 191, in read_records
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -     yield from super().read_records(stream_slice=stream_slice, **kwargs)
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 226, in read_records
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -     response = self._send_request(request)
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -     ret = target(*args, **kwargs)
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -     ret = target(*args, **kwargs)
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 196, in _send_request
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 -     raise UserDefinedBackoffException(backoff=custom_backoff_time, request=request, response=response)
2021-07-10 17:36:53 ERROR () LineGobbler(voidCall):85 - airbyte_cdk.sources.streams.http.exceptions.UserDefinedBackoffException
2021-07-10 17:36:56 INFO () DefaultReplicationWorker(run):141 - Source thread complete.
2021-07-10 17:36:56 INFO () DefaultReplicationWorker(run):142 - Waiting for destination thread to join.
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):80 - {} - Airbyte message consumer: succeeded.
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.d.b.BufferedStreamConsumer(close):190 - {} - executing on success close procedure.
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):182 - {} - Finalizing tables in destination started for 5 streams
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream channel_members. schema public, tmp table _airbyte_1625938537652__airbyte_raw_channel_members, final table _airbyte_raw_channel_members
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream channel_messages. schema public, tmp table _airbyte_1625938537657__airbyte_raw_channel_messages, final table _airbyte_raw_channel_messages
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream channels. schema public, tmp table _airbyte_1625938537658__airbyte_raw_channels, final table _airbyte_raw_channels
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream threads. schema public, tmp table _airbyte_1625938537658__airbyte_raw_threads, final table _airbyte_raw_threads
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream users. schema public, tmp table _airbyte_1625938537659__airbyte_raw_users, final table _airbyte_raw_users
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):200 - {} - Executing finalization of tables.
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):202 - {} - Finalizing tables in destination completed.
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):205 - {} - Cleaning tmp tables in destination started for 5 streams
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream channel_members. schema public, tmp table name: _airbyte_1625938537652__airbyte_raw_channel_members
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream channel_messages. schema public, tmp table name: _airbyte_1625938537657__airbyte_raw_channel_messages
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream channels. schema public, tmp table name: _airbyte_1625938537658__airbyte_raw_channels
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream threads. schema public, tmp table name: _airbyte_1625938537658__airbyte_raw_threads
2021-07-10 17:36:56 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:56 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream users. schema public, tmp table name: _airbyte_1625938537659__airbyte_raw_users
2021-07-10 17:36:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:57 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):214 - {} - Cleaning tmp tables in destination completed.
2021-07-10 17:36:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:57 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):118 - {} - Completed integration: io.airbyte.integrations.destination.postgres.PostgresDestination
2021-07-10 17:36:57 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:36:57 �[32mINFO�[m i.a.i.d.p.PostgresDestination(main):85 - {} - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2021-07-10 17:36:59 INFO () DefaultReplicationWorker(run):144 - Destination thread complete.
2021-07-10 17:36:59 ERROR () DefaultReplicationWorker(run):148 - Sync worker failed.
io.airbyte.workers.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:134) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:146) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:52) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:146) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
2021-07-10 17:36:59 INFO () DefaultReplicationWorker(run):172 - sync summary: io.airbyte.config.ReplicationAttemptSummary@1ce2f3eb[status=failed,recordsSynced=22187,bytesSynced=1198098,startTime=1625938532709,endTime=1625938619960]
2021-07-10 17:36:59 INFO () DefaultReplicationWorker(run):181 - Source did not output any state messages
2021-07-10 17:36:59 WARN () DefaultReplicationWorker(run):192 - State capture: No state retained.
2021-07-10 17:36:59 INFO () TemporalAttemptExecution(get):133 - Stopping cancellation check scheduling...
2021-07-10 17:36:59 INFO () RetryingTemporalAttemptExecution(get):118 - Last output present: true. Should attempt again: true
2021-07-10 17:36:59 INFO () RetryingTemporalAttemptExecution(get):123 - Starting attempt: 1 of 3
2021-07-10 17:36:59 INFO () TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.27.1-alpha
2021-07-10 17:37:00 INFO () DefaultReplicationWorker(run):102 - start sync worker. job id: 1 attempt id: 2
2021-07-10 17:37:00 INFO () DefaultReplicationWorker(run):111 - configured sync modes: {null.channels=full_refresh - append, null.channel_messages=incremental - append_dedup, null.channel_members=full_refresh - append, null.users=full_refresh - append, null.threads=incremental - append_dedup}
2021-07-10 17:37:00 INFO () DefaultAirbyteDestination(start):78 - Running destination...
2021-07-10 17:37:00 INFO () LineGobbler(voidCall):85 - Checking if airbyte/destination-postgres:0.3.6 exists...
2021-07-10 17:37:00 INFO () LineGobbler(voidCall):85 - airbyte/destination-postgres:0.3.6 was found locally.
2021-07-10 17:37:00 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/1/2 --network host --log-driver none airbyte/destination-postgres:0.3.6 write --config destination_config.json --catalog destination_catalog.json
2021-07-10 17:37:00 INFO () LineGobbler(voidCall):85 - Checking if airbyte/source-slack:0.1.7 exists...
2021-07-10 17:37:00 INFO () LineGobbler(voidCall):85 - airbyte/source-slack:0.1.7 was found locally.
2021-07-10 17:37:00 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/1/2 --network host --log-driver none airbyte/source-slack:0.1.7 read --config source_config.json --catalog source_catalog.json
2021-07-10 17:37:00 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):210 - Replication thread started.
2021-07-10 17:37:00 INFO () DefaultReplicationWorker(run):139 - Waiting for source thread to join.
2021-07-10 17:37:00 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):246 - Destination output thread started.
2021-07-10 17:37:05 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:37:05 �[32mINFO�[m i.a.i.d.p.PostgresDestination(main):83 - {} - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2021-07-10 17:37:05 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:37:05 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):78 - {} - Running integration: io.airbyte.integrations.destination.postgres.PostgresDestination
2021-07-10 17:37:05 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:37:05 �[32mINFO�[m i.a.i.b.IntegrationCliParser(parseOptions):135 - {} - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2021-07-10 17:37:05 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:37:05 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):82 - {} - Command: WRITE
2021-07-10 17:37:05 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:37:05 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):83 - {} - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2021-07-10 17:37:05 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:37:05 �[32mINFO�[m i.a.i.d.b.BufferedStreamConsumer(startTracked):120 - {} - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2021-07-10 17:37:05 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:37:05 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):145 - {} - Preparing tmp tables in destination started for 5 streams
2021-07-10 17:37:05 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:37:05 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream channel_members. schema: public, tmp table name: _airbyte_1625938625951__airbyte_raw_channel_members
2021-07-10 17:37:06 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:37:06 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream channel_messages. schema: public, tmp table name: _airbyte_1625938625954__airbyte_raw_channel_messages
2021-07-10 17:37:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:37:07 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream channels. schema: public, tmp table name: _airbyte_1625938625954__airbyte_raw_channels
2021-07-10 17:37:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:37:07 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream threads. schema: public, tmp table name: _airbyte_1625938625954__airbyte_raw_threads
2021-07-10 17:37:07 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:37:07 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream users. schema: public, tmp table name: _airbyte_1625938625955__airbyte_raw_users
2021-07-10 17:37:08 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:37:08 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):155 - {} - Preparing tables in destination completed.
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Starting syncing SourceSlack
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - joining Slack channels
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: dev
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: feedback-and-requests
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: announcements
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: editorial
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: good-reads
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: github-updates
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: random
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: integrations
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: dev-frontend
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: website
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: testing-0_1_0
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: release_v0_2_0
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: troubleshooting
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: test-73
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: airflow
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: introductions
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: connector_builds
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: lifesight--narrative
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: connector-development
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: getting-started
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: memes-and-banter
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: users-brazil
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: shameless-plugs
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: write-for-airbyte
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: careers
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: understanding-airbyte
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: acceptance-test
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: contributing-to-airbyte
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: cdk
2021-07-10 17:37:12 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Syncing stream: channel_members 
2021-07-10 17:37:14 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 1000
2021-07-10 17:37:16 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 2000
2021-07-10 17:37:18 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 3000
2021-07-10 17:37:20 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 4000
2021-07-10 17:37:22 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 5000
2021-07-10 17:37:24 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 6000
2021-07-10 17:37:26 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 7000
2021-07-10 17:37:28 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 8000
2021-07-10 17:37:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 9000
2021-07-10 17:37:32 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 10000
2021-07-10 17:37:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 11000
2021-07-10 17:37:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 12000
2021-07-10 17:37:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 13000
2021-07-10 17:37:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 14000
2021-07-10 17:37:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 15000
2021-07-10 17:37:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 16000
2021-07-10 17:37:47 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 17000
2021-07-10 17:37:49 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 18000
2021-07-10 17:37:51 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 19000
2021-07-10 17:37:53 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 20000
2021-07-10 17:37:55 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 21000
2021-07-10 17:37:57 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 22000
2021-07-10 17:38:10 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Read 22187 records from channel_members stream
2021-07-10 17:38:10 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Syncing stream: channel_messages 
2021-07-10 17:38:10 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:38:10 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:38:10 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:38:10 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:38:10 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 - Traceback (most recent call last):
2021-07-10 17:38:10 ERROR () DefaultAirbyteStreamFactory(internalLog):108 - Max retry limit reached. Request: <PreparedRequest [GET]>, Response: <Response [429]>
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -   File "/airbyte/integration_code/main.py", line 33, in <module>
2021-07-10 17:38:10 ERROR () DefaultAirbyteStreamFactory(internalLog):108 - Encountered an exception while reading stream SourceSlack
Traceback (most recent call last):
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 108, in read
    logger=logger, stream_instance=stream_instance, configured_stream=configured_stream, connector_state=connector_state
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 133, in _read_stream
    for record in record_iterator:
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 164, in _read_incremental
    for record_data in records:
  File "/airbyte/integration_code/source_slack/source.py", line 191, in read_records
    yield from super().read_records(stream_slice=stream_slice, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 226, in read_records
    response = self._send_request(request)
  File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry
    ret = target(*args, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry
    ret = target(*args, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 196, in _send_request
    raise UserDefinedBackoffException(backoff=custom_backoff_time, request=request, response=response)
airbyte_cdk.sources.streams.http.exceptions.UserDefinedBackoffException

2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -     launch(source, sys.argv[1:])
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py", line 115, in launch
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -     for message in source_entrypoint.run(parsed_args):
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py", line 106, in run
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -     for message in generator:
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 112, in read
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -     raise e
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 108, in read
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -     logger=logger, stream_instance=stream_instance, configured_stream=configured_stream, connector_state=connector_state
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 133, in _read_stream
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -     for record in record_iterator:
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 164, in _read_incremental
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -     for record_data in records:
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -   File "/airbyte/integration_code/source_slack/source.py", line 191, in read_records
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -     yield from super().read_records(stream_slice=stream_slice, **kwargs)
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 226, in read_records
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -     response = self._send_request(request)
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -     ret = target(*args, **kwargs)
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -     ret = target(*args, **kwargs)
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 196, in _send_request
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 -     raise UserDefinedBackoffException(backoff=custom_backoff_time, request=request, response=response)
2021-07-10 17:38:10 ERROR () LineGobbler(voidCall):85 - airbyte_cdk.sources.streams.http.exceptions.UserDefinedBackoffException
2021-07-10 17:38:12 INFO () DefaultReplicationWorker(run):141 - Source thread complete.
2021-07-10 17:38:12 INFO () DefaultReplicationWorker(run):142 - Waiting for destination thread to join.
2021-07-10 17:38:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:12 �[32mINFO�[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):80 - {} - Airbyte message consumer: succeeded.
2021-07-10 17:38:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:12 �[32mINFO�[m i.a.i.d.b.BufferedStreamConsumer(close):190 - {} - executing on success close procedure.
2021-07-10 17:38:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:12 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):182 - {} - Finalizing tables in destination started for 5 streams
2021-07-10 17:38:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:12 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream channel_members. schema public, tmp table _airbyte_1625938625951__airbyte_raw_channel_members, final table _airbyte_raw_channel_members
2021-07-10 17:38:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:12 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream channel_messages. schema public, tmp table _airbyte_1625938625954__airbyte_raw_channel_messages, final table _airbyte_raw_channel_messages
2021-07-10 17:38:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:12 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream channels. schema public, tmp table _airbyte_1625938625954__airbyte_raw_channels, final table _airbyte_raw_channels
2021-07-10 17:38:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:12 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream threads. schema public, tmp table _airbyte_1625938625954__airbyte_raw_threads, final table _airbyte_raw_threads
2021-07-10 17:38:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:12 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream users. schema public, tmp table _airbyte_1625938625955__airbyte_raw_users, final table _airbyte_raw_users
2021-07-10 17:38:12 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:12 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):200 - {} - Executing finalization of tables.
2021-07-10 17:38:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:13 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):202 - {} - Finalizing tables in destination completed.
2021-07-10 17:38:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:13 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):205 - {} - Cleaning tmp tables in destination started for 5 streams
2021-07-10 17:38:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:13 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream channel_members. schema public, tmp table name: _airbyte_1625938625951__airbyte_raw_channel_members
2021-07-10 17:38:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:13 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream channel_messages. schema public, tmp table name: _airbyte_1625938625954__airbyte_raw_channel_messages
2021-07-10 17:38:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:13 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream channels. schema public, tmp table name: _airbyte_1625938625954__airbyte_raw_channels
2021-07-10 17:38:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:13 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream threads. schema public, tmp table name: _airbyte_1625938625954__airbyte_raw_threads
2021-07-10 17:38:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:13 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream users. schema public, tmp table name: _airbyte_1625938625955__airbyte_raw_users
2021-07-10 17:38:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:13 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):214 - {} - Cleaning tmp tables in destination completed.
2021-07-10 17:38:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:13 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):118 - {} - Completed integration: io.airbyte.integrations.destination.postgres.PostgresDestination
2021-07-10 17:38:13 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:13 �[32mINFO�[m i.a.i.d.p.PostgresDestination(main):85 - {} - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2021-07-10 17:38:15 INFO () DefaultReplicationWorker(run):144 - Destination thread complete.
2021-07-10 17:38:15 ERROR () DefaultReplicationWorker(run):148 - Sync worker failed.
io.airbyte.workers.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:134) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:146) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:52) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:146) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
2021-07-10 17:38:15 INFO () DefaultReplicationWorker(run):172 - sync summary: io.airbyte.config.ReplicationAttemptSummary@235e67d0[status=failed,recordsSynced=22187,bytesSynced=1198098,startTime=1625938620138,endTime=1625938695147]
2021-07-10 17:38:15 INFO () DefaultReplicationWorker(run):181 - Source did not output any state messages
2021-07-10 17:38:15 WARN () DefaultReplicationWorker(run):192 - State capture: No state retained.
2021-07-10 17:38:15 INFO () TemporalAttemptExecution(get):133 - Stopping cancellation check scheduling...
2021-07-10 17:38:15 INFO () RetryingTemporalAttemptExecution(get):118 - Last output present: true. Should attempt again: true
2021-07-10 17:38:15 INFO () RetryingTemporalAttemptExecution(get):123 - Starting attempt: 2 of 3
2021-07-10 17:38:15 INFO () TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.27.1-alpha
2021-07-10 17:38:15 INFO () DefaultReplicationWorker(run):102 - start sync worker. job id: 1 attempt id: 2
2021-07-10 17:38:15 INFO () DefaultReplicationWorker(run):111 - configured sync modes: {null.channels=full_refresh - append, null.channel_messages=incremental - append_dedup, null.channel_members=full_refresh - append, null.users=full_refresh - append, null.threads=incremental - append_dedup}
2021-07-10 17:38:15 INFO () DefaultAirbyteDestination(start):78 - Running destination...
2021-07-10 17:38:15 INFO () LineGobbler(voidCall):85 - Checking if airbyte/destination-postgres:0.3.6 exists...
2021-07-10 17:38:15 INFO () LineGobbler(voidCall):85 - airbyte/destination-postgres:0.3.6 was found locally.
2021-07-10 17:38:15 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/1/2 --network host --log-driver none airbyte/destination-postgres:0.3.6 write --config destination_config.json --catalog destination_catalog.json
2021-07-10 17:38:15 INFO () LineGobbler(voidCall):85 - Checking if airbyte/source-slack:0.1.7 exists...
2021-07-10 17:38:15 INFO () LineGobbler(voidCall):85 - airbyte/source-slack:0.1.7 was found locally.
2021-07-10 17:38:15 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/1/2 --network host --log-driver none airbyte/source-slack:0.1.7 read --config source_config.json --catalog source_catalog.json
2021-07-10 17:38:15 INFO () DefaultReplicationWorker(run):139 - Waiting for source thread to join.
2021-07-10 17:38:15 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):210 - Replication thread started.
2021-07-10 17:38:15 INFO () DefaultReplicationWorker(lambda$getDestinationOutputRunnable$3):246 - Destination output thread started.
2021-07-10 17:38:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:20 �[32mINFO�[m i.a.i.d.p.PostgresDestination(main):83 - {} - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2021-07-10 17:38:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:20 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):78 - {} - Running integration: io.airbyte.integrations.destination.postgres.PostgresDestination
2021-07-10 17:38:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:20 �[32mINFO�[m i.a.i.b.IntegrationCliParser(parseOptions):135 - {} - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2021-07-10 17:38:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:20 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):82 - {} - Command: WRITE
2021-07-10 17:38:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:20 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):83 - {} - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2021-07-10 17:38:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:20 �[32mINFO�[m i.a.i.d.b.BufferedStreamConsumer(startTracked):120 - {} - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2021-07-10 17:38:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:20 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):145 - {} - Preparing tmp tables in destination started for 5 streams
2021-07-10 17:38:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:20 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream channel_members. schema: public, tmp table name: _airbyte_1625938700651__airbyte_raw_channel_members
2021-07-10 17:38:20 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:20 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream channel_messages. schema: public, tmp table name: _airbyte_1625938700655__airbyte_raw_channel_messages
2021-07-10 17:38:21 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:21 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream channels. schema: public, tmp table name: _airbyte_1625938700655__airbyte_raw_channels
2021-07-10 17:38:21 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:21 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream threads. schema: public, tmp table name: _airbyte_1625938700656__airbyte_raw_threads
2021-07-10 17:38:21 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:21 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):149 - {} - Preparing tmp table in destination started for stream users. schema: public, tmp table name: _airbyte_1625938700656__airbyte_raw_users
2021-07-10 17:38:22 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:38:22 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):155 - {} - Preparing tables in destination completed.
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Starting syncing SourceSlack
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - joining Slack channels
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: dev
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: feedback-and-requests
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: announcements
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: editorial
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: good-reads
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: github-updates
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: random
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: integrations
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: dev-frontend
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: website
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: testing-0_1_0
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: release_v0_2_0
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: troubleshooting
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: test-73
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: airflow
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: introductions
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: connector_builds
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: lifesight--narrative
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: connector-development
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: getting-started
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: memes-and-banter
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: users-brazil
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: shameless-plugs
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: write-for-airbyte
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: careers
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: understanding-airbyte
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: acceptance-test
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: contributing-to-airbyte
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Successfully joined channel: cdk
2021-07-10 17:38:27 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Syncing stream: channel_members 
2021-07-10 17:38:30 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 1000
2021-07-10 17:38:31 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 2000
2021-07-10 17:38:33 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 3000
2021-07-10 17:38:35 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 4000
2021-07-10 17:38:37 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 5000
2021-07-10 17:38:39 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 6000
2021-07-10 17:38:41 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 7000
2021-07-10 17:38:43 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 8000
2021-07-10 17:38:45 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 9000
2021-07-10 17:38:48 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 10000
2021-07-10 17:38:50 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 11000
2021-07-10 17:38:52 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 12000
2021-07-10 17:38:54 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 13000
2021-07-10 17:38:56 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 14000
2021-07-10 17:38:59 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 15000
2021-07-10 17:39:01 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 16000
2021-07-10 17:39:03 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 17000
2021-07-10 17:39:05 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 18000
2021-07-10 17:39:06 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 19000
2021-07-10 17:39:08 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 20000
2021-07-10 17:39:10 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 21000
2021-07-10 17:39:13 INFO () DefaultReplicationWorker(lambda$getReplicationRunnable$2):223 - Records read: 22000
2021-07-10 17:39:35 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Read 22187 records from channel_members stream
2021-07-10 17:39:35 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Syncing stream: channel_messages 
2021-07-10 17:39:35 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:39:35 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:39:35 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:39:35 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 - Traceback (most recent call last):
2021-07-10 17:39:35 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -   File "/airbyte/integration_code/main.py", line 33, in <module>
2021-07-10 17:39:35 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -     launch(source, sys.argv[1:])
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py", line 115, in launch
2021-07-10 17:39:35 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -     for message in source_entrypoint.run(parsed_args):
2021-07-10 17:39:35 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/entrypoint.py", line 106, in run
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -     for message in generator:
2021-07-10 17:39:35 INFO () DefaultAirbyteStreamFactory(internalLog):110 - Retrying. Sleeping for 1 seconds
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 112, in read
2021-07-10 17:39:35 ERROR () DefaultAirbyteStreamFactory(internalLog):108 - Max retry limit reached. Request: <PreparedRequest [GET]>, Response: <Response [429]>
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -     raise e
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 108, in read
2021-07-10 17:39:35 ERROR () DefaultAirbyteStreamFactory(internalLog):108 - Encountered an exception while reading stream SourceSlack
Traceback (most recent call last):
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 108, in read
    logger=logger, stream_instance=stream_instance, configured_stream=configured_stream, connector_state=connector_state
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 133, in _read_stream
    for record in record_iterator:
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 164, in _read_incremental
    for record_data in records:
  File "/airbyte/integration_code/source_slack/source.py", line 191, in read_records
    yield from super().read_records(stream_slice=stream_slice, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 226, in read_records
    response = self._send_request(request)
  File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry
    ret = target(*args, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry
    ret = target(*args, **kwargs)
  File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 196, in _send_request
    raise UserDefinedBackoffException(backoff=custom_backoff_time, request=request, response=response)
airbyte_cdk.sources.streams.http.exceptions.UserDefinedBackoffException

2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -     logger=logger, stream_instance=stream_instance, configured_stream=configured_stream, connector_state=connector_state
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 133, in _read_stream
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -     for record in record_iterator:
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/abstract_source.py", line 164, in _read_incremental
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -     for record_data in records:
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -   File "/airbyte/integration_code/source_slack/source.py", line 191, in read_records
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -     yield from super().read_records(stream_slice=stream_slice, **kwargs)
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 226, in read_records
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -     response = self._send_request(request)
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -     ret = target(*args, **kwargs)
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/backoff/_sync.py", line 94, in retry
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -     ret = target(*args, **kwargs)
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.7/site-packages/airbyte_cdk/sources/streams/http/http.py", line 196, in _send_request
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 -     raise UserDefinedBackoffException(backoff=custom_backoff_time, request=request, response=response)
2021-07-10 17:39:35 ERROR () LineGobbler(voidCall):85 - airbyte_cdk.sources.streams.http.exceptions.UserDefinedBackoffException
2021-07-10 17:39:37 INFO () DefaultReplicationWorker(run):141 - Source thread complete.
2021-07-10 17:39:37 INFO () DefaultReplicationWorker(run):142 - Waiting for destination thread to join.
2021-07-10 17:39:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:37 �[32mINFO�[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):80 - {} - Airbyte message consumer: succeeded.
2021-07-10 17:39:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:37 �[32mINFO�[m i.a.i.d.b.BufferedStreamConsumer(close):190 - {} - executing on success close procedure.
2021-07-10 17:39:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:37 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):182 - {} - Finalizing tables in destination started for 5 streams
2021-07-10 17:39:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:37 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream channel_members. schema public, tmp table _airbyte_1625938700651__airbyte_raw_channel_members, final table _airbyte_raw_channel_members
2021-07-10 17:39:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:37 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream channel_messages. schema public, tmp table _airbyte_1625938700655__airbyte_raw_channel_messages, final table _airbyte_raw_channel_messages
2021-07-10 17:39:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:37 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream channels. schema public, tmp table _airbyte_1625938700655__airbyte_raw_channels, final table _airbyte_raw_channels
2021-07-10 17:39:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:37 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream threads. schema public, tmp table _airbyte_1625938700656__airbyte_raw_threads, final table _airbyte_raw_threads
2021-07-10 17:39:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:37 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Finalizing stream users. schema public, tmp table _airbyte_1625938700656__airbyte_raw_users, final table _airbyte_raw_users
2021-07-10 17:39:37 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:37 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):200 - {} - Executing finalization of tables.
2021-07-10 17:39:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:38 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):202 - {} - Finalizing tables in destination completed.
2021-07-10 17:39:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:38 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):205 - {} - Cleaning tmp tables in destination started for 5 streams
2021-07-10 17:39:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:38 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream channel_members. schema public, tmp table name: _airbyte_1625938700651__airbyte_raw_channel_members
2021-07-10 17:39:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:38 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream channel_messages. schema public, tmp table name: _airbyte_1625938700655__airbyte_raw_channel_messages
2021-07-10 17:39:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:38 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream channels. schema public, tmp table name: _airbyte_1625938700655__airbyte_raw_channels
2021-07-10 17:39:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:38 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream threads. schema public, tmp table name: _airbyte_1625938700656__airbyte_raw_threads
2021-07-10 17:39:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:38 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):209 - {} - Cleaning tmp table in destination started for stream users. schema public, tmp table name: _airbyte_1625938700656__airbyte_raw_users
2021-07-10 17:39:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:38 �[32mINFO�[m i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):214 - {} - Cleaning tmp tables in destination completed.
2021-07-10 17:39:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:38 �[32mINFO�[m i.a.i.b.IntegrationRunner(run):118 - {} - Completed integration: io.airbyte.integrations.destination.postgres.PostgresDestination
2021-07-10 17:39:38 INFO () DefaultAirbyteStreamFactory(lambda$create$0):73 - 2021-07-10 17:39:38 �[32mINFO�[m i.a.i.d.p.PostgresDestination(main):85 - {} - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2021-07-10 17:39:42 INFO () DefaultReplicationWorker(run):144 - Destination thread complete.
2021-07-10 17:39:42 ERROR () DefaultReplicationWorker(run):148 - Sync worker failed.
io.airbyte.workers.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.
	at io.airbyte.workers.protocols.airbyte.DefaultAirbyteSource.close(DefaultAirbyteSource.java:134) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:146) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.DefaultReplicationWorker.run(DefaultReplicationWorker.java:52) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:146) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
2021-07-10 17:39:42 INFO () DefaultReplicationWorker(run):172 - sync summary: io.airbyte.config.ReplicationAttemptSummary@36ae33fe[status=failed,recordsSynced=22187,bytesSynced=1198098,startTime=1625938695345,endTime=1625938782140]
2021-07-10 17:39:42 INFO () DefaultReplicationWorker(run):181 - Source did not output any state messages
2021-07-10 17:39:42 WARN () DefaultReplicationWorker(run):192 - State capture: No state retained.
2021-07-10 17:39:42 INFO () TemporalAttemptExecution(get):133 - Stopping cancellation check scheduling...
2021-07-10 17:39:42 INFO () RetryingTemporalAttemptExecution(get):112 - Max retries reached: 3
2021-07-10 17:39:42 INFO () SyncWorkflow$ReplicationActivityImpl(replicate):202 - attempt summaries: [io.airbyte.config.ReplicationOutput@7bd2ad76[replicationAttemptSummary=io.airbyte.config.ReplicationAttemptSummary@1ce2f3eb[status=failed,recordsSynced=22187,bytesSynced=1198098,startTime=1625938532709,endTime=1625938619960],state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@fd55cc8[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@2a96ee7d[stream=io.airbyte.protocol.models.AirbyteStream@7d11739a[name=channel_members,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-06/schema#","properties":{"member_id":{"type":"string"},"channel_id":{"type":"string"}},"additionalProperties":true},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@1346d853[stream=io.airbyte.protocol.models.AirbyteStream@3650e5ef[name=channel_messages,jsonSchema={"type":["null","object"],"properties":{"ts":{"type":["null","string"]},"name":{"type":["null","string"]},"team":{"type":["null","string"]},"text":{"type":["null","string"]},"type":{"type":["null","string"]},"user":{"type":["null","string"]},"icons":{"type":["null","object"],"properties":{"emoji":{"type":["null","string"]}},"additionalProperties":false},"topic":{"type":["null","string"]},"blocks":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"type":{"type":["null","string"]}},"additionalProperties":true}},"bot_id":{"type":["null","string"]},"upload":{"type":["null","boolean"]},"file_id":{"type":["null","string"]},"inviter":{"type":["null","string"]},"purpose":{"type":["null","string"]},"subtype":{"type":["null","string"]},"file_ids":{"type":["null","array"],"items":{"type":["null","string"]}},"is_intro":{"type":["null","boolean"]},"old_name":{"type":["null","string"]},"username":{"type":["null","string"]},"last_read":{"type":["null","string"],"format":"date-time"},"permalink":{"type":["null","string"],"format":"uri"},"pinned_to":{"type":["null","array"],"items":{"type":["null","string"]}},"reactions":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"name":{"type":["null","string"]},"count":{"type":["null","integer"]},"users":{"type":["null","array"],"items":{"type":["null","string"]}}},"additionalProperties":true}},"thread_ts":{"type":["null","string"]},"user_team":{"type":["null","string"]},"channel_id":{"type":["null","string"]},"is_starred":{"type":["null","boolean"]},"subscribed":{"type":["null","boolean"]},"attachments":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"color":{"type":["null","string"]},"title":{"type":["null","string"]},"fallback":{"type":["null","string"]}}}},"bot_profile":{"type":["null","object"],"properties":{"id":{"type":["null","string"]},"name":{"type":["null","string"]},"app_id":{"type":["null","string"]},"deleted":{"type":["null","boolean"]},"team_id":{"type":["null","string"]},"updated":{"type":["null","string"],"format":"date-time"}},"additionalProperties":false},"reply_count":{"type":["null","integer"]},"reply_users":{"type":["null","array"],"items":{"type":["null","string"]}},"source_team":{"type":["null","string"]},"latest_reply":{"type":["null","string"]},"unread_count":{"type":["null","integer"]},"client_msg_id":{"type":["null","string"]},"display_as_bot":{"type":["null","boolean"]},"parent_user_id":{"type":["null","string"]},"reply_users_count":{"type":["null","integer"]},"is_delayed_message":{"type":["null","boolean"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[float_ts],sourceDefinedPrimaryKey=[[channel_id], [ts]],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[float_ts],destinationSyncMode=append_dedup,primaryKey=[[channel_id], [ts]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2ba8105e[stream=io.airbyte.protocol.models.AirbyteStream@5dd32b12[name=channels,jsonSchema={"type":"object","properties":{"id":{"type":"string"},"name":{"type":"string"},"is_im":{"type":"boolean"},"topic":{"type":"object","properties":{"value":{"type":"string"},"creator":{"type":"string"},"last_set":{"type":"integer"}},"additionalProperties":true},"locale":{"type":"string"},"created":{"type":"integer"},"creator":{"type":"string"},"is_mpim":{"type":"boolean"},"purpose":{"type":"object","properties":{"value":{"type":"string"},"creator":{"type":"string"},"last_set":{"type":"integer"}},"additionalProperties":true},"is_group":{"type":"boolean"},"unlinked":{"type":"integer"},"is_member":{"type":"boolean"},"is_shared":{"type":"boolean"},"last_read":{"type":"string"},"is_channel":{"type":"boolean"},"is_general":{"type":"boolean"},"is_private":{"type":"boolean"},"is_archived":{"type":"boolean"},"num_members":{"type":"integer"},"is_read_only":{"type":"boolean"},"is_ext_shared":{"type":"boolean"},"is_org_shared":{"type":"boolean"},"pending_shared":{"type":"array","items":{}},"previous_names":{"type":"array","items":{"type":"string"}},"name_normalized":{"type":"string"},"is_pending_ext_shared":{"type":"boolean"}},"additional_properties":true},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@78f2e4bb[stream=io.airbyte.protocol.models.AirbyteStream@49bc19d7[name=threads,jsonSchema={"type":["null","object"],"properties":{"ts":{"type":["null","number"]},"team":{"type":["null","string"]},"text":{"type":["null","string"]},"type":{"type":["null","string"]},"user":{"type":["null","string"]},"blocks":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"type":{"type":["null","string"]}},"additionalProperties":true}},"thread_ts":{"type":["null","string"]},"channel_id":{"type":["null","string"]},"subscribed":{"type":["null","boolean"]},"reply_count":{"type":["null","integer"]},"reply_users":{"type":["null","array"],"items":{"type":"string"}},"latest_reply":{"type":["null","string"]},"client_msg_id":{"type":["null","string"]},"reply_users_count":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[float_ts],sourceDefinedPrimaryKey=[[channel_id], [ts]],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[float_ts],destinationSyncMode=append_dedup,primaryKey=[[channel_id], [ts]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@227dca5e[stream=io.airbyte.protocol.models.AirbyteStream@6632feb8[name=users,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-06/schema#","properties":{"id":{"type":"string"},"tz":{"type":"string"},"name":{"type":"string"},"color":{"type":"string"},"is_bot":{"type":"boolean"},"deleted":{"type":"boolean"},"has_2fa":{"type":"boolean"},"profile":{"type":"object","properties":{"team":{"type":"string"},"email":{"type":"string"},"phone":{"type":"string"},"skype":{"type":"string"},"title":{"type":"string"},"image_24":{"type":"string"},"image_32":{"type":"string"},"image_48":{"type":"string"},"image_72":{"type":"string"},"image_192":{"type":"string"},"image_512":{"type":"string"},"last_name":{"type":"string"},"real_name":{"type":"string"},"first_name":{"type":"string"},"image_1024":{"type":"string"},"avatar_hash":{"type":"string"},"status_text":{"type":"string"},"display_name":{"type":"string"},"status_emoji":{"type":"string"},"image_original":{"type":"string"},"real_name_normalized":{"type":"string"},"display_name_normalized":{"type":"string"}},"additionalProperties":true},"team_id":{"type":"string"},"updated":{"type":"integer"},"is_admin":{"type":"boolean"},"is_owner":{"type":"boolean"},"tz_label":{"type":"string"},"real_name":{"type":"string"},"tz_offset":{"type":"integer"},"is_app_user":{"type":"boolean"},"is_restricted":{"type":"boolean"},"is_primary_owner":{"type":"boolean"},"is_ultra_restricted":{"type":"boolean"}},"additionalProperties":true},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}]], io.airbyte.config.ReplicationOutput@98a09f9[replicationAttemptSummary=io.airbyte.config.ReplicationAttemptSummary@235e67d0[status=failed,recordsSynced=22187,bytesSynced=1198098,startTime=1625938620138,endTime=1625938695147],state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@20d1cbbe[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@6c32cac0[stream=io.airbyte.protocol.models.AirbyteStream@1d843ec0[name=channel_members,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-06/schema#","properties":{"member_id":{"type":"string"},"channel_id":{"type":"string"}},"additionalProperties":true},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@44983948[stream=io.airbyte.protocol.models.AirbyteStream@6a3a965e[name=channel_messages,jsonSchema={"type":["null","object"],"properties":{"ts":{"type":["null","string"]},"name":{"type":["null","string"]},"team":{"type":["null","string"]},"text":{"type":["null","string"]},"type":{"type":["null","string"]},"user":{"type":["null","string"]},"icons":{"type":["null","object"],"properties":{"emoji":{"type":["null","string"]}},"additionalProperties":false},"topic":{"type":["null","string"]},"blocks":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"type":{"type":["null","string"]}},"additionalProperties":true}},"bot_id":{"type":["null","string"]},"upload":{"type":["null","boolean"]},"file_id":{"type":["null","string"]},"inviter":{"type":["null","string"]},"purpose":{"type":["null","string"]},"subtype":{"type":["null","string"]},"file_ids":{"type":["null","array"],"items":{"type":["null","string"]}},"is_intro":{"type":["null","boolean"]},"old_name":{"type":["null","string"]},"username":{"type":["null","string"]},"last_read":{"type":["null","string"],"format":"date-time"},"permalink":{"type":["null","string"],"format":"uri"},"pinned_to":{"type":["null","array"],"items":{"type":["null","string"]}},"reactions":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"name":{"type":["null","string"]},"count":{"type":["null","integer"]},"users":{"type":["null","array"],"items":{"type":["null","string"]}}},"additionalProperties":true}},"thread_ts":{"type":["null","string"]},"user_team":{"type":["null","string"]},"channel_id":{"type":["null","string"]},"is_starred":{"type":["null","boolean"]},"subscribed":{"type":["null","boolean"]},"attachments":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"color":{"type":["null","string"]},"title":{"type":["null","string"]},"fallback":{"type":["null","string"]}}}},"bot_profile":{"type":["null","object"],"properties":{"id":{"type":["null","string"]},"name":{"type":["null","string"]},"app_id":{"type":["null","string"]},"deleted":{"type":["null","boolean"]},"team_id":{"type":["null","string"]},"updated":{"type":["null","string"],"format":"date-time"}},"additionalProperties":false},"reply_count":{"type":["null","integer"]},"reply_users":{"type":["null","array"],"items":{"type":["null","string"]}},"source_team":{"type":["null","string"]},"latest_reply":{"type":["null","string"]},"unread_count":{"type":["null","integer"]},"client_msg_id":{"type":["null","string"]},"display_as_bot":{"type":["null","boolean"]},"parent_user_id":{"type":["null","string"]},"reply_users_count":{"type":["null","integer"]},"is_delayed_message":{"type":["null","boolean"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[float_ts],sourceDefinedPrimaryKey=[[channel_id], [ts]],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[float_ts],destinationSyncMode=append_dedup,primaryKey=[[channel_id], [ts]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@10a42513[stream=io.airbyte.protocol.models.AirbyteStream@2cea6bf9[name=channels,jsonSchema={"type":"object","properties":{"id":{"type":"string"},"name":{"type":"string"},"is_im":{"type":"boolean"},"topic":{"type":"object","properties":{"value":{"type":"string"},"creator":{"type":"string"},"last_set":{"type":"integer"}},"additionalProperties":true},"locale":{"type":"string"},"created":{"type":"integer"},"creator":{"type":"string"},"is_mpim":{"type":"boolean"},"purpose":{"type":"object","properties":{"value":{"type":"string"},"creator":{"type":"string"},"last_set":{"type":"integer"}},"additionalProperties":true},"is_group":{"type":"boolean"},"unlinked":{"type":"integer"},"is_member":{"type":"boolean"},"is_shared":{"type":"boolean"},"last_read":{"type":"string"},"is_channel":{"type":"boolean"},"is_general":{"type":"boolean"},"is_private":{"type":"boolean"},"is_archived":{"type":"boolean"},"num_members":{"type":"integer"},"is_read_only":{"type":"boolean"},"is_ext_shared":{"type":"boolean"},"is_org_shared":{"type":"boolean"},"pending_shared":{"type":"array","items":{}},"previous_names":{"type":"array","items":{"type":"string"}},"name_normalized":{"type":"string"},"is_pending_ext_shared":{"type":"boolean"}},"additional_properties":true},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@29bd4555[stream=io.airbyte.protocol.models.AirbyteStream@170bae5a[name=threads,jsonSchema={"type":["null","object"],"properties":{"ts":{"type":["null","number"]},"team":{"type":["null","string"]},"text":{"type":["null","string"]},"type":{"type":["null","string"]},"user":{"type":["null","string"]},"blocks":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"type":{"type":["null","string"]}},"additionalProperties":true}},"thread_ts":{"type":["null","string"]},"channel_id":{"type":["null","string"]},"subscribed":{"type":["null","boolean"]},"reply_count":{"type":["null","integer"]},"reply_users":{"type":["null","array"],"items":{"type":"string"}},"latest_reply":{"type":["null","string"]},"client_msg_id":{"type":["null","string"]},"reply_users_count":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[float_ts],sourceDefinedPrimaryKey=[[channel_id], [ts]],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[float_ts],destinationSyncMode=append_dedup,primaryKey=[[channel_id], [ts]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@26b69d15[stream=io.airbyte.protocol.models.AirbyteStream@597c8f99[name=users,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-06/schema#","properties":{"id":{"type":"string"},"tz":{"type":"string"},"name":{"type":"string"},"color":{"type":"string"},"is_bot":{"type":"boolean"},"deleted":{"type":"boolean"},"has_2fa":{"type":"boolean"},"profile":{"type":"object","properties":{"team":{"type":"string"},"email":{"type":"string"},"phone":{"type":"string"},"skype":{"type":"string"},"title":{"type":"string"},"image_24":{"type":"string"},"image_32":{"type":"string"},"image_48":{"type":"string"},"image_72":{"type":"string"},"image_192":{"type":"string"},"image_512":{"type":"string"},"last_name":{"type":"string"},"real_name":{"type":"string"},"first_name":{"type":"string"},"image_1024":{"type":"string"},"avatar_hash":{"type":"string"},"status_text":{"type":"string"},"display_name":{"type":"string"},"status_emoji":{"type":"string"},"image_original":{"type":"string"},"real_name_normalized":{"type":"string"},"display_name_normalized":{"type":"string"}},"additionalProperties":true},"team_id":{"type":"string"},"updated":{"type":"integer"},"is_admin":{"type":"boolean"},"is_owner":{"type":"boolean"},"tz_label":{"type":"string"},"real_name":{"type":"string"},"tz_offset":{"type":"integer"},"is_app_user":{"type":"boolean"},"is_restricted":{"type":"boolean"},"is_primary_owner":{"type":"boolean"},"is_ultra_restricted":{"type":"boolean"}},"additionalProperties":true},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}]], io.airbyte.config.ReplicationOutput@1a28fe0e[replicationAttemptSummary=io.airbyte.config.ReplicationAttemptSummary@36ae33fe[status=failed,recordsSynced=22187,bytesSynced=1198098,startTime=1625938695345,endTime=1625938782140],state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@501bea6f[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@42d79b4c[stream=io.airbyte.protocol.models.AirbyteStream@7f6ad4c8[name=channel_members,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-06/schema#","properties":{"member_id":{"type":"string"},"channel_id":{"type":"string"}},"additionalProperties":true},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@226f9da5[stream=io.airbyte.protocol.models.AirbyteStream@2d284315[name=channel_messages,jsonSchema={"type":["null","object"],"properties":{"ts":{"type":["null","string"]},"name":{"type":["null","string"]},"team":{"type":["null","string"]},"text":{"type":["null","string"]},"type":{"type":["null","string"]},"user":{"type":["null","string"]},"icons":{"type":["null","object"],"properties":{"emoji":{"type":["null","string"]}},"additionalProperties":false},"topic":{"type":["null","string"]},"blocks":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"type":{"type":["null","string"]}},"additionalProperties":true}},"bot_id":{"type":["null","string"]},"upload":{"type":["null","boolean"]},"file_id":{"type":["null","string"]},"inviter":{"type":["null","string"]},"purpose":{"type":["null","string"]},"subtype":{"type":["null","string"]},"file_ids":{"type":["null","array"],"items":{"type":["null","string"]}},"is_intro":{"type":["null","boolean"]},"old_name":{"type":["null","string"]},"username":{"type":["null","string"]},"last_read":{"type":["null","string"],"format":"date-time"},"permalink":{"type":["null","string"],"format":"uri"},"pinned_to":{"type":["null","array"],"items":{"type":["null","string"]}},"reactions":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"name":{"type":["null","string"]},"count":{"type":["null","integer"]},"users":{"type":["null","array"],"items":{"type":["null","string"]}}},"additionalProperties":true}},"thread_ts":{"type":["null","string"]},"user_team":{"type":["null","string"]},"channel_id":{"type":["null","string"]},"is_starred":{"type":["null","boolean"]},"subscribed":{"type":["null","boolean"]},"attachments":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"color":{"type":["null","string"]},"title":{"type":["null","string"]},"fallback":{"type":["null","string"]}}}},"bot_profile":{"type":["null","object"],"properties":{"id":{"type":["null","string"]},"name":{"type":["null","string"]},"app_id":{"type":["null","string"]},"deleted":{"type":["null","boolean"]},"team_id":{"type":["null","string"]},"updated":{"type":["null","string"],"format":"date-time"}},"additionalProperties":false},"reply_count":{"type":["null","integer"]},"reply_users":{"type":["null","array"],"items":{"type":["null","string"]}},"source_team":{"type":["null","string"]},"latest_reply":{"type":["null","string"]},"unread_count":{"type":["null","integer"]},"client_msg_id":{"type":["null","string"]},"display_as_bot":{"type":["null","boolean"]},"parent_user_id":{"type":["null","string"]},"reply_users_count":{"type":["null","integer"]},"is_delayed_message":{"type":["null","boolean"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[float_ts],sourceDefinedPrimaryKey=[[channel_id], [ts]],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[float_ts],destinationSyncMode=append_dedup,primaryKey=[[channel_id], [ts]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@53dbb007[stream=io.airbyte.protocol.models.AirbyteStream@7abef220[name=channels,jsonSchema={"type":"object","properties":{"id":{"type":"string"},"name":{"type":"string"},"is_im":{"type":"boolean"},"topic":{"type":"object","properties":{"value":{"type":"string"},"creator":{"type":"string"},"last_set":{"type":"integer"}},"additionalProperties":true},"locale":{"type":"string"},"created":{"type":"integer"},"creator":{"type":"string"},"is_mpim":{"type":"boolean"},"purpose":{"type":"object","properties":{"value":{"type":"string"},"creator":{"type":"string"},"last_set":{"type":"integer"}},"additionalProperties":true},"is_group":{"type":"boolean"},"unlinked":{"type":"integer"},"is_member":{"type":"boolean"},"is_shared":{"type":"boolean"},"last_read":{"type":"string"},"is_channel":{"type":"boolean"},"is_general":{"type":"boolean"},"is_private":{"type":"boolean"},"is_archived":{"type":"boolean"},"num_members":{"type":"integer"},"is_read_only":{"type":"boolean"},"is_ext_shared":{"type":"boolean"},"is_org_shared":{"type":"boolean"},"pending_shared":{"type":"array","items":{}},"previous_names":{"type":"array","items":{"type":"string"}},"name_normalized":{"type":"string"},"is_pending_ext_shared":{"type":"boolean"}},"additional_properties":true},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2462ca67[stream=io.airbyte.protocol.models.AirbyteStream@4b3d1515[name=threads,jsonSchema={"type":["null","object"],"properties":{"ts":{"type":["null","number"]},"team":{"type":["null","string"]},"text":{"type":["null","string"]},"type":{"type":["null","string"]},"user":{"type":["null","string"]},"blocks":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"type":{"type":["null","string"]}},"additionalProperties":true}},"thread_ts":{"type":["null","string"]},"channel_id":{"type":["null","string"]},"subscribed":{"type":["null","boolean"]},"reply_count":{"type":["null","integer"]},"reply_users":{"type":["null","array"],"items":{"type":"string"}},"latest_reply":{"type":["null","string"]},"client_msg_id":{"type":["null","string"]},"reply_users_count":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[float_ts],sourceDefinedPrimaryKey=[[channel_id], [ts]],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[float_ts],destinationSyncMode=append_dedup,primaryKey=[[channel_id], [ts]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4568cffd[stream=io.airbyte.protocol.models.AirbyteStream@48ca1a82[name=users,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-06/schema#","properties":{"id":{"type":"string"},"tz":{"type":"string"},"name":{"type":"string"},"color":{"type":"string"},"is_bot":{"type":"boolean"},"deleted":{"type":"boolean"},"has_2fa":{"type":"boolean"},"profile":{"type":"object","properties":{"team":{"type":"string"},"email":{"type":"string"},"phone":{"type":"string"},"skype":{"type":"string"},"title":{"type":"string"},"image_24":{"type":"string"},"image_32":{"type":"string"},"image_48":{"type":"string"},"image_72":{"type":"string"},"image_192":{"type":"string"},"image_512":{"type":"string"},"last_name":{"type":"string"},"real_name":{"type":"string"},"first_name":{"type":"string"},"image_1024":{"type":"string"},"avatar_hash":{"type":"string"},"status_text":{"type":"string"},"display_name":{"type":"string"},"status_emoji":{"type":"string"},"image_original":{"type":"string"},"real_name_normalized":{"type":"string"},"display_name_normalized":{"type":"string"}},"additionalProperties":true},"team_id":{"type":"string"},"updated":{"type":"integer"},"is_admin":{"type":"boolean"},"is_owner":{"type":"boolean"},"tz_label":{"type":"string"},"real_name":{"type":"string"},"tz_offset":{"type":"integer"},"is_app_user":{"type":"boolean"},"is_restricted":{"type":"boolean"},"is_primary_owner":{"type":"boolean"},"is_ultra_restricted":{"type":"boolean"}},"additionalProperties":true},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}]]]
2021-07-10 17:39:42 INFO () SyncWorkflow$ReplicationActivityImpl(replicate):203 - sync summary: io.airbyte.config.StandardSyncOutput@5aebcc1a[standardSyncSummary=io.airbyte.config.StandardSyncSummary@426dd3cf[status=failed,recordsSynced=66561,bytesSynced=3594294,startTime=1625938532709,endTime=1625938782140],state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@501bea6f[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@42d79b4c[stream=io.airbyte.protocol.models.AirbyteStream@7f6ad4c8[name=channel_members,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-06/schema#","properties":{"member_id":{"type":"string"},"channel_id":{"type":"string"}},"additionalProperties":true},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@226f9da5[stream=io.airbyte.protocol.models.AirbyteStream@2d284315[name=channel_messages,jsonSchema={"type":["null","object"],"properties":{"ts":{"type":["null","string"]},"name":{"type":["null","string"]},"team":{"type":["null","string"]},"text":{"type":["null","string"]},"type":{"type":["null","string"]},"user":{"type":["null","string"]},"icons":{"type":["null","object"],"properties":{"emoji":{"type":["null","string"]}},"additionalProperties":false},"topic":{"type":["null","string"]},"blocks":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"type":{"type":["null","string"]}},"additionalProperties":true}},"bot_id":{"type":["null","string"]},"upload":{"type":["null","boolean"]},"file_id":{"type":["null","string"]},"inviter":{"type":["null","string"]},"purpose":{"type":["null","string"]},"subtype":{"type":["null","string"]},"file_ids":{"type":["null","array"],"items":{"type":["null","string"]}},"is_intro":{"type":["null","boolean"]},"old_name":{"type":["null","string"]},"username":{"type":["null","string"]},"last_read":{"type":["null","string"],"format":"date-time"},"permalink":{"type":["null","string"],"format":"uri"},"pinned_to":{"type":["null","array"],"items":{"type":["null","string"]}},"reactions":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"name":{"type":["null","string"]},"count":{"type":["null","integer"]},"users":{"type":["null","array"],"items":{"type":["null","string"]}}},"additionalProperties":true}},"thread_ts":{"type":["null","string"]},"user_team":{"type":["null","string"]},"channel_id":{"type":["null","string"]},"is_starred":{"type":["null","boolean"]},"subscribed":{"type":["null","boolean"]},"attachments":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"id":{"type":["null","integer"]},"color":{"type":["null","string"]},"title":{"type":["null","string"]},"fallback":{"type":["null","string"]}}}},"bot_profile":{"type":["null","object"],"properties":{"id":{"type":["null","string"]},"name":{"type":["null","string"]},"app_id":{"type":["null","string"]},"deleted":{"type":["null","boolean"]},"team_id":{"type":["null","string"]},"updated":{"type":["null","string"],"format":"date-time"}},"additionalProperties":false},"reply_count":{"type":["null","integer"]},"reply_users":{"type":["null","array"],"items":{"type":["null","string"]}},"source_team":{"type":["null","string"]},"latest_reply":{"type":["null","string"]},"unread_count":{"type":["null","integer"]},"client_msg_id":{"type":["null","string"]},"display_as_bot":{"type":["null","boolean"]},"parent_user_id":{"type":["null","string"]},"reply_users_count":{"type":["null","integer"]},"is_delayed_message":{"type":["null","boolean"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[float_ts],sourceDefinedPrimaryKey=[[channel_id], [ts]],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[float_ts],destinationSyncMode=append_dedup,primaryKey=[[channel_id], [ts]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@53dbb007[stream=io.airbyte.protocol.models.AirbyteStream@7abef220[name=channels,jsonSchema={"type":"object","properties":{"id":{"type":"string"},"name":{"type":"string"},"is_im":{"type":"boolean"},"topic":{"type":"object","properties":{"value":{"type":"string"},"creator":{"type":"string"},"last_set":{"type":"integer"}},"additionalProperties":true},"locale":{"type":"string"},"created":{"type":"integer"},"creator":{"type":"string"},"is_mpim":{"type":"boolean"},"purpose":{"type":"object","properties":{"value":{"type":"string"},"creator":{"type":"string"},"last_set":{"type":"integer"}},"additionalProperties":true},"is_group":{"type":"boolean"},"unlinked":{"type":"integer"},"is_member":{"type":"boolean"},"is_shared":{"type":"boolean"},"last_read":{"type":"string"},"is_channel":{"type":"boolean"},"is_general":{"type":"boolean"},"is_private":{"type":"boolean"},"is_archived":{"type":"boolean"},"num_members":{"type":"integer"},"is_read_only":{"type":"boolean"},"is_ext_shared":{"type":"boolean"},"is_org_shared":{"type":"boolean"},"pending_shared":{"type":"array","items":{}},"previous_names":{"type":"array","items":{"type":"string"}},"name_normalized":{"type":"string"},"is_pending_ext_shared":{"type":"boolean"}},"additional_properties":true},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@2462ca67[stream=io.airbyte.protocol.models.AirbyteStream@4b3d1515[name=threads,jsonSchema={"type":["null","object"],"properties":{"ts":{"type":["null","number"]},"team":{"type":["null","string"]},"text":{"type":["null","string"]},"type":{"type":["null","string"]},"user":{"type":["null","string"]},"blocks":{"type":["null","array"],"items":{"type":["null","object"],"properties":{"type":{"type":["null","string"]}},"additionalProperties":true}},"thread_ts":{"type":["null","string"]},"channel_id":{"type":["null","string"]},"subscribed":{"type":["null","boolean"]},"reply_count":{"type":["null","integer"]},"reply_users":{"type":["null","array"],"items":{"type":"string"}},"latest_reply":{"type":["null","string"]},"client_msg_id":{"type":["null","string"]},"reply_users_count":{"type":["null","number"]}},"additionalProperties":false},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[float_ts],sourceDefinedPrimaryKey=[[channel_id], [ts]],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[float_ts],destinationSyncMode=append_dedup,primaryKey=[[channel_id], [ts]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@4568cffd[stream=io.airbyte.protocol.models.AirbyteStream@48ca1a82[name=users,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-06/schema#","properties":{"id":{"type":"string"},"tz":{"type":"string"},"name":{"type":"string"},"color":{"type":"string"},"is_bot":{"type":"boolean"},"deleted":{"type":"boolean"},"has_2fa":{"type":"boolean"},"profile":{"type":"object","properties":{"team":{"type":"string"},"email":{"type":"string"},"phone":{"type":"string"},"skype":{"type":"string"},"title":{"type":"string"},"image_24":{"type":"string"},"image_32":{"type":"string"},"image_48":{"type":"string"},"image_72":{"type":"string"},"image_192":{"type":"string"},"image_512":{"type":"string"},"last_name":{"type":"string"},"real_name":{"type":"string"},"first_name":{"type":"string"},"image_1024":{"type":"string"},"avatar_hash":{"type":"string"},"status_text":{"type":"string"},"display_name":{"type":"string"},"status_emoji":{"type":"string"},"image_original":{"type":"string"},"real_name_normalized":{"type":"string"},"display_name_normalized":{"type":"string"}},"additionalProperties":true},"team_id":{"type":"string"},"updated":{"type":"integer"},"is_admin":{"type":"boolean"},"is_owner":{"type":"boolean"},"tz_label":{"type":"string"},"real_name":{"type":"string"},"tz_offset":{"type":"integer"},"is_app_user":{"type":"boolean"},"is_restricted":{"type":"boolean"},"is_primary_owner":{"type":"boolean"},"is_ultra_restricted":{"type":"boolean"}},"additionalProperties":true},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[[id]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[[id]],additionalProperties={}]],additionalProperties={}]]
2021-07-10 17:39:42 INFO () TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.27.1-alpha
2021-07-10 17:39:42 INFO () DefaultNormalizationWorker(run):61 - Running normalization.
2021-07-10 17:39:42 INFO () LineGobbler(voidCall):85 - Checking if airbyte/normalization:0.1.35 exists...
2021-07-10 17:39:42 INFO () LineGobbler(voidCall):85 - airbyte/normalization:0.1.35 was found locally.
2021-07-10 17:39:42 INFO () DockerProcessFactory(create):146 - Preparing command: docker run --rm --init -i -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -w /data/1/2/normalize --network host --log-driver none airbyte/normalization:0.1.35 run --integration-type postgres --config destination_config.json --catalog destination_catalog.json
2021-07-10 17:39:45 INFO () LineGobbler(voidCall):85 - Running: transform-config --config destination_config.json --integration-type postgres --out /data/1/2/normalize
2021-07-10 17:39:45 INFO () LineGobbler(voidCall):85 - Namespace(config='destination_config.json', integration_type=<DestinationType.postgres: 'postgres'>, out='/data/1/2/normalize')
2021-07-10 17:39:45 INFO () LineGobbler(voidCall):85 - transform_postgres
2021-07-10 17:39:45 INFO () LineGobbler(voidCall):85 - Running: transform-catalog --integration-type postgres --profile-config-dir /data/1/2/normalize --catalog destination_catalog.json --out /data/1/2/normalize/models/generated/ --json-column _airbyte_data
2021-07-10 17:39:46 INFO () LineGobbler(voidCall):85 - Processing destination_catalog.json...
2021-07-10 17:39:46 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/public/channel_members_ab1.sql from channel_members
2021-07-10 17:39:46 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/public/channel_members_ab2.sql from channel_members
2021-07-10 17:39:46 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/public/channel_members_ab3.sql from channel_members
2021-07-10 17:39:46 INFO () LineGobbler(voidCall):85 -   Generating airbyte_tables/public/channel_members.sql from channel_members
2021-07-10 17:39:46 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/public/channel_messages_ab1.sql from channel_messages
2021-07-10 17:39:46 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/public/channel_messages_ab2.sql from channel_messages
2021-07-10 17:39:46 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/public/channel_messages_ab3.sql from channel_messages
2021-07-10 17:39:46 INFO () LineGobbler(voidCall):85 -   Generating airbyte_ctes/public/channel_messages_ab4.sql from channel_messages
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 - Traceback (most recent call last):
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/bin/transform-catalog", line 8, in <module>
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -     sys.exit(main())
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.8/site-packages/normalization/transform_catalog/transform.py", line 102, in main
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -     TransformCatalog().run(args)
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.8/site-packages/normalization/transform_catalog/transform.py", line 55, in run
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -     self.process_catalog()
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.8/site-packages/normalization/transform_catalog/transform.py", line 82, in process_catalog
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -     processor.process(catalog_file=catalog_file, json_column_name=json_col, default_schema=schema)
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.8/site-packages/normalization/transform_catalog/catalog_processor.py", line 93, in process
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -     nested_processors = stream_processor.process()
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.8/site-packages/normalization/transform_catalog/stream_processor.py", line 231, in process
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -     self.generate_scd_type_2_model(from_table, column_names) + where_clause,
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.8/site-packages/normalization/transform_catalog/stream_processor.py", line 511, in generate_scd_type_2_model
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -     cursor_field=self.get_cursor_field(column_names),
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -   File "/usr/local/lib/python3.8/site-packages/normalization/transform_catalog/stream_processor.py", line 526, in get_cursor_field
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 -     return column_names[self.cursor_field[0]][0]
2021-07-10 17:39:46 ERROR () LineGobbler(voidCall):85 - KeyError: 'float_ts'
2021-07-10 17:39:47 INFO () TemporalAttemptExecution(lambda$getWorkerThread$2):149 - Completing future exceptionally...
io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:69) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:36) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:146) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
Caused by: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:66) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	... 3 more
	Suppressed: io.airbyte.workers.WorkerException: Normalization process wasn't successful
		at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:151) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:60) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:36) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:146) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:832) [?:?]
2021-07-10 17:39:47 INFO () TemporalAttemptExecution(get):133 - Stopping cancellation check scheduling...
2021-07-10 17:39:47 WARN () POJOActivityTaskHandler$POJOActivityImplementation(execute):243 - Activity failure. ActivityId=80d117ae-bf93-3844-91c7-c108f5551e79, activityType=Normalize, attempt=1
java.util.concurrent.ExecutionException: io.airbyte.workers.WorkerException: Normalization Failed.
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2063) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.get(TemporalAttemptExecution.java:131) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.temporal.SyncWorkflow$NormalizationActivityImpl.normalize(SyncWorkflow.java:321) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:?]
	at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:564) ~[?:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:277) ~[temporal-sdk-1.0.4.jar:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:216) ~[temporal-sdk-1.0.4.jar:?]
	at io.temporal.internal.sync.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:181) ~[temporal-sdk-1.0.4.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:192) ~[temporal-sdk-1.0.4.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:154) ~[temporal-sdk-1.0.4.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:73) ~[temporal-sdk-1.0.4.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:630) [?:?]
	at java.lang.Thread.run(Thread.java:832) [?:?]
Caused by: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:69) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:36) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:146) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	... 1 more
Caused by: io.airbyte.workers.WorkerException: Normalization Failed.
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:66) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:36) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:146) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
	... 1 more
	Suppressed: io.airbyte.workers.WorkerException: Normalization process wasn't successful
		at io.airbyte.workers.normalization.DefaultNormalizationRunner.close(DefaultNormalizationRunner.java:151) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:60) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
		at io.airbyte.workers.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:36) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:146) ~[io.airbyte-airbyte-workers-0.27.1-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:832) [?:?]

Steps to Reproduce

  1. Create slack source connector (I used the integration test account APIKEY / 2020-08-30T00:00:00Z / 7)
  2. Create a destination with normalization enabled
  3. Sync data

Are you willing to submit a PR?

Yes
@marcosmarxm marcosmarxm added the type/bug Something isn't working label Jul 10, 2021
@marcosmarxm marcosmarxm changed the title Source Slack: float_ts Source Slack: using wrong field name for cursor field 'float_ts' Jul 10, 2021
@marcosmarxm marcosmarxm added the area/connectors Connector related issues label Jul 10, 2021
@marcosmarxm marcosmarxm mentioned this issue Jul 10, 2021
Merged
26 tasks
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
area/connectors Connector related issues connectors/source/slack connectors/sources-api type/bug Something isn't working
Projects
None yet
Milestone
No milestone
Development

Successfully merging a pull request may close this issue.

🐛 Source Slack: add float_ts field airbytehq/airbyte
2 participants
@marcosmarxm @igrankova