Skip to content

Commit 8782de3

Browse files
Make nexus header check case-insensitive (#2335)
1 parent 7245bf8 commit 8782de3

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

temporal-sdk/src/main/java/io/temporal/internal/nexus/NexusTaskHandlerImpl.java

+3-1
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,9 @@ public Result handle(NexusTask task, Scope metricsScope) throws TimeoutException
9696
ScheduledFuture<?> timeoutTask = null;
9797
AtomicBoolean timedOut = new AtomicBoolean(false);
9898
try {
99-
String timeoutString = headers.get(Header.REQUEST_TIMEOUT);
99+
// Parse request timeout, use the context headers to get the timeout
100+
// since they are case-insensitive.
101+
String timeoutString = ctx.getHeaders().get(Header.REQUEST_TIMEOUT);
100102
if (timeoutString != null) {
101103
try {
102104
Duration timeout = NexusUtil.parseRequestTimeout(timeoutString);

0 commit comments

Comments
 (0)