2022-02-09 13:19:15 INFO i.a.w.w.WorkerRun(call):49 - Executing worker wrapper. Airbyte version: 0.35.26-alpha
2022-02-09 13:19:15 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/1/0/logs.log
2022-02-09 13:19:15 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.26-alpha
2022-02-09 13:19:15 WARN c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword example - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-02-09 13:19:15 INFO i.a.w.DefaultReplicationWorker(run):103 - start sync worker. job id: 1 attempt id: 0
2022-02-09 13:19:15 INFO i.a.w.DefaultReplicationWorker(run):115 - configured sync modes: {null.active_users=full_refresh - append, null.annotations=full_refresh - append, null.average_session_length=incremental - append, null.events=incremental - append}
2022-02-09 13:19:15 INFO i.a.w.p.a.DefaultAirbyteDestination(start):69 - Running destination...
2022-02-09 13:19:16 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-postgres:0.3.13 exists...
2022-02-09 13:19:16 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-postgres:0.3.13 was found locally.
2022-02-09 13:19:16 INFO i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/1/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/destination-postgres:0.3.13 write --config destination_config.json --catalog destination_catalog.json
2022-02-09 13:19:16 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-amplitude:0.1.4 exists...
2022-02-09 13:19:16 INFO i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/1/0 --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/source-amplitude:0.1.4 read --config source_config.json --catalog source_catalog.json
2022-02-09 13:19:16 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-amplitude:0.1.4 was found locally.
2022-02-09 13:19:16 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):337 - Destination output thread started.
2022-02-09 13:19:16 INFO i.a.w.DefaultReplicationWorker(run):157 - Waiting for source and destination threads to complete.
2022-02-09 13:19:16 INFO i.a.w.DefaultReplicationWorker(lambda$getReplicationRunnable$5):278 - Replication thread started.
2022-02-09 13:19:17 source > Starting syncing SourceAmplitude
2022-02-09 13:19:17 source > Syncing stream: active_users 
2022-02-09 13:19:18 destination > 2022-02-09 13:19:18 INFO i.a.i.d.p.PostgresDestination(main):69 - {} - starting destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-02-09 13:19:18 destination > 2022-02-09 13:19:18 INFO i.a.i.b.IntegrationRunner(run):76 - {} - Running integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-02-09 13:19:19 destination > 2022-02-09 13:19:19 INFO i.a.i.b.IntegrationCliParser(parseOptions):118 - {} - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-02-09 13:19:19 destination > 2022-02-09 13:19:19 INFO i.a.i.b.IntegrationRunner(run):80 - {} - Command: WRITE
2022-02-09 13:19:19 destination > 2022-02-09 13:19:19 INFO i.a.i.b.IntegrationRunner(run):81 - {} - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-02-09 13:19:19 destination > 2022-02-09 13:19:19 WARN c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-02-09 13:19:19 destination > 2022-02-09 13:19:19 WARN c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-02-09 13:19:19 destination > 2022-02-09 13:19:19 WARN c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-02-09 13:19:19 destination > 2022-02-09 13:19:19 WARN c.n.s.JsonMetaSchema(newValidator):338 - {} - Unknown keyword multiline - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-02-09 13:19:20 destination > 2022-02-09 13:19:20 INFO i.a.i.b.s.SshTunnel(getInstance):170 - {} - Starting connection with method: NO_TUNNEL
2022-02-09 13:19:20 destination > 2022-02-09 13:19:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - {} - Write config: WriteConfig{streamName=amplitude-active_users, namespace=null, outputSchemaName=public, tmpTableName=_airbyte_tmp_fqp_amplitude_active_users, outputTableName=_airbyte_raw_amplitude_active_users, syncMode=append}
2022-02-09 13:19:20 destination > 2022-02-09 13:19:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - {} - Write config: WriteConfig{streamName=amplitude-annotations, namespace=null, outputSchemaName=public, tmpTableName=_airbyte_tmp_bsi_amplitude_annotations, outputTableName=_airbyte_raw_amplitude_annotations, syncMode=append}
2022-02-09 13:19:20 destination > 2022-02-09 13:19:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - {} - Write config: WriteConfig{streamName=amplitude-average_session_length, namespace=null, outputSchemaName=public, tmpTableName=_airbyte_tmp_ely_amplitude_average_session_length, outputTableName=_airbyte_raw_amplitude_average_session_length, syncMode=append}
2022-02-09 13:19:20 destination > 2022-02-09 13:19:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$toWriteConfig$0):96 - {} - Write config: WriteConfig{streamName=amplitude-events, namespace=null, outputSchemaName=public, tmpTableName=_airbyte_tmp_dmq_amplitude_events, outputTableName=_airbyte_raw_amplitude_events, syncMode=append}
2022-02-09 13:19:20 destination > 2022-02-09 13:19:20 INFO i.a.i.d.b.BufferedStreamConsumer(startTracked):125 - {} - class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started.
2022-02-09 13:19:20 destination > 2022-02-09 13:19:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):121 - {} - Preparing tmp tables in destination started for 4 streams
2022-02-09 13:19:20 destination > 2022-02-09 13:19:20 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - {} - Preparing tmp table in destination started for stream amplitude-active_users. schema: public, tmp table name: _airbyte_tmp_fqp_amplitude_active_users
2022-02-09 13:19:21 destination > 2022-02-09 13:19:21 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - {} - Preparing tmp table in destination started for stream amplitude-annotations. schema: public, tmp table name: _airbyte_tmp_bsi_amplitude_annotations
2022-02-09 13:19:21 destination > 2022-02-09 13:19:21 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - {} - Preparing tmp table in destination started for stream amplitude-average_session_length. schema: public, tmp table name: _airbyte_tmp_ely_amplitude_average_session_length
2022-02-09 13:19:21 destination > 2022-02-09 13:19:21 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):125 - {} - Preparing tmp table in destination started for stream amplitude-events. schema: public, tmp table name: _airbyte_tmp_dmq_amplitude_events
2022-02-09 13:19:21 destination > 2022-02-09 13:19:21 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onStartFunction$1):131 - {} - Preparing tables in destination completed.
2022-02-09 13:19:22 source > Read 262 records from active_users stream
2022-02-09 13:19:22 source > Finished syncing SourceAmplitude
2022-02-09 13:19:22 source > SourceAmplitude runtimes:

