Skip to content

Commit b56326f

Browse files
Updated to adhere new Redis schema
1 parent 3e72b79 commit b56326f

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

internal/scheduler/fcfs/fcfs.go

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,13 @@ func (f *FCFSScheduler) Run(ctx context.Context) error {
9292

9393
/* we assume the transaction has been processed -> updated Redis */
9494
transaction.Status = types.StatusSuccess
95-
f.curSessionManager.SaveTransactionResultsRedis(curSession, transaction, "txresults")
95+
96+
/* store the result of processed transaction into Redis */
97+
f.curSessionManager.SaveTransactionRedisList(curSession, transaction, "txresults")
98+
99+
/* remove the transaction as pending from Redis */
100+
f.curSessionManager.RemovePendingTransaction(curSession, transaction.ID)
101+
96102
}(curSession, transaction)
97103
}
98104
}

0 commit comments

Comments
 (0)