2023-09-03 14:05:15 INFO i.a.v.j.JsonSchemaValidator(test):71 - JSON schema validation failed. 
errors: $.access_token: is missing but it is required, $.option_title: must be a constant value OAuth Credentials
2023-09-03 14:05:15 INFO i.a.a.LoggingTrackingClient(track):43 - track. version: null, userId: null, action: Connector Jobs, metadata: {job_type=sync, config.source.credentials.option_title=PAT Credentials, namespace_definition=source, config.destination.edition_configs.segment_user_id=set, config.source.credentials.personal_access_token=set, config.destination.dry_run=false, frequency=manual, connector_source_definition_id=ef69ef6e-aa7f-4af1-a01d-ef775033524e, workspace_id=9305eb98-eff2-4933-980a-3ec54522104b, attempt_stage=STARTED, config.destination.edition_configs.hasura_url=set, attempt_id=1, connector_destination=Faros Destination, catalog.sync_mode.incremental=set, connector_destination_docker_repository=farosai/airbyte-faros-destination, table_prefix=true, config.destination.jsonata_mode=FALLBACK, workspace_name=9305eb98-eff2-4933-980a-3ec54522104b, config.source.start_date=set, catalog.destination_sync_mode.overwrite=set, number_of_streams=10, catalog.destination_sync_mode.append_dedup=set, connector_source=GitHub, connector_source_docker_repository=airbyte/source-github, config.source.repository=set, config.destination.invalid_record_strategy=SKIP, catalog.sync_mode.full_refresh=set, connection_id=5bf5574b-7005-4955-a79e-dd4fc1dbad81, config.destination.edition_configs.edition=community, job_id=25, connector_source_version=0.3.1, connector_destination_version=0.6.7, operation_count=0, config.source.page_size_for_large_streams=set, config.destination.edition_configs.hasura_admin_secret=set, connector_destination_definition_id=5d0b0def-c26d-4c66-ac85-00a7cfd9d160}
2023-09-03 14:05:15 INFO i.a.w.t.TemporalAttemptExecution(get):106 - Docker volume job log path: /tmp/workspace/25/0/logs.log
2023-09-03 14:05:15 INFO i.a.w.t.TemporalAttemptExecution(get):111 - Executing worker wrapper. Airbyte version: 0.40.9
2023-09-03 14:05:15 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-09-03 14:05:15 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-09-03 14:05:15 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-09-03 14:05:15 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-github:0.3.1 exists...
2023-09-03 14:05:15 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-github:0.3.1 was found locally.
2023-09-03 14:05:15 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = source-github-check-25-0-afxci with resources io.airbyte.config.ResourceRequirements@5c2ab614[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-09-03 14:05:15 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/25/0 --log-driver none --name source-github-check-25-0-afxci --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-github:0.3.1 -e AIRBYTE_VERSION=0.40.9 -e WORKER_JOB_ID=25 airbyte/source-github:0.3.1 check --config source_config.json
2023-09-03 14:05:16 INFO i.a.w.i.DefaultAirbyteStreamFactory(internalLog):103 - Check succeeded
2023-09-03 14:05:16 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-09-03 14:05:16 INFO i.a.w.t.TemporalAttemptExecution(get):132 - Stopping cancellation check scheduling...
2023-09-03 14:05:16 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-09-03 14:05:16 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-09-03 14:05:16 INFO i.a.w.t.TemporalAttemptExecution(get):106 - Docker volume job log path: /tmp/workspace/25/0/logs.log
2023-09-03 14:05:16 INFO i.a.w.t.TemporalAttemptExecution(get):111 - Executing worker wrapper. Airbyte version: 0.40.9
2023-09-03 14:05:16 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-09-03 14:05:16 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START CHECK -----
2023-09-03 14:05:16 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-09-03 14:05:16 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if farosai/airbyte-faros-destination:0.6.7 exists...
2023-09-03 14:05:16 INFO i.a.c.i.LineGobbler(voidCall):114 - farosai/airbyte-faros-destination:0.6.7 was found locally.
2023-09-03 14:05:16 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = airbyte-faros-destination-check-25-0-fommq with resources io.airbyte.config.ResourceRequirements@5c2ab614[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-09-03 14:05:16 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/25/0 --log-driver none --name airbyte-faros-destination-check-25-0-fommq --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=farosai/airbyte-faros-destination:0.6.7 -e AIRBYTE_VERSION=0.40.9 -e WORKER_JOB_ID=25 farosai/airbyte-faros-destination:0.6.7 check --config source_config.json
2023-09-03 14:05:16 ERROR i.a.c.i.LineGobbler(voidCall):114 - WARNING: The requested image's platform (linux/amd64) does not match the detected host platform (linux/arm64/v8) and no specific platform was requested
2023-09-03 14:05:20 INFO i.a.w.t.TemporalAttemptExecution(get):132 - Stopping cancellation check scheduling...
2023-09-03 14:05:20 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-09-03 14:05:20 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END CHECK -----
2023-09-03 14:05:20 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-09-03 14:05:20 INFO i.a.w.t.TemporalAttemptExecution(get):106 - Docker volume job log path: /tmp/workspace/25/0/logs.log
2023-09-03 14:05:20 INFO i.a.w.t.TemporalAttemptExecution(get):111 - Executing worker wrapper. Airbyte version: 0.40.9
2023-09-03 14:05:20 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):49 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2023-09-03 14:05:20 INFO i.a.c.EnvConfigs(getEnvOrDefault):1096 - Using default value for environment variable METRIC_CLIENT: ''
2023-09-03 14:05:20 WARN i.a.m.l.MetricClientFactory(initialize):60 - Metric client is already initialized to 
2023-09-03 14:05:20 INFO i.a.c.f.EnvVariableFeatureFlags(getEnvOrDefault):49 - Using default value for environment variable LOG_CONNECTOR_MESSAGES: 'false'
2023-09-03 14:05:20 INFO i.a.w.g.DefaultReplicationWorker(run):122 - start sync worker. job id: 25 attempt id: 0
2023-09-03 14:05:20 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-09-03 14:05:20 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- START REPLICATION -----
2023-09-03 14:05:20 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-09-03 14:05:20 INFO i.a.w.g.DefaultReplicationWorker(run):135 - configured sync modes: {null.pull_requests=incremental - append_dedup, null.review_comments=incremental - append_dedup, null.commits=incremental - append_dedup, null.assignees=full_refresh - overwrite, null.organizations=full_refresh - overwrite, null.branches=full_refresh - overwrite, null.users=full_refresh - overwrite, null.tags=full_refresh - overwrite, null.repositories=full_refresh - overwrite, null.reviews=incremental - append_dedup}
2023-09-03 14:05:20 INFO i.a.w.i.DefaultAirbyteDestination(start):69 - Running destination...
2023-09-03 14:05:20 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if farosai/airbyte-faros-destination:0.6.7 exists...
2023-09-03 14:05:20 INFO i.a.c.i.LineGobbler(voidCall):114 - farosai/airbyte-faros-destination:0.6.7 was found locally.
2023-09-03 14:05:20 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = airbyte-faros-destination-write-25-0-sriph with resources io.airbyte.config.ResourceRequirements@61aaa01a[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-09-03 14:05:20 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/25/0 --log-driver none --name airbyte-faros-destination-write-25-0-sriph --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=farosai/airbyte-faros-destination:0.6.7 -e AIRBYTE_VERSION=0.40.9 -e WORKER_JOB_ID=25 farosai/airbyte-faros-destination:0.6.7 write --config destination_config.json --catalog destination_catalog.json
2023-09-03 14:05:20 INFO i.a.c.i.LineGobbler(voidCall):114 - Checking if airbyte/source-github:0.3.1 exists...
2023-09-03 14:05:20 INFO i.a.c.i.LineGobbler(voidCall):114 - airbyte/source-github:0.3.1 was found locally.
2023-09-03 14:05:20 INFO i.a.w.p.DockerProcessFactory(create):119 - Creating docker container = source-github-read-25-0-worql with resources io.airbyte.config.ResourceRequirements@44bd9889[cpuRequest=,cpuLimit=,memoryRequest=,memoryLimit=]
2023-09-03 14:05:20 INFO i.a.w.p.DockerProcessFactory(create):163 - Preparing command: docker run --rm --init -i -w /data/25/0 --log-driver none --name source-github-read-25-0-worql --network host -v airbyte_workspace:/data -v /tmp/airbyte_local:/local -e DEPLOYMENT_MODE=OSS -e USE_STREAM_CAPABLE_STATE=true -e AIRBYTE_ROLE= -e WORKER_ENVIRONMENT=DOCKER -e WORKER_JOB_ATTEMPT=0 -e WORKER_CONNECTOR_IMAGE=airbyte/source-github:0.3.1 -e AIRBYTE_VERSION=0.40.9 -e WORKER_JOB_ID=25 airbyte/source-github:0.3.1 read --config source_config.json --catalog source_catalog.json --state input_state.json
2023-09-03 14:05:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getDestinationOutputRunnable$7):435 - Destination output thread started.
2023-09-03 14:05:20 INFO i.a.w.g.DefaultReplicationWorker(run):177 - Waiting for source and destination threads to complete.
2023-09-03 14:05:20 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):322 - Replication thread started.
2023-09-03 14:05:20 destination > WARNING: The requested image's platform (linux/amd64) does not match the detected host platform (linux/arm64/v8) and no specific platform was requested
2023-09-03 14:05:20 source > Starting syncing SourceGithub
2023-09-03 14:05:24 destination > Config: {"dry_run":false,"jsonata_mode":"FALLBACK","edition_configs":{"edition":"community","hasura_url":"http://localhost:8080","segment_user_id":"0ea8f59d-ae71-59f8-81b8-5278a21c637c","hasura_admin_secret":"REDACTED","community_graphql_batch_size":100,"api_url":"https://prod.api.faros.ai","graph":"default","graphql_api":"v2","cloud_graphql_upsert_batch_size":10000,"cloud_graphql_batch_size":100,"check_connection":true,"expiration":"5 seconds"},"invalid_record_strategy":"SKIP","replace_origin_map":"{}","exclude_fields_map":"{}","source_specific_configs":{"agileaccelerator":{"max_description_length":1000,"work_additional_fields":[]},"azurepipeline":{"application_mapping":"{}"},"backlog":{"max_description_length":1000},"bitbucket":{"application_mapping":"{}"},"circleci":{"skip_writing_test_cases":true},"clickup":{"taskboard_source":"space","truncate_limit":10000},"datadog":{"application_mapping":"{}"},"docker":{"organization":"unknown-org"},"firehydrant":{"application_mapping":"{}","max_description_length":1000},"jira":{"truncate_limit":10000,"exclude_fields":[],"additional_fields_array_limit":50},"notion":{"projects":{"properties":{"name":"Name","description":"Description"}},"epics":{"properties":{"name":"Name","description":"Description","project":"Project","status":"Status"}},"sprints":{"properties":{"name":"Name","description":"Description","status":"Status","started_at":"Started At","ended_at":"Ended At","closed_at":"Closed At"}},"tasks":{"properties":{"name":"Name","description":"Description","type":"Type","project":"Project","epic":"Epic","sprint":"Sprint","status":"Status","priority":"Priority","points":"Points","assignee":"Assignee","resolved_at":"Resolved At"}}},"opsgenie":{"max_description_length":1000,"application_mapping":"{}"},"pagerduty":{"application_mapping":"{}"},"phabricator":{"max_description_length":1000},"servicenow":{"application_mapping":"{}","application_field":"business_service"},"squadcast":{"application_mapping":"{}"},"statuspage":{"application_mapping":"{}"},"victorops":{"application_mapping":"{}","application_field":"service"}}}
2023-09-03 14:05:24 destination > Catalog: {"streams":[{"stream":{"name":"github_source__github__assignees","json_schema":{},"supported_sync_modes":["full_refresh"],"default_cursor_field":[],"source_defined_primary_key":[["id"]]},"sync_mode":"full_refresh","cursor_field":[],"destination_sync_mode":"overwrite","primary_key":[["id"]]},{"stream":{"name":"github_source__github__branches","json_schema":{},"supported_sync_modes":["full_refresh"],"default_cursor_field":[],"source_defined_primary_key":[["repository"],["name"]]},"sync_mode":"full_refresh","cursor_field":[],"destination_sync_mode":"overwrite","primary_key":[["repository"],["name"]]},{"stream":{"name":"github_source__github__commits","json_schema":{},"supported_sync_modes":["full_refresh","incremental"],"source_defined_cursor":true,"default_cursor_field":["created_at"],"source_defined_primary_key":[["sha"]]},"sync_mode":"incremental","cursor_field":["created_at"],"destination_sync_mode":"append_dedup","primary_key":[["sha"]]},{"stream":{"name":"github_source__github__organizations","json_schema":{},"supported_sync_modes":["full_refresh"],"default_cursor_field":[],"source_defined_primary_key":[["id"]]},"sync_mode":"full_refresh","cursor_field":[],"destination_sync_mode":"overwrite","primary_key":[["id"]]},{"stream":{"name":"github_source__github__pull_requests","json_schema":{},"supported_sync_modes":["full_refresh","incremental"],"source_defined_cursor":true,"default_cursor_field":["updated_at"],"source_defined_primary_key":[["id"]]},"sync_mode":"incremental","cursor_field":["updated_at"],"destination_sync_mode":"append_dedup","primary_key":[["id"]]},{"stream":{"name":"github_source__github__repositories","json_schema":{},"supported_sync_modes":["full_refresh","incremental"],"source_defined_cursor":true,"default_cursor_field":["updated_at"],"source_defined_primary_key":[["id"]]},"sync_mode":"full_refresh","cursor_field":["updated_at"],"destination_sync_mode":"overwrite","primary_key":[["id"]]},{"stream":{"name":"github_source__github__review_comments","json_schema":{},"supported_sync_modes":["full_refresh","incremental"],"source_defined_cursor":true,"default_cursor_field":["updated_at"],"source_defined_primary_key":[["id"]]},"sync_mode":"incremental","cursor_field":["updated_at"],"destination_sync_mode":"append_dedup","primary_key":[["id"]]},{"stream":{"name":"github_source__github__reviews","json_schema":{},"supported_sync_modes":["full_refresh","incremental"],"source_defined_cursor":true,"default_cursor_field":["pull_request_updated_at"],"source_defined_primary_key":[["id"]]},"sync_mode":"incremental","cursor_field":["pull_request_updated_at"],"destination_sync_mode":"append_dedup","primary_key":[["id"]]},{"stream":{"name":"github_source__github__tags","json_schema":{},"supported_sync_modes":["full_refresh"],"default_cursor_field":[],"source_defined_primary_key":[["repository"],["name"]]},"sync_mode":"full_refresh","cursor_field":[],"destination_sync_mode":"overwrite","primary_key":[["repository"],["name"]]},{"stream":{"name":"github_source__github__users","json_schema":{},"supported_sync_modes":["full_refresh"],"default_cursor_field":[],"source_defined_primary_key":[["id"]]},"sync_mode":"full_refresh","cursor_field":[],"destination_sync_mode":"overwrite","primary_key":[["id"]]}]}
2023-09-03 14:05:24 destination > Determined origin 'github_source' from stream prefixes
2023-09-03 14:05:24 destination > Using Assignees converter to convert github_source__github__assignees stream records
2023-09-03 14:05:25 destination > Using Branches converter to convert github_source__github__branches stream records
2023-09-03 14:05:25 destination > Using Commits converter to convert github_source__github__commits stream records
2023-09-03 14:05:25 destination > Using Organizations converter to convert github_source__github__organizations stream records
2023-09-03 14:05:25 destination > Using PullRequests converter to convert github_source__github__pull_requests stream records
2023-09-03 14:05:25 destination > Using Repositories converter to convert github_source__github__repositories stream records
2023-09-03 14:05:25 destination > Using ReviewComments converter to convert github_source__github__review_comments stream records
2023-09-03 14:05:25 destination > Using Reviews converter to convert github_source__github__reviews stream records
2023-09-03 14:05:25 destination > Using Tags converter to convert github_source__github__tags stream records
2023-09-03 14:05:25 destination > Using Users converter to convert github_source__github__users stream records
2023-09-03 14:05:25 destination > Using GraphQLClient for writer
2023-09-03 14:08:06 source > Syncing stream: assignees 
2023-09-03 14:08:08 source > Read 746 records from assignees stream
2023-09-03 14:08:08 source > Finished syncing assignees
2023-09-03 14:08:08 source > SourceGithub runtimes:
Syncing stream assignees 0:00:02.219388
2023-09-03 14:08:08 source > Syncing stream: branches 
2023-09-03 14:08:13 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 1000 (768 KB)
2023-09-03 14:08:30 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 2000 (1009 KB)
2023-09-03 14:08:51 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 3000 (1 MB)
2023-09-03 14:09:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 4000 (1 MB)
2023-09-03 14:09:28 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 5000 (1 MB)
2023-09-03 14:09:48 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 6000 (1 MB)
2023-09-03 14:10:08 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 7000 (2 MB)
2023-09-03 14:10:26 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 8000 (2 MB)
2023-09-03 14:10:45 INFO i.a.w.g.DefaultReplicationWorker(lambda$getReplicationRunnable$6):352 - Records read: 9000 (2 MB)
2023-09-03 14:10:51 source > Read 8585 records from branches stream
2023-09-03 14:10:51 source > Finished syncing branches
2023-09-03 14:10:51 source > SourceGithub runtimes:
Syncing stream assignees 0:00:02.219388
Syncing stream branches 0:02:42.904775
2023-09-03 14:10:51 source > Syncing stream: commits 
2023-09-03 14:10:52 source > Read 199 records from commits stream
2023-09-03 14:10:52 source > Finished syncing commits
2023-09-03 14:10:52 source > SourceGithub runtimes:
Syncing stream assignees 0:00:02.219388
Syncing stream branches 0:02:42.904775
Syncing stream commits 0:00:01.462835
2023-09-03 14:10:52 source > Syncing stream: organizations 
2023-09-03 14:10:53 source > Read 1 records from organizations stream
2023-09-03 14:10:53 source > Finished syncing organizations
2023-09-03 14:10:53 source > SourceGithub runtimes:
Syncing stream assignees 0:00:02.219388
Syncing stream branches 0:02:42.904775
Syncing stream commits 0:00:01.462835
Syncing stream organizations 0:00:00.288910
2023-09-03 14:10:53 source > Syncing stream: pull_requests 
2023-09-04 10:10:31 source > Retrying (Retry(total=2, connect=None, read=None, redirect=None, status=None)) after connection broken by 'ProtocolError('Connection aborted.', RemoteDisconnected('Remote end closed connection without response'))': /repos/Asana/codez/pulls?per_page=20&page=7630&state=all&sort=updated&direction=asc
2023-09-04 10:22:18 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):195 - Running sync worker cancellation...
2023-09-04 10:22:18 INFO i.a.w.g.DefaultReplicationWorker(cancel):473 - Cancelling replication worker...
2023-09-04 10:22:28 INFO i.a.w.g.DefaultReplicationWorker(cancel):481 - Cancelling destination...
2023-09-04 10:22:28 INFO i.a.w.i.DefaultAirbyteDestination(cancel):125 - Attempting to cancel destination process...
2023-09-04 10:22:28 INFO i.a.w.i.DefaultAirbyteDestination(cancel):130 - Destination process exists, cancelling...
2023-09-04 10:22:28 INFO i.a.w.g.DefaultReplicationWorker(run):182 - One of source or destination thread complete. Waiting on the other.
2023-09-04 10:22:28 INFO i.a.w.i.DefaultAirbyteDestination(cancel):132 - Cancelled destination process!
2023-09-04 10:22:28 INFO i.a.w.g.DefaultReplicationWorker(cancel):488 - Cancelling source...
2023-09-04 10:22:28 INFO i.a.w.i.DefaultAirbyteSource(cancel):146 - Attempting to cancel source process...
2023-09-04 10:22:28 INFO i.a.w.i.DefaultAirbyteSource(cancel):151 - Source process exists, cancelling...
2023-09-04 10:22:28 INFO i.a.w.g.DefaultReplicationWorker(run):184 - Source and destination threads complete.
2023-09-04 10:22:28 INFO i.a.w.i.DefaultAirbyteSource(cancel):153 - Cancelled source process!
2023-09-04 10:22:28 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):199 - Interrupting worker thread...
2023-09-04 10:22:28 INFO i.a.w.t.TemporalAttemptExecution(lambda$getCancellationChecker$3):202 - Cancelling completable future...
2023-09-04 10:22:28 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2023-09-04 10:22:28 WARN i.a.w.t.CancellationHandler$TemporalCancellationHandler(checkAndHandleCancellation):53 - Job either timed out or was cancelled.
2023-09-04 10:22:28 INFO i.a.w.t.TemporalAttemptExecution(get):132 - Stopping cancellation check scheduling...
2023-09-04 10:22:28 INFO i.a.w.t.TemporalUtils(withBackgroundHeartbeat):279 - Stopping temporal heartbeating...
2023-09-04 10:22:28 ERROR i.a.w.g.DefaultReplicationWorker(run):188 - Sync worker failed.
io.airbyte.workers.exception.WorkerException: Source process exit with code 143. This warning is normal if the job was cancelled.
	at io.airbyte.workers.internal.DefaultAirbyteSource.close(DefaultAirbyteSource.java:140) ~[io.airbyte-airbyte-workers-0.40.9.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:186) ~[io.airbyte-airbyte-workers-0.40.9.jar:?]
	at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:68) ~[io.airbyte-airbyte-workers-0.40.9.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:159) ~[io.airbyte-airbyte-workers-0.40.9.jar:?]
	at java.lang.Thread.run(Thread.java:833) ~[?:?]
	Suppressed: java.io.IOException: Stream closed
		at java.lang.ProcessBuilder$NullOutputStream.write(ProcessBuilder.java:445) ~[?:?]
		at java.io.OutputStream.write(OutputStream.java:162) ~[?:?]
		at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:81) ~[?:?]
		at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:142) ~[?:?]
		at sun.nio.cs.StreamEncoder.implFlush(StreamEncoder.java:320) ~[?:?]
		at sun.nio.cs.StreamEncoder.flush(StreamEncoder.java:160) ~[?:?]
		at java.io.OutputStreamWriter.flush(OutputStreamWriter.java:248) ~[?:?]
		at java.io.BufferedWriter.flush(BufferedWriter.java:257) ~[?:?]
		at io.airbyte.workers.internal.DefaultAirbyteDestination.notifyEndOfInput(DefaultAirbyteDestination.java:98) ~[io.airbyte-airbyte-workers-0.40.9.jar:?]
		at io.airbyte.workers.internal.DefaultAirbyteDestination.close(DefaultAirbyteDestination.java:111) ~[io.airbyte-airbyte-workers-0.40.9.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:145) ~[io.airbyte-airbyte-workers-0.40.9.jar:?]
		at io.airbyte.workers.general.DefaultReplicationWorker.run(DefaultReplicationWorker.java:68) ~[io.airbyte-airbyte-workers-0.40.9.jar:?]
		at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:159) ~[io.airbyte-airbyte-workers-0.40.9.jar:?]
		at java.lang.Thread.run(Thread.java:833) ~[?:?]
