diff --git a/grpc-client-utils/src/main/java/org/hypertrace/core/grpcutils/client/TimeoutVerifyingClientInterceptor.java b/grpc-client-utils/src/main/java/org/hypertrace/core/grpcutils/client/TimeoutVerifyingClientInterceptor.java index f971bbc..67cbeec 100644 --- a/grpc-client-utils/src/main/java/org/hypertrace/core/grpcutils/client/TimeoutVerifyingClientInterceptor.java +++ b/grpc-client-utils/src/main/java/org/hypertrace/core/grpcutils/client/TimeoutVerifyingClientInterceptor.java @@ -6,6 +6,7 @@ import io.grpc.Channel; import io.grpc.ClientCall; import io.grpc.ClientInterceptor; +import io.grpc.Context; import io.grpc.MethodDescriptor; import lombok.extern.slf4j.Slf4j; @@ -15,7 +16,7 @@ public class TimeoutVerifyingClientInterceptor implements ClientInterceptor { @Override public ClientCall interceptCall( MethodDescriptor methodDescriptor, CallOptions callOptions, Channel channel) { - if (isNull(callOptions.getDeadline())) { + if (isNull(callOptions.getDeadline()) && isNull(Context.current().getDeadline())) { log.warn("Missing deadline for call to method {}", methodDescriptor.getFullMethodName()); }