From db9bb9e05cc6f7fceefebfe3580f03f76858a9e4 Mon Sep 17 00:00:00 2001 From: Gaston Yelmini Date: Thu, 19 Dec 2024 15:36:30 -0300 Subject: [PATCH 1/2] [NO-TICKET] remove batch logs --- .../src/synchronization/index.ts | 25 ------------------- 1 file changed, 25 deletions(-) diff --git a/packages/integration-sdk-runtime/src/synchronization/index.ts b/packages/integration-sdk-runtime/src/synchronization/index.ts index 901ca199e..75f77ee5b 100644 --- a/packages/integration-sdk-runtime/src/synchronization/index.ts +++ b/packages/integration-sdk-runtime/src/synchronization/index.ts @@ -488,7 +488,6 @@ export async function uploadDataChunk< }, 'Uploading data...', ); - const startTime = Date.now(); try { await apiClient.post( `/persister/synchronization/jobs/${jobId}/${type as string}`, @@ -507,30 +506,6 @@ export async function uploadDataChunk< cleanAxiosError(err); throw err; } - - const duration = Date.now() - startTime; - if (duration >= 10_000) { - logger.info( - { - uploadCorrelationId, - uploadType: type, - attemptNum: ctx.attemptNum, - batchSize: batch.length, - batchSizeInBytes: getSizeOfObject(batch), - uploadDuration: duration, - }, - 'Finished uploading big batch', - ); - } - logger.debug( - { - uploadCorrelationId, - uploadType: type, - attemptNum: ctx.attemptNum, - batchSize: batch.length, - }, - 'Finished uploading batch', - ); }, { maxAttempts: 5, From ee5d5bdda8d5df3e87d482c88849227ecdb5aea4 Mon Sep 17 00:00:00 2001 From: Gaston Yelmini Date: Thu, 19 Dec 2024 15:37:40 -0300 Subject: [PATCH 2/2] Remove unused import --- packages/integration-sdk-runtime/src/synchronization/index.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/integration-sdk-runtime/src/synchronization/index.ts b/packages/integration-sdk-runtime/src/synchronization/index.ts index 75f77ee5b..aa1e8378e 100644 --- a/packages/integration-sdk-runtime/src/synchronization/index.ts +++ b/packages/integration-sdk-runtime/src/synchronization/index.ts @@ -26,7 +26,7 @@ import { randomUUID as uuid } from 'crypto'; import { createEventPublishingQueue } from './events'; import { iterateParsedGraphFiles } from '..'; import { shrinkBatchRawData } from './shrinkBatchRawData'; -import { batchGraphObjectsBySizeInBytes, getSizeOfObject } from './batchBySize'; +import { batchGraphObjectsBySizeInBytes } from './batchBySize'; import type { Alpha } from '@lifeomic/alpha'; export { synchronizationApiError };