github/oneuptime
1
1
Fork 0
mirror of https://github.com/OneUptime/oneuptime.git synced 2026-04-06 00:32:12 +02:00
Code Issues 193 Packages Projects Releases Wiki Activity

chore(fluent-ingest): normalize formatting in FluentLogsIngestService and Index.ts

Browse Source
This commit is contained in:
Simon Larsen
2025-11-07 20:22:51 +00:00
parent 30b6353714
commit e524dfda6d
2 changed files with 6 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
OpenTelemetryIngest/Index.ts
View File

@@ -71,7 +71,6 @@ const init: PromiseVoidFunction = async (): Promise<void> => {
await Realtime.init();
// add default routes
await App.addDefaultRoutes();
} catch (err) {
logger.error("App Init Failed:");
logger.error(err);

15
OpenTelemetryIngest/Services/FluentLogsIngestService.ts
View File

@@ -105,12 +105,11 @@ export default class FluentLogsIngestService extends OtelIngestBaseService {
dataRententionInDays: metadata.dataRententionInDays,
} satisfies TelemetryServiceMetadata;
const baseAttributes: Dictionary<
AttributeType | Array<AttributeType>
> = TelemetryUtil.getAttributesForServiceIdAndServiceName({
serviceId: serviceMetadata.serviceId,
serviceName,
});
const baseAttributes: Dictionary<AttributeType | Array<AttributeType>> =
TelemetryUtil.getAttributesForServiceIdAndServiceName({
serviceId: serviceMetadata.serviceId,
serviceName,
});
const baseAttributeKeys: Array<string> =
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) {