Skip to content

Commit 2333b84

Browse files
committed
Fix exception in requeue code
File "/Users/prashanthpai/mysrc/sharq-testing/requeue_script.py", line 8, in <module> response = sq.requeue() File "/Users/prashanthpai/mysrc/sharq-testing/env/lib/python3.9/site-packages/sharq/queue.py", line 332, in requeue self.finish( File "/Users/prashanthpai/mysrc/sharq-testing/env/lib/python3.9/site-packages/sharq/queue.py", line 241, in finish raise BadArgumentException('`queue_type` has an invalid value.') sharq.exceptions.BadArgumentException: `queue_type` has an invalid value. Signed-off-by: Prashanth Pai <prashanth.pai@plivo.com>
1 parent 4abb554 commit 2333b84

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

sharq/queue.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -315,6 +315,9 @@ def requeue(self):
315315
'%s:active:queue_type' % self._key_prefix)
316316
for queue_type in active_queue_type_list:
317317
# requeue all expired jobs in all queue types.
318+
319+
queue_type = queue_type.decode('utf-8')
320+
318321
keys = [
319322
self._key_prefix,
320323
queue_type

0 commit comments

Comments
 (0)