18
18
from .mixins import RedisCleanupMixin
19
19
20
20
21
- class ReliableRedisDeduplicationTests (RedisCleanupMixin , unittest .TestCase ):
21
+ class ReliableRedisTests (RedisCleanupMixin , unittest .TestCase ):
22
22
longMessage = True
23
23
prefix = settings .LIGHTWEIGHT_QUEUE_REDIS_PREFIX
24
24
@@ -60,19 +60,19 @@ def setUp(self) -> None:
60
60
self .backend = ReliableRedisBackend ()
61
61
self .client = self .backend .client
62
62
63
- super (ReliableRedisDeduplicationTests , self ).setUp ()
63
+ super (ReliableRedisTests , self ).setUp ()
64
64
65
65
self .start_time = datetime .datetime .utcnow ()
66
66
67
- def test_empty_queue (self ):
67
+ def test_deduplicate_empty_queue (self ):
68
68
result = self .backend .deduplicate ('empty-queue' )
69
69
self .assertEqual (
70
70
(0 , 0 ),
71
71
result ,
72
72
"Should do nothing when queue empty" ,
73
73
)
74
74
75
- def test_single_entry_in_queue (self ):
75
+ def test_deduplicate_single_entry_in_queue (self ):
76
76
QUEUE = 'single-job-queue'
77
77
78
78
self .enqueue_job (QUEUE )
@@ -96,7 +96,7 @@ def test_single_entry_in_queue(self):
96
96
"Should still be a single entry in the queue" ,
97
97
)
98
98
99
- def test_unique_entries_in_queue (self ):
99
+ def test_deduplicate_unique_entries_in_queue (self ):
100
100
QUEUE = 'unique-jobs-queue'
101
101
102
102
self .enqueue_job (QUEUE , args = ('args1' ,))
@@ -121,7 +121,7 @@ def test_unique_entries_in_queue(self):
121
121
"Should still be a single entry in the queue" ,
122
122
)
123
123
124
- def test_duplicate_entries_in_queue (self ):
124
+ def test_deduplicate_duplicate_entries_in_queue (self ):
125
125
QUEUE = 'duplicate-jobs-queue'
126
126
127
127
self .enqueue_job (QUEUE )
@@ -146,7 +146,7 @@ def test_duplicate_entries_in_queue(self):
146
146
"Should still be a single entry in the queue" ,
147
147
)
148
148
149
- def test_preserves_order_with_fixed_timestamps (self ):
149
+ def test_deduplicate_preserves_order_with_fixed_timestamps (self ):
150
150
QUEUE = 'job-queue'
151
151
WORKER_NUMBER = 0
152
152
@@ -201,7 +201,7 @@ def test_preserves_order_with_fixed_timestamps(self):
201
201
"Third job dequeued should be the third job enqueued" ,
202
202
)
203
203
204
- def test_preserves_order_with_unique_timestamps (self ):
204
+ def test_deduplicate_preserves_order_with_unique_timestamps (self ):
205
205
QUEUE = 'job-queue'
206
206
WORKER_NUMBER = 0
207
207
0 commit comments