2022-08-18 08:11:42 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/256/0/logs.log
2022-08-18 08:11:42 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.35-alpha
2022-08-18 08:11:42 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-08-18 08:11:42 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-amazon-seller-partner:0.2.24 exists...
2022-08-18 08:11:42 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-amazon-seller-partner:0.2.24 was found locally.
2022-08-18 08:11:42 [32mINFO[m i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 256
2022-08-18 08:11:42 [32mINFO[m i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/256/0 --log-driver none --name source-amazon-seller-partner-check-256-0-knyfx --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/source-amazon-seller-partner:0.2.24 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.35-alpha -e WORKER_JOB_ID=256 airbyte/source-amazon-seller-partner:0.2.24 check --config source_config.json
2022-08-18 08:11:46 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(internalLog):97 - Check succeeded
2022-08-18 08:11:46 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-08-18 08:11:46 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/256/0/logs.log
2022-08-18 08:11:46 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.35-alpha
2022-08-18 08:11:46 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-08-18 08:11:46 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-csv:0.2.10 exists...
2022-08-18 08:11:46 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-csv:0.2.10 was found locally.
2022-08-18 08:11:46 [32mINFO[m i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 256
2022-08-18 08:11:46 [32mINFO[m i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/256/0 --log-driver none --name destination-csv-check-256-0-hbske --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/destination-csv:0.2.10 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.35-alpha -e WORKER_JOB_ID=256 airbyte/destination-csv:0.2.10 check --config source_config.json
2022-08-18 08:11:47 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-18 08:11:47 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {check=null, config=source_config.json}
2022-08-18 08:11:47 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-18 08:11:47 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.csv.CsvDestination
2022-08-18 08:11:47 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-18 08:11:47 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):124 - Command: CHECK
2022-08-18 08:11:47 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-18 08:11:47 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=CHECK, configPath='source_config.json', catalogPath='null', statePath='null'}
2022-08-18 08:11:47 [32mINFO[m i.a.w.i.DefaultAirbyteStreamFactory(lambda$create$0):61 - 2022-08-18 08:11:47 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-08-18 08:11:48 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-08-18 08:11:48 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):108 - Docker volume job log path: /tmp/workspace/256/0/logs.log
2022-08-18 08:11:48 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):113 - Executing worker wrapper. Airbyte version: 0.39.35-alpha
2022-08-18 08:11:48 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-08-18 08:11:48 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):115 - start sync worker. job id: 256 attempt id: 0
2022-08-18 08:11:48 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):127 - configured sync modes: {null.GET_BRAND_ANALYTICS_SEARCH_TERMS_REPORT=full_refresh - append}
2022-08-18 08:11:48 [32mINFO[m i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2022-08-18 08:11:48 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-08-18 08:11:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/destination-csv:0.2.10 exists...
2022-08-18 08:11:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - airbyte/destination-csv:0.2.10 was found locally.
2022-08-18 08:11:48 [32mINFO[m i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 256
2022-08-18 08:11:48 [32mINFO[m i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/256/0 --log-driver none --name destination-csv-write-256-0-lcvgx --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/destination-csv:0.2.10 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.35-alpha -e WORKER_JOB_ID=256 airbyte/destination-csv:0.2.10 write --config destination_config.json --catalog destination_catalog.json
2022-08-18 08:11:48 [32mINFO[m i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):43 - Using default value for environment variable USE_STREAM_CAPABLE_STATE: 'false'
2022-08-18 08:11:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - Checking if airbyte/source-amazon-seller-partner:0.2.24 exists...
2022-08-18 08:11:48 [32mINFO[m i.a.c.i.LineGobbler(voidCall):82 - airbyte/source-amazon-seller-partner:0.2.24 was found locally.
2022-08-18 08:11:48 [32mINFO[m i.a.w.p.DockerProcessFactory(create):108 - Creating docker job ID: 256
2022-08-18 08:11:48 [32mINFO[m i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/256/0 --log-driver none --name source-amazon-seller-partner-read-256-0-gvifv --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=false -e WORKER_ENVIRONMENT=DOCKER -e AIRBYTE_ROLE= -e WORKER_CONNECTOR_IMAGE=airbyte/source-amazon-seller-partner:0.2.24 -e WORKER_JOB_ATTEMPT=0 -e AIRBYTE_VERSION=0.39.35-alpha -e WORKER_JOB_ID=256 airbyte/source-amazon-seller-partner:0.2.24 read --config source_config.json --catalog source_catalog.json
2022-08-18 08:11:48 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):405 - Destination output thread started.
2022-08-18 08:11:48 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):169 - Waiting for source and destination threads to complete.
2022-08-18 08:11:48 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):298 - Replication thread started.
2022-08-18 08:11:49 [44msource[0m > Starting syncing SourceAmazonSellerPartner
2022-08-18 08:11:49 [43mdestination[0m > 2022-08-18 08:11:49 [32mINFO[m i.a.i.b.IntegrationCliParser(parseOptions):118 - integration args: {catalog=destination_catalog.json, write=null, config=destination_config.json}
2022-08-18 08:11:49 [43mdestination[0m > 2022-08-18 08:11:49 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):123 - Running integration: io.airbyte.integrations.destination.csv.CsvDestination
2022-08-18 08:11:49 [43mdestination[0m > 2022-08-18 08:11:49 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):124 - Command: WRITE
2022-08-18 08:11:49 [43mdestination[0m > 2022-08-18 08:11:49 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):125 - Integration config: IntegrationConfig{command=WRITE, configPath='destination_config.json', catalogPath='destination_catalog.json', statePath='null'}
2022-08-18 08:11:49 [44msource[0m > Syncing stream: GET_BRAND_ANALYTICS_SEARCH_TERMS_REPORT 
2022-08-18 08:11:49 [44msource[0m > Encountered an exception while reading stream GET_BRAND_ANALYTICS_SEARCH_TERMS_REPORT
Traceback (most recent call last):
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 114, in read
    yield from self._read_stream(
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 173, in _read_stream
    for record in record_iterator:
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 267, in _read_full_refresh
    for record in records:
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 339, in read_records
    report_id = self._create_report(sync_mode, cursor_field, stream_slice, stream_state)["reportId"]
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 264, in _create_report
    report_data = self._report_data(sync_mode, cursor_field, stream_slice, stream_state)
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 461, in _report_data
    options = self.report_options()
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 321, in report_options
    return json_lib.loads(self._report_options).get(self.name)
  File "/usr/local/lib/python3.9/json/__init__.py", line 346, in loads
    return _default_decoder.decode(s)
  File "/usr/local/lib/python3.9/json/decoder.py", line 337, in decode
    obj, end = self.raw_decode(s, idx=_w(s, 0).end())
  File "/usr/local/lib/python3.9/json/decoder.py", line 355, in raw_decode
    raise JSONDecodeError("Expecting value", s, err.value) from None
json.decoder.JSONDecodeError: Expecting value: line 1 column 1 (char 0)
2022-08-18 08:11:49 [44msource[0m > Finished syncing GET_BRAND_ANALYTICS_SEARCH_TERMS_REPORT
2022-08-18 08:11:49 [44msource[0m > SourceAmazonSellerPartner runtimes:
Syncing stream GET_BRAND_ANALYTICS_SEARCH_TERMS_REPORT 0:00:00.001801
2022-08-18 08:11:49 [44msource[0m > Expecting value: line 1 column 1 (char 0)
Traceback (most recent call last):
  File "/airbyte/integration_code/main.py", line 13, in <module>
    launch(source, sys.argv[1:])
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py", line 123, in launch
    for message in source_entrypoint.run(parsed_args):
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py", line 114, in run
    for message in generator:
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 128, in read
    raise e
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 114, in read
    yield from self._read_stream(
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 173, in _read_stream
    for record in record_iterator:
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 267, in _read_full_refresh
    for record in records:
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 339, in read_records
    report_id = self._create_report(sync_mode, cursor_field, stream_slice, stream_state)["reportId"]
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 264, in _create_report
    report_data = self._report_data(sync_mode, cursor_field, stream_slice, stream_state)
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 461, in _report_data
    options = self.report_options()
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 321, in report_options
    return json_lib.loads(self._report_options).get(self.name)
  File "/usr/local/lib/python3.9/json/__init__.py", line 346, in loads
    return _default_decoder.decode(s)
  File "/usr/local/lib/python3.9/json/decoder.py", line 337, in decode
    obj, end = self.raw_decode(s, idx=_w(s, 0).end())
  File "/usr/local/lib/python3.9/json/decoder.py", line 355, in raw_decode
    raise JSONDecodeError("Expecting value", s, err.value) from None
json.decoder.JSONDecodeError: Expecting value: line 1 column 1 (char 0)
2022-08-18 08:11:49 [43mdestination[0m > 2022-08-18 08:11:49 [33mWARN[m c.n.s.JsonMetaSchema(newValidator):338 - Unknown keyword examples - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword
2022-08-18 08:11:49 [43mdestination[0m > 2022-08-18 08:11:49 [32mINFO[m i.a.i.d.c.CsvDestination$CsvConsumer(<init>):140 - initializing consumer.
2022-08-18 08:11:49 [32mINFO[m i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):327 - Source has no more messages, closing connection.
2022-08-18 08:11:49 [43mdestination[0m > 2022-08-18 08:11:49 [32mINFO[m i.a.i.b.FailureTrackingAirbyteMessageConsumer(close):65 - Airbyte message consumer: succeeded.
2022-08-18 08:11:49 [43mdestination[0m > 2022-08-18 08:11:49 [32mINFO[m i.a.i.d.c.CsvDestination$CsvConsumer(close):179 - finalizing consumer.
2022-08-18 08:11:49 [43mdestination[0m > 2022-08-18 08:11:49 [32mINFO[m i.a.i.d.c.CsvDestination$CsvConsumer(close):195 - File output: /local/_airbyte_raw_GET_BRAND_ANALYTICS_SEARCH_TERMS_REPORT.csv
2022-08-18 08:11:49 [43mdestination[0m > 2022-08-18 08:11:49 [32mINFO[m i.a.i.b.IntegrationRunner(runInternal):171 - Completed integration: io.airbyte.integrations.destination.csv.CsvDestination
2022-08-18 08:11:49 [1;31mERROR[m i.a.w.g.DefaultReplicationWorker(run):180 - Sync worker failed.
java.util.concurrent.ExecutionException: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!
	at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396) ~[?:?]
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073) ~[?:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:173) ~[io.airbyte-airbyte-workers-0.39.35-alpha.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.35-alpha.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.35-alpha.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]
	Suppressed: io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.
		at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.39.35-alpha.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:137) ~[io.airbyte-airbyte-workers-0.39.35-alpha.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:65) ~[io.airbyte-airbyte-workers-0.39.35-alpha.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:158) ~[io.airbyte-airbyte-workers-0.39.35-alpha.jar:?]
		at java.lang.Thread.run(Thread.java:833) [?:?]
Caused by: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:331) ~[io.airbyte-airbyte-workers-0.39.35-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
Caused by: io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.
	at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136) ~[io.airbyte-airbyte-workers-0.39.35-alpha.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:329) ~[io.airbyte-airbyte-workers-0.39.35-alpha.jar:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	... 1 more
2022-08-18 08:11:49 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):239 - sync summary: io.airbyte.config.ReplicationAttemptSummary@6e451954[status=failed,recordsSynced=0,bytesSynced=0,startTime=1660810308156,endTime=1660810309794,totalStats=io.airbyte.config.SyncStats@14f94141[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]]
2022-08-18 08:11:49 [32mINFO[m i.a.w.g.DefaultReplicationWorker(run):268 - Source did not output any state messages
2022-08-18 08:11:49 [33mWARN[m i.a.w.g.DefaultReplicationWorker(run):279 - State capture: No state retained.
2022-08-18 08:11:49 [32mINFO[m i.a.w.t.TemporalAttemptExecution(get):134 - Stopping cancellation check scheduling...
2022-08-18 08:11:49 [32mINFO[m i.a.w.t.s.ReplicationActivityImpl(lambda$replicate$3):161 - sync summary: io.airbyte.config.StandardSyncOutput@580ff383[standardSyncSummary=io.airbyte.config.StandardSyncSummary@1d0d76e6[status=failed,recordsSynced=0,bytesSynced=0,startTime=1660810308156,endTime=1660810309794,totalStats=io.airbyte.config.SyncStats@14f94141[recordsEmitted=0,bytesEmitted=0,stateMessagesEmitted=0,recordsCommitted=0],streamStats=[]],normalizationSummary=<null>,state=<null>,outputCatalog=io.airbyte.protocol.models.ConfiguredAirbyteCatalog@735345b4[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@2c5a0997[stream=io.airbyte.protocol.models.AirbyteStream@bee6474[name=GET_BRAND_ANALYTICS_SEARCH_TERMS_REPORT,jsonSchema={"type":"object","title":"Brand Analytics Search Terms Reports","$schema":"http://json-schema.org/draft-07/schema#","properties":{"clickShare":{"type":["null","number"]},"searchTerm":{"type":["null","string"]},"clickedAsin":{"type":["null","string"]},"clickShareRank":{"type":["null","number"]},"departmentName":{"type":["null","string"]},"conversionShare":{"type":["null","number"]},"searchFrequencyRank":{"type":["null","number"]}},"description":"Brand Analytics Search Terms Reports"},supportedSyncModes=[full_refresh],sourceDefinedCursor=<null>,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}],failures=[io.airbyte.config.FailureReason@7d2289a9[failureOrigin=source,failureType=system_error,internalMessage=Expecting value: line 1 column 1 (char 0),externalMessage=Something went wrong in the connector. See the logs for more details.,metadata=io.airbyte.config.Metadata@14b50d5c[additionalProperties={attemptNumber=0, jobId=256, from_trace_message=true}],stacktrace=Traceback (most recent call last):
  File "/airbyte/integration_code/main.py", line 13, in <module>
    launch(source, sys.argv[1:])
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py", line 123, in launch
    for message in source_entrypoint.run(parsed_args):
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/entrypoint.py", line 114, in run
    for message in generator:
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 128, in read
    raise e
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 114, in read
    yield from self._read_stream(
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 173, in _read_stream
    for record in record_iterator:
  File "/usr/local/lib/python3.9/site-packages/airbyte_cdk/sources/abstract_source.py", line 267, in _read_full_refresh
    for record in records:
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 339, in read_records
    report_id = self._create_report(sync_mode, cursor_field, stream_slice, stream_state)["reportId"]
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 264, in _create_report
    report_data = self._report_data(sync_mode, cursor_field, stream_slice, stream_state)
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 461, in _report_data
    options = self.report_options()
  File "/airbyte/integration_code/source_amazon_seller_partner/streams.py", line 321, in report_options
    return json_lib.loads(self._report_options).get(self.name)
  File "/usr/local/lib/python3.9/json/__init__.py", line 346, in loads
    return _default_decoder.decode(s)
  File "/usr/local/lib/python3.9/json/decoder.py", line 337, in decode
    obj, end = self.raw_decode(s, idx=_w(s, 0).end())
  File "/usr/local/lib/python3.9/json/decoder.py", line 355, in raw_decode
    raise JSONDecodeError("Expecting value", s, err.value) from None
json.decoder.JSONDecodeError: Expecting value: line 1 column 1 (char 0)
,retryable=<null>,timestamp=1660810309512], io.airbyte.config.FailureReason@68dfa8ec[failureOrigin=source,failureType=<null>,internalMessage=io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!,externalMessage=Something went wrong within the source connector,metadata=io.airbyte.config.Metadata@10eaac47[additionalProperties={attemptNumber=0, jobId=256}],stacktrace=java.util.concurrent.CompletionException: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:315)
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:320)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1807)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: io.airbyte.workers.general.DefaultReplicationWorker$SourceException: Source cannot be stopped!
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:331)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	... 3 more
Caused by: io.airbyte.workers.exception.WorkerException: Source process exit with code 1. This warning is normal if the job was cancelled.
	at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:136)
	at io.airbyte.workers.general.DefaultReplicationWorker.lambda$getReplicationRunnable$6(DefaultReplicationWorker.java:329)
	... 4 more
,retryable=<null>,timestamp=1660810309660]]]
2022-08-18 08:11:49 [32mINFO[m i.a.w.t.TemporalUtils(withBackgroundHeartbeat):291 - Stopping temporal heartbeating...