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 59e68fa commit 06562f0Copy full SHA for 06562f0
internal/scheduler/fcfs/fcfs.go
@@ -3,6 +3,7 @@ package fcfs
3
import (
4
"context"
5
"runtime"
6
+ "time"
7
8
"go.uber.org/zap"
9
@@ -92,9 +93,12 @@ func (f *FCFSScheduler) Run(ctx context.Context) error {
92
93
94
/* we assume the transaction has been processed -> updated Redis */
95
transaction.Status = types.StatusSuccess
96
+
97
+ /* update duration of transaction execution */
98
+ elapsed := time.Since(transaction.Timestamp)
99
+ transaction.DurationMs = elapsed.Milliseconds()
100
101
/* this whole code snippet should be called "Update Session State after transaction execution" */
-
102
/* update the session's completed/failed count */
103
curSession.Mutex.Lock()
104
if transaction.ExecStatus {
0 commit comments