From e524dfda6d50755ab28b40d13fa205da4ce8a72a Mon Sep 17 00:00:00 2001 From: Simon Larsen Date: Fri, 7 Nov 2025 20:22:51 +0000 Subject: [PATCH] chore(fluent-ingest): normalize formatting in FluentLogsIngestService and Index.ts --- OpenTelemetryIngest/Index.ts | 1 - .../Services/FluentLogsIngestService.ts | 15 ++++++--------- 2 files changed, 6 insertions(+), 10 deletions(-) diff --git a/OpenTelemetryIngest/Index.ts b/OpenTelemetryIngest/Index.ts index 1ea391ea99..da4b7989af 100644 --- a/OpenTelemetryIngest/Index.ts +++ b/OpenTelemetryIngest/Index.ts @@ -71,7 +71,6 @@ const init: PromiseVoidFunction = async (): Promise => { await Realtime.init(); // add default routes await App.addDefaultRoutes(); - } catch (err) { logger.error("App Init Failed:"); logger.error(err); diff --git a/OpenTelemetryIngest/Services/FluentLogsIngestService.ts b/OpenTelemetryIngest/Services/FluentLogsIngestService.ts index f0b0c40e39..8ead5131d9 100644 --- a/OpenTelemetryIngest/Services/FluentLogsIngestService.ts +++ b/OpenTelemetryIngest/Services/FluentLogsIngestService.ts @@ -105,12 +105,11 @@ export default class FluentLogsIngestService extends OtelIngestBaseService { dataRententionInDays: metadata.dataRententionInDays, } satisfies TelemetryServiceMetadata; - const baseAttributes: Dictionary< - AttributeType | Array - > = TelemetryUtil.getAttributesForServiceIdAndServiceName({ - serviceId: serviceMetadata.serviceId, - serviceName, - }); + const baseAttributes: Dictionary> = + TelemetryUtil.getAttributesForServiceIdAndServiceName({ + serviceId: serviceMetadata.serviceId, + serviceName, + }); const baseAttributeKeys: Array = TelemetryUtil.getAttributeKeys(baseAttributes); @@ -151,9 +150,7 @@ export default class FluentLogsIngestService extends OtelIngestBaseService { dbLogs.push(logRow); processed++; - if ( - dbLogs.length >= OPEN_TELEMETRY_INGEST_LOG_FLUSH_BATCH_SIZE - ) { + if (dbLogs.length >= OPEN_TELEMETRY_INGEST_LOG_FLUSH_BATCH_SIZE) { await this.flushLogsBuffer(dbLogs); } } catch (processingError) {