We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d4b7a25 commit 76b8f07Copy full SHA for 76b8f07
pkg/nodes/queue.go
@@ -15,7 +15,7 @@ var (
15
taskQueue = make(chan config.Peer) // taskQueue channel for pending tasks (peers to process later).
16
MaxRetryCount = 5 // MaxRetryCount number of retries per node.
17
TickerTime = 5 * time.Second // TickerTime time specified to make a signal.
18
- timeoutDurationProcessQueue = 10 * time.Second // timeoutDurationProcessQueue time specified to make a signal.
+ timeoutDurationProcessQueue = 60 * time.Second // timeoutDurationProcessQueue time specified to make a signal.
19
)
20
21
// ProcessTaskQueue processes the pending tasks in the queue the time specified in the const TickerTime.
0 commit comments