2023-09-04 10:22:28 INFO i.a.w.g.DefaultReplicationWorker(run):279 - Source output at least one state message
2023-09-04 10:22:28 WARN i.a.w.g.DefaultReplicationWorker(run):289 - State capture: No new state, falling back on input state: io.airbyte.config.State@135928f4[state={}]
2023-09-04 10:22:28 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=c6802126-6c3f-38c3-b7ce-a93e526c3905, activityType=Replicate, attempt=1
java.lang.RuntimeException: java.util.concurrent.CancellationException
	at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:277) ~[io.airbyte-airbyte-workers-0.40.9.jar:?]
	at io.airbyte.workers.temporal.sync.ReplicationActivityImpl.replicate(ReplicationActivityImpl.java:103) ~[io.airbyte-airbyte-workers-0.40.9.jar:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?]
	at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
	at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityInboundCallsInterceptor.execute(POJOActivityTaskHandler.java:214) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler$POJOActivityImplementation.execute(POJOActivityTaskHandler.java:180) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.activity.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:120) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:204) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:164) ~[temporal-sdk-1.8.1.jar:?]
	at io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:93) ~[temporal-sdk-1.8.1.jar:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
	at java.lang.Thread.run(Thread.java:833) ~[?:?]
Caused by: java.util.concurrent.CancellationException
	at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2478) ~[?:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$3(TemporalAttemptExecution.java:205) ~[io.airbyte-airbyte-workers-0.40.9.jar:?]
	at io.airbyte.workers.temporal.CancellationHandler$TemporalCancellationHandler.checkAndHandleCancellation(CancellationHandler.java:52) ~[io.airbyte-airbyte-workers-0.40.9.jar:?]
	at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getCancellationChecker$4(TemporalAttemptExecution.java:208) ~[io.airbyte-airbyte-workers-0.40.9.jar:?]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305) ~[?:?]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305) ~[?:?]
	... 3 more
