Skip to content

Commit 9ae63b9

Browse files
committed
fix: LambdaUtils forceFlush flushes Logs also
1 parent 00cd5e4 commit 9ae63b9

File tree

1 file changed

+3
-1
lines changed
  • instrumentation/aws-lambda/aws-lambda-core-1.0/library/src/main/java/io/opentelemetry/instrumentation/awslambdacore/v1_0

1 file changed

+3
-1
lines changed

instrumentation/aws-lambda/aws-lambda-core-1.0/library/src/main/java/io/opentelemetry/instrumentation/awslambdacore/v1_0/LambdaUtils.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,9 @@ final class LambdaUtils {
1515
static void forceFlush(OpenTelemetrySdk openTelemetrySdk, long flushTimeout, TimeUnit unit) {
1616
CompletableResultCode traceFlush = openTelemetrySdk.getSdkTracerProvider().forceFlush();
1717
CompletableResultCode metricsFlush = openTelemetrySdk.getSdkMeterProvider().forceFlush();
18-
CompletableResultCode.ofAll(Arrays.asList(traceFlush, metricsFlush)).join(flushTimeout, unit);
18+
CompletableResultCode logsFlush = openTelemetrySdk.getSdkLoggerProvider().forceFlush();
19+
CompletableResultCode.ofAll(Arrays.asList(traceFlush, metricsFlush, logsFlush))
20+
.join(flushTimeout, unit);
1921
}
2022

2123
private LambdaUtils() {}

0 commit comments

Comments
 (0)