We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3dee344 commit 1d82fa9Copy full SHA for 1d82fa9
lib/oxidized/worker.rb
@@ -23,11 +23,11 @@ def work
23
"#{@jobs_done} of #{@nodes.size}"
24
# ask for next node in queue non destructive way
25
nextnode = @nodes.first
26
- break if Oxidized.config.interval.zero? and not nextnode.nexted?
+ break if Oxidized.config.interval.zero? && !nextnode.nexted?
27
+
28
nextnode.nexted = false
- unless nextnode.last.nil?
29
- break if nextnode.last.end + Oxidized.config.interval > Time.now.utc
30
- end
+ break if !nextnode.last.nil? && (nextnode.last.end + Oxidized.config.interval > Time.now.utc)
31
# shift nodes and get the next node
32
node = @nodes.get
33
node.running? ? next : node.running = true
0 commit comments