2022-02-09 13:19:22 source > Syncing stream: annotations 
2022-02-09 13:19:23 source > Read 0 records from annotations stream
2022-02-09 13:19:23 source > Finished syncing SourceAmplitude
2022-02-09 13:19:23 source > SourceAmplitude runtimes:

2022-02-09 13:19:23 source > Syncing stream: average_session_length 
2022-02-09 13:19:24 source > Setting state of average_session_length stream to {'date': '2021-06-10'}
2022-02-09 13:19:24 source > Setting state of average_session_length stream to {'date': '2021-06-19'}
2022-02-09 13:19:24 source > Setting state of average_session_length stream to {'date': '2021-06-29'}
2022-02-09 13:19:24 source > Setting state of average_session_length stream to {'date': '2021-07-08'}
2022-02-09 13:19:25 source > Setting state of average_session_length stream to {'date': '2021-07-17'}
2022-02-09 13:19:25 source > Setting state of average_session_length stream to {'date': '2021-07-27'}
2022-02-09 13:19:25 source > Setting state of average_session_length stream to {'date': '2021-08-05'}
2022-02-09 13:19:25 source > Setting state of average_session_length stream to {'date': '2021-08-15'}
2022-02-09 13:19:26 source > Setting state of average_session_length stream to {'date': '2021-08-24'}
2022-02-09 13:19:26 source > Setting state of average_session_length stream to {'date': '2021-09-02'}
2022-02-09 13:19:26 source > Setting state of average_session_length stream to {'date': '2021-09-12'}
2022-02-09 13:19:27 source > Setting state of average_session_length stream to {'date': '2021-09-21'}
2022-02-09 13:19:27 source > Setting state of average_session_length stream to {'date': '2021-09-30'}
2022-02-09 13:19:27 source > Setting state of average_session_length stream to {'date': '2021-10-10'}
2022-02-09 13:19:28 source > Setting state of average_session_length stream to {'date': '2021-10-19'}
2022-02-09 13:19:28 source > Setting state of average_session_length stream to {'date': '2021-10-29'}
2022-02-09 13:19:28 source > Setting state of average_session_length stream to {'date': '2021-11-07'}
2022-02-09 13:19:29 source > Setting state of average_session_length stream to {'date': '2021-11-16'}
2022-02-09 13:19:29 source > Setting state of average_session_length stream to {'date': '2021-11-26'}
2022-02-09 13:19:29 source > Setting state of average_session_length stream to {'date': '2021-12-05'}
2022-02-09 13:19:30 source > Setting state of average_session_length stream to {'date': '2021-12-14'}
2022-02-09 13:19:30 source > Setting state of average_session_length stream to {'date': '2021-12-24'}
2022-02-09 13:19:31 source > Setting state of average_session_length stream to {'date': '2022-01-02'}
2022-02-09 13:19:31 source > Setting state of average_session_length stream to {'date': '2022-01-12'}
2022-02-09 13:19:32 source > Setting state of average_session_length stream to {'date': '2022-01-21'}
2022-02-09 13:19:32 source > Setting state of average_session_length stream to {'date': '2022-01-30'}
2022-02-09 13:19:32 source > Setting state of average_session_length stream to {'date': '2022-02-09'}
2022-02-09 13:19:32 source > Setting state of average_session_length stream to {'date': '2022-02-09'}
2022-02-09 13:19:32 source > Read 270 records from average_session_length stream
2022-02-09 13:19:32 source > Finished syncing SourceAmplitude
2022-02-09 13:19:32 source > SourceAmplitude runtimes:

