perfectqueue 0.8.21 → 0.8.22
This diff represents the content of publicly available package versions that have been released to one of the supported registries. The information contained in this diff is provided for informational purposes only and reflects changes between package versions as they appear in their respective public registries.
- data/ChangeLog +5 -0
- data/lib/perfectqueue/backend/rdb_compat.rb +3 -4
- data/lib/perfectqueue/version.rb +1 -1
- metadata +2 -2
data/ChangeLog
CHANGED
|
@@ -262,13 +262,12 @@ SQL
|
|
|
262
262
|
row = @db.fetch("SELECT id, timeout, created_at FROM `#{@table}` WHERE id=? LIMIT 1", key).first
|
|
263
263
|
if row == nil
|
|
264
264
|
raise PreemptedError, "task key=#{key} does not exist or preempted."
|
|
265
|
+
elsif row[:created_at] == nil
|
|
266
|
+
raise PreemptedError, "task key=#{key} preempted."
|
|
265
267
|
elsif row[:created_at] <= 0
|
|
266
268
|
raise CancelRequestedError, "task key=#{key} is cancel requested."
|
|
267
|
-
|
|
269
|
+
else # row[:timeout] == next_timeout
|
|
268
270
|
# ok
|
|
269
|
-
else
|
|
270
|
-
# row[:created_at] == null
|
|
271
|
-
raise PreemptedError, "task key=#{key} preempted."
|
|
272
271
|
end
|
|
273
272
|
end
|
|
274
273
|
}
|
data/lib/perfectqueue/version.rb
CHANGED
metadata
CHANGED
|
@@ -1,7 +1,7 @@
|
|
|
1
1
|
--- !ruby/object:Gem::Specification
|
|
2
2
|
name: perfectqueue
|
|
3
3
|
version: !ruby/object:Gem::Version
|
|
4
|
-
version: 0.8.
|
|
4
|
+
version: 0.8.22
|
|
5
5
|
prerelease:
|
|
6
6
|
platform: ruby
|
|
7
7
|
authors:
|
|
@@ -9,7 +9,7 @@ authors:
|
|
|
9
9
|
autorequire:
|
|
10
10
|
bindir: bin
|
|
11
11
|
cert_chain: []
|
|
12
|
-
date: 2012-10-
|
|
12
|
+
date: 2012-10-22 00:00:00.000000000 Z
|
|
13
13
|
dependencies:
|
|
14
14
|
- !ruby/object:Gem::Dependency
|
|
15
15
|
name: sequel
|