Skip to content

Commit 07b267e

Browse files
authored
fix: disable queueAndWait flag for now (#157)
2 parents 1a7f5d5 + 4ff5542 commit 07b267e

File tree

1 file changed

+3
-11
lines changed

1 file changed

+3
-11
lines changed

pkg/rpcServer/rewardsHandlers.go

Lines changed: 3 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -25,17 +25,9 @@ func (rpc *RpcServer) GenerateRewards(ctx context.Context, req *sidecarV1.Genera
2525
CalculationType: rewardsCalculatorQueue.RewardsCalculationType_CalculateRewards,
2626
CutoffDate: cutoffDate,
2727
}
28-
if req.GetWaitForComplete() {
29-
data, qErr := rpc.rewardsQueue.EnqueueAndWait(ctx, msg)
30-
cutoffDate = data.CutoffDate
31-
err = qErr
32-
} else {
33-
rpc.rewardsQueue.Enqueue(&rewardsCalculatorQueue.RewardsCalculationMessage{
34-
Data: msg,
35-
ResponseChan: make(chan *rewardsCalculatorQueue.RewardsCalculatorResponse),
36-
})
37-
queued = true
38-
}
28+
data, qErr := rpc.rewardsQueue.EnqueueAndWait(ctx, msg)
29+
cutoffDate = data.CutoffDate
30+
err = qErr
3931

4032
if err != nil {
4133
if errors.Is(err, &rewards.ErrRewardsCalculationInProgress{}) {

0 commit comments

Comments
 (0)