2022-02-09 13:19:32 source > Syncing stream: events 
2022-02-09 13:19:35 source > Error during syncing events stream - 404 Client Error: Not Found for url: https://amplitude.com/api/2/export?start=20210601T00&end=20210604T00
2022-02-09 13:19:35 source > Setting state of events stream to {}
2022-02-09 13:19:35 source > Read 0 records from events stream
2022-02-09 13:19:35 source > Finished syncing SourceAmplitude
2022-02-09 13:19:35 source > SourceAmplitude runtimes:

2022-02-09 13:19:35 source > Finished syncing SourceAmplitude
2022-02-09 13:19:36 INFO i.a.w.DefaultReplicationWorker(run):162 - One of source or destination thread complete. Waiting on the other.
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):60 - {} - Airbyte message consumer: succeeded.
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.d.b.BufferedStreamConsumer(close):200 - {} - executing on success close procedure.
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):160 - {} - Finalizing tables in destination started for 4 streams
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - {} - Finalizing stream amplitude-active_users. schema public, tmp table _airbyte_tmp_fqp_amplitude_active_users, final table _airbyte_raw_amplitude_active_users
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - {} - Finalizing stream amplitude-annotations. schema public, tmp table _airbyte_tmp_bsi_amplitude_annotations, final table _airbyte_raw_amplitude_annotations
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - {} - Finalizing stream amplitude-average_session_length. schema public, tmp table _airbyte_tmp_ely_amplitude_average_session_length, final table _airbyte_raw_amplitude_average_session_length
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):165 - {} - Finalizing stream amplitude-events. schema public, tmp table _airbyte_tmp_dmq_amplitude_events, final table _airbyte_raw_amplitude_events
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):178 - {} - Executing finalization of tables.
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):180 - {} - Finalizing tables in destination completed.
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):183 - {} - Cleaning tmp tables in destination started for 4 streams
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Cleaning tmp table in destination started for stream amplitude-active_users. schema public, tmp table name: _airbyte_tmp_fqp_amplitude_active_users
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Cleaning tmp table in destination started for stream amplitude-annotations. schema public, tmp table name: _airbyte_tmp_bsi_amplitude_annotations
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Cleaning tmp table in destination started for stream amplitude-average_session_length. schema public, tmp table name: _airbyte_tmp_ely_amplitude_average_session_length
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):187 - {} - Cleaning tmp table in destination started for stream amplitude-events. schema public, tmp table name: _airbyte_tmp_dmq_amplitude_events
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.d.j.JdbcBufferedConsumerFactory(lambda$onCloseFunction$3):192 - {} - Cleaning tmp tables in destination completed.
2022-02-09 13:19:36 INFO i.a.w.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$6):347 - State in DefaultReplicationWorker from destination: io.airbyte.protocol.models.AirbyteMessage@538ecf10[type=STATE,log=<null>,spec=<null>,connectionStatus=<null>,catalog=<null>,record=<null>,state=io.airbyte.protocol.models.AirbyteStateMessage@6e817734[data={"average_session_length":{"date":"2022-02-09"},"events":{}},additionalProperties={}],additionalProperties={}]
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.b.IntegrationRunner(run):133 - {} - Completed integration: io.airbyte.integrations.base.ssh.SshWrappedDestination
2022-02-09 13:19:36 destination > 2022-02-09 13:19:36 INFO i.a.i.d.p.PostgresDestination(main):71 - {} - completed destination: class io.airbyte.integrations.destination.postgres.PostgresDestination
2022-02-09 13:19:36 INFO i.a.w.DefaultReplicationWorker(run):164 - Source and destination threads complete.
2022-02-09 13:19:36 INFO i.a.w.DefaultReplicationWorker(run):227 - sync summary: io.airbyte.config.ReplicationAttemptSummary@f261e20[status=completed,recordsSynced=532,bytesSynced=250245,startTime=1644412755996,endTime=1644412776591,totalStats=io.airbyte.config.SyncStats@1e635ddc[recordsEmitted=532,bytesEmitted=250245,stateMessagesEmitted=29,recordsCommitted=532],streamStats=[io.airbyte.config.StreamSyncStats@8fc72c4[streamName=amplitude-average_session_length,stats=io.airbyte.config.SyncStats@741c746d[recordsEmitted=270,bytesEmitted=11590,stateMessagesEmitted=<null>,recordsCommitted=270]], io.airbyte.config.StreamSyncStats@4bf4b3d0[streamName=amplitude-active_users,stats=io.airbyte.config.SyncStats@4ffd8acf[recordsEmitted=262,bytesEmitted=238655,stateMessagesEmitted=<null>,recordsCommitted=262]]]]
2022-02-09 13:19:36 INFO i.a.w.DefaultReplicationWorker(run):247 - Source output at least one state message
2022-02-09 13:19:36 INFO i.a.w.DefaultReplicationWorker(run):253 - State capture: Updated state to: Optional[io.airbyte.config.State@33540c58[state={"average_session_length":{"date":"2022-02-09"},"events":{}}]]
2022-02-09 13:19:36 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-02-09 13:19:36 INFO i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$1):144 - sync summary: io.airbyte.config.StandardSyncOutput@295992d9[standardSyncSummary=io.airbyte.config.StandardSyncSummary@160b2ab4[status=completed,recordsSynced=532,bytesSynced=250245,startTime=1644412755996,endTime=1644412776591,totalStats=io.airbyte.config.SyncStats@1e635ddc[recordsEmitted=532,bytesEmitted=250245,stateMessagesEmitted=29,recordsCommitted=532],streamStats=[io.airbyte.config.StreamSyncStats@8fc72c4[streamName=amplitude-average_session_length,stats=io.airbyte.config.SyncStats@741c746d[recordsEmitted=270,bytesEmitted=11590,stateMessagesEmitted=<null>,recordsCommitted=270]], io.airbyte.config.StreamSyncStats@4bf4b3d0[streamName=amplitude-active_users,stats=io.airbyte.config.SyncStats@4ffd8acf[recordsEmitted=262,bytesEmitted=238655,stateMessagesEmitted=<null>,recordsCommitted=262]]]],state=io.airbyte.config.State@33540c58[state={"average_session_length":{"date":"2022-02-09"},"events":{}}],outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@4dd2974f[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@21a6b6b0[stream=io.airbyte.protocol.models.AirbyteStream@440c3707[name=amplitude-active_users,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"date":{"type":["null","string"],"format":"date"},"statistics":{"type":["null","object"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[date],sourceDefinedPrimaryKey=[[date]],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[date],destinationSyncMode=append,primaryKey=[[date]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@b1dfbb8[stream=io.airbyte.protocol.models.AirbyteStream@522c6d7b[name=amplitude-annotations,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"id":{"type":["null","integer"]},"date":{"type":["null","string"],"format":"date-time"},"label":{"type":["null","string"]},"details":{"type":["null","string"]}}},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@46ab52b8[stream=io.airbyte.protocol.models.AirbyteStream@63bae165[name=amplitude-average_session_length,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"date":{"type":["null","string"],"format":"date"},"length":{"type":["null","number"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[date],sourceDefinedPrimaryKey=[[date]],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[date],destinationSyncMode=append,primaryKey=[[date]],additionalProperties={}], io.airbyte.protocol.models.ConfiguredAirbyteStream@71e0691[stream=io.airbyte.protocol.models.AirbyteStream@36e8e4bc[name=amplitude-events,jsonSchema={"type":"object","$schema":"http://json-schema.org/draft-07/schema#","properties":{"app":{"type":["null","integer"]},"dma":{"type":["null","string"]},"adid":{"type":["null","string"]},"city":{"type":["null","string"]},"data":{"type":["null","object"]},"idfa":{"type":["null","string"]},"uuid":{"type":["null","string"]},"groups":{"type":["null","object"]},"paying":{"type":["null","boolean"]},"region":{"type":["null","string"]},"$schema":{"type":["null","integer"]},"country":{"type":["null","string"]},"library":{"type":["null","string"]},"os_name":{"type":["null","string"]},"user_id":{"type":["null","string"]},"event_id":{"type":["null","integer"]},"language":{"type":["null","string"]},"platform":{"type":["null","string"]},"device_id":{"type":["null","string"]},"$insert_id":{"type":["null","string"]},"event_time":{"type":["null","string"],"format":"date-time"},"event_type":{"type":["null","string"]},"ip_address":{"type":["null","string"]},"os_version":{"type":["null","string"]},"session_id":{"type":["null","number"]},"device_type":{"type":["null","string"]},"sample_rate":{"type":["null","string","number"]},"amplitude_id":{"type":["null","integer"]},"device_brand":{"type":["null","string"]},"device_model":{"type":["null","string"]},"location_lat":{"type":["null","number"]},"location_lng":{"type":["null","number"]},"version_name":{"type":["null","string"]},"device_family":{"type":["null","string"]},"start_version":{"type":["null","string"]},"device_carrier":{"type":["null","string"]},"processed_time":{"type":["null","string"],"format":"date-time"},"user_properties":{"type":["null","object"]},"event_properties":{"type":["null","object"]},"group_properties":{"type":["null","object"]},"client_event_time":{"type":["null","string"],"format":"date-time"},"client_upload_time":{"type":["null","string"],"format":"date-time"},"server_upload_time":{"type":["null","string"],"format":"date-time"},"user_creation_time":{"type":["null","string"],"format":"date-time"},"device_manufacturer":{"type":["null","string"]},"amplitude_event_type":{"type":["null","string"]},"is_attribution_event":{"type":["null","boolean"]},"server_received_time":{"type":["null","string"],"format":"date-time"},"amplitude_attribution_ids":{"type":["null","string"]}}},supportedSyncModes=[full_refresh, incremental],sourceDefinedCursor=true,defaultCursorField=[event_time],sourceDefinedPrimaryKey=[[uuid]],namespace=<null>,additionalProperties={}],syncMode=incremental,cursorField=[event_time],destinationSyncMode=append,primaryKey=[[uuid]],additionalProperties={}]],additionalProperties={}],failures=[]]
2022-02-09 13:19:36 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):234 - Stopping temporal heartbeating...
2022-02-09 13:19:36 INFO i.a.c.p.ConfigRepository(updateConnectionState):545 - Updating connection 9cd251e4-b4cc-4d49-9b90-acedb3cef063 state: io.airbyte.config.State@10d473ed[state={"average_session_length":{"date":"2022-02-09"},"events":{}}]
2022-02-09 13:19:36 INFO i.a.w.t.TemporalAttemptExecution(get):105 - Docker volume job log path: /tmp/workspace/1/0/logs.log
2022-02-09 13:19:36 INFO i.a.w.t.TemporalAttemptExecution(get):110 - Executing worker wrapper. Airbyte version: 0.35.26-alpha
2022-02-09 13:19:36 INFO i.a.w.DefaultNormalizationWorker(run):46 - Running normalization.
2022-02-09 13:19:36 INFO i.a.w.n.DefaultNormalizationRunner(runProcess):122 - Running with normalization version: airbyte/normalization:0.1.66
2022-02-09 13:19:36 INFO i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/normalization:0.1.66 exists...
2022-02-09 13:19:36 INFO i.a.c.i.LineGobbler(voidCall):82 - airbyte/normalization:0.1.66 not found locally. Attempting to pull the image...
2022-02-09 13:20:01 INFO i.a.c.i.LineGobbler(voidCall):82 - Pulled airbyte/normalization:0.1.66 from remote.
2022-02-09 13:20:01 INFO i.a.w.p.DockerProcessFactory(create):157 - Preparing command: docker run --rm --init -i -w /data/1/0/normalize --log-driver none --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local airbyte/normalization:0.1.66 run --integration-type postgres --config destination_config.json --catalog destination_catalog.json
2022-02-09 13:20:05 normalization > Running: transform-config --config destination_config.json --integration-type postgres --out /data/1/0/normalize
2022-02-09 13:20:06 normalization > Namespace(config='destination_config.json', integration_type=<DestinationType.postgres: 'postgres'>, out='/data/1/0/normalize')
2022-02-09 13:20:06 normalization > transform_postgres
2022-02-09 13:20:06 normalization > Running: transform-catalog --integration-type postgres --profile-config-dir /data/1/0/normalize --catalog destination_catalog.json --out /data/1/0/normalize/models/generated/ --json-column _airbyte_data
2022-02-09 13:20:06 normalization > Processing destination_catalog.json...
2022-02-09 13:20:06 normalization >   Generating airbyte_ctes/public/amplitude_active_users_ab1.sql from amplitude-active_users
2022-02-09 13:20:06 normalization >   Generating airbyte_ctes/public/amplitude_active_users_ab2.sql from amplitude-active_users
2022-02-09 13:20:06 normalization >   Generating airbyte_ctes/public/amplitude_active_users_ab3.sql from amplitude-active_users
2022-02-09 13:20:06 normalization >   Generating airbyte_incremental/public/amplitude_active_users.sql from amplitude-active_users
2022-02-09 13:20:06 normalization >   Generating airbyte_ctes/public/amplitude_annotations_ab1.sql from amplitude-annotations
2022-02-09 13:20:06 normalization >   Generating airbyte_ctes/public/amplitude_annotations_ab2.sql from amplitude-annotations
2022-02-09 13:20:06 normalization >   Generating airbyte_ctes/public/amplitude_annotations_ab3.sql from amplitude-annotations
2022-02-09 13:20:06 normalization >   Generating airbyte_incremental/public/amplitude_annotations.sql from amplitude-annotations
2022-02-09 13:20:06 normalization >   Generating airbyte_ctes/public/amplitude_average_session_length_ab1.sql from amplitude-average_session_length
2022-02-09 13:20:06 normalization >   Generating airbyte_ctes/public/amplitude_average_session_length_ab2.sql from amplitude-average_session_length
2022-02-09 13:20:06 normalization > Truncating _airbyte_amplitude_average_session_length_hashid (#48) to _airbyte_amplitude_a_session_length_hashid (#43)
2022-02-09 13:20:06 normalization >   Generating airbyte_ctes/public/amplitude_average_session_length_ab3.sql from amplitude-average_session_length
2022-02-09 13:20:06 normalization > Truncating _airbyte_amplitude_average_session_length_hashid (#48) to _airbyte_amplitude_a_session_length_hashid (#43)
2022-02-09 13:20:06 normalization >   Generating airbyte_incremental/public/amplitude_average_session_length.sql from amplitude-average_session_length
2022-02-09 13:20:06 normalization >   Generating airbyte_ctes/public/amplitude_events_ab1.sql from amplitude-events
2022-02-09 13:20:06 normalization >   Generating airbyte_ctes/public/amplitude_events_ab2.sql from amplitude-events
2022-02-09 13:20:06 normalization >   Generating airbyte_ctes/public/amplitude_events_ab3.sql from amplitude-events
2022-02-09 13:20:06 normalization >   Generating airbyte_incremental/public/amplitude_events.sql from amplitude-events
2022-02-09 13:20:06 normalization > detected no config file for ssh, assuming ssh is off.
2022-02-09 13:20:08 normalization > Running with dbt=0.21.1
2022-02-09 13:20:09 normalization > Unable to do partial parsing because ../build/partial_parse.msgpack not found
2022-02-09 13:20:10 normalization > [WARNING]: Configuration paths exist in your dbt_project.yml file which do not apply to any resources.
2022-02-09 13:20:10 normalization > There are 2 unused configuration paths:
2022-02-09 13:20:10 normalization > - models.airbyte_utils.generated.airbyte_views
2022-02-09 13:20:10 normalization > - models.airbyte_utils.generated.airbyte_tables
2022-02-09 13:20:10 normalization > 
2022-02-09 13:20:10 normalization > Found 16 models, 0 tests, 0 snapshots, 0 analyses, 494 macros, 0 operations, 0 seed files, 4 sources, 0 exposures
2022-02-09 13:20:10 normalization > 
2022-02-09 13:20:11 normalization > 13:20:11 | Concurrency: 8 threads (target='prod')
2022-02-09 13:20:11 normalization > 13:20:11 | 
2022-02-09 13:20:11 normalization > 13:20:11 | 1 of 4 START incremental model public.amplitude_annotations.................................................. [RUN]
2022-02-09 13:20:11 normalization > 13:20:11 | 2 of 4 START incremental model public.amplitude_average_session_length....................................... [RUN]
2022-02-09 13:20:11 normalization > 13:20:11 | 3 of 4 START incremental model public.amplitude_active_users................................................. [RUN]
2022-02-09 13:20:11 normalization > 13:20:11 + "data".public."amplitude_annotations"._airbyte_ab_id does not exist yet. The table will be created or rebuilt with dbt.full_refresh
2022-02-09 13:20:11 normalization > 13:20:11 + "data".public."amplitude_average_session_length"._airbyte_ab_id does not exist yet. The table will be created or rebuilt with dbt.full_refresh
2022-02-09 13:20:12 normalization > 13:20:12 + "data".public."amplitude_active_users"._airbyte_ab_id does not exist yet. The table will be created or rebuilt with dbt.full_refresh
2022-02-09 13:20:12 normalization > 13:20:12 | 4 of 4 START incremental model public.amplitude_events....................................................... [RUN]
2022-02-09 13:20:12 normalization > 13:20:12 | 1 of 4 OK created incremental model public.amplitude_annotations............................................. [SELECT 0 in 0.52s]
2022-02-09 13:20:12 normalization > 13:20:12 | 2 of 4 OK created incremental model public.amplitude_average_session_length.................................. [SELECT 270 in 0.51s]
2022-02-09 13:20:12 normalization > 13:20:12 | 3 of 4 OK created incremental model public.amplitude_active_users............................................ [SELECT 262 in 0.45s]
2022-02-09 13:20:12 normalization > 13:20:12 + "data".public."amplitude_events"._airbyte_ab_id does not exist yet. The table will be created or rebuilt with dbt.full_refresh
2022-02-09 13:20:12 normalization > 13:20:12 | 4 of 4 OK created incremental model public.amplitude_events.................................................. [SELECT 0 in 0.10s]
2022-02-09 13:20:12 normalization > 13:20:12 | 
2022-02-09 13:20:12 normalization > 13:20:12 | Finished running 4 incremental models in 1.30s.
2022-02-09 13:20:12 normalization > 
2022-02-09 13:20:12 normalization > Completed successfully
2022-02-09 13:20:12 normalization > 
2022-02-09 13:20:12 normalization > Done. PASS=4 WARN=0 ERROR=0 SKIP=0 TOTAL=4
2022-02-09 13:20:12 INFO i.a.w.DefaultNormalizationWorker(run):69 - Normalization executed in 35 seconds.
2022-02-09 13:20:12 INFO i.a.w.t.TemporalAttemptExecution(get):131 - Stopping cancellation check scheduling...
2022-02-09 13:20:12 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):234 - Stopping temporal heartbeating...