2023-09-04 10:22:28 INFO i.a.w.g.DefaultReplicationWorker(run):300 - sync summary: {
  "status" : "cancelled",
  "recordsSynced" : 9531,
  "bytesSynced" : 3938848,
  "startTime" : 1693749920580,
  "endTime" : 1693822948465,
  "totalStats" : {
    "recordsEmitted" : 9531,
    "bytesEmitted" : 3938848,
    "sourceStateMessagesEmitted" : 1,
    "destinationStateMessagesEmitted" : 0,
    "recordsCommitted" : 0,
    "meanSecondsBeforeSourceStateMessageEmitted" : 166,
    "maxSecondsBeforeSourceStateMessageEmitted" : 166,
    "maxSecondsBetweenStateMessageEmittedandCommitted" : 0,
    "meanSecondsBetweenStateMessageEmittedandCommitted" : 0
  },
  "streamStats" : [ {
    "streamName" : "github_source__github__commits",
    "stats" : {
      "recordsEmitted" : 199,
      "bytesEmitted" : 1089905
    }
  }, {
    "streamName" : "github_source__github__organizations",
    "stats" : {
      "recordsEmitted" : 1,
      "bytesEmitted" : 1746
    }
  }, {
    "streamName" : "github_source__github__branches",
    "stats" : {
      "recordsEmitted" : 8585,
      "bytesEmitted" : 2122309
    }
  }, {
    "streamName" : "github_source__github__assignees",
    "stats" : {
      "recordsEmitted" : 746,
      "bytesEmitted" : 724888
    }
  } ]
}
2023-09-04 10:22:28 INFO i.a.w.g.DefaultReplicationWorker(run):301 - failures: [ ]
2023-09-04 10:22:28 INFO i.a.c.i.LineGobbler(voidCall):114 - 
2023-09-04 10:22:28 INFO i.a.c.i.LineGobbler(voidCall):114 - ----- END REPLICATION -----
2023-09-04 10:22:28 INFO i.a.c.i.LineGobbler(voidCall):114 -