Skip to content

Commit b568ba1

Browse files
Fix PollScaleReportHandle
1 parent 59e4793 commit b568ba1

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

temporal-sdk/src/main/java/io/temporal/internal/worker/PollScaleReportHandle.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,9 @@ public synchronized void report(T task, Throwable e) {
5151
if (task != null) {
5252
ingestedThisPeriod += 1;
5353
}
54-
ScalingTask.ScalingDecision scalingDecision = task.getScalingDecision();
55-
if (scalingDecision != null) {
54+
55+
if (task != null && task.getScalingDecision() != null) {
56+
ScalingTask.ScalingDecision scalingDecision = task.getScalingDecision();
5657
everSawScalingDecision = true;
5758
int deltaSuggestion = scalingDecision.getPollRequestDeltaSuggestion();
5859
logger.info("Poller scaling report. Delta suggestion: {}.", deltaSuggestion);

0 commit comments

Comments
 (0)