We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4631b16 commit a68f201Copy full SHA for a68f201
temporal-sdk/src/main/java/io/temporal/internal/worker/AsyncWorkflowPollTask.java
@@ -154,10 +154,9 @@ public CompletableFuture<WorkflowTask> poll(SlotPermit permit)
154
pollerMetricScope
155
.counter(MetricsType.WORKFLOW_TASK_QUEUE_POLL_SUCCEED_COUNTER)
156
.inc(1);
157
- Timestamp startedTime = ProtobufTimeUtils.getCurrentProtoTime();
158
159
.timer(MetricsType.WORKFLOW_TASK_SCHEDULE_TO_START_LATENCY)
160
- .record(ProtobufTimeUtils.toM3Duration(startedTime, r.getScheduledTime()));
+ .record(ProtobufTimeUtils.toM3Duration(r.getStartedTime(), r.getScheduledTime()));
161
return new WorkflowTask(r, (reason) -> slotSupplier.releaseSlot(reason, permit));
162
})
163
.whenComplete(
0 commit comments