Skip to content

Commit 47f5200

Browse files
author
Itay Bleier
committed
Removed unicode code references and bumped up version
1 parent 80676ca commit 47f5200

File tree

3 files changed

+4
-5
lines changed

3 files changed

+4
-5
lines changed

eb_sqs/worker/worker.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -75,14 +75,13 @@ def execute(self, msg):
7575

7676
def delay(self, group_id, queue_name, func, args, kwargs, max_retries, use_pickle, delay, execute_inline):
7777
# type: (unicode, unicode, Any, tuple, dict, int, bool, int, bool) -> Any
78-
id = unicode(uuid.uuid4())
79-
worker_task = WorkerTask(id, group_id, queue_name, func, args, kwargs, max_retries, 0, None, use_pickle)
78+
worker_task = WorkerTask(str(uuid.uuid4()), group_id, queue_name, func, args, kwargs, max_retries, 0, None, use_pickle)
8079
return self._enqueue_task(worker_task, delay, execute_inline, False, True)
8180

8281
def retry(self, worker_task, delay, execute_inline, count_retries):
8382
# type: (WorkerTask, int, bool, bool) -> Any
8483
worker_task = worker_task.copy(settings.FORCE_SERIALIZATION)
85-
worker_task.retry_id = unicode(uuid.uuid4())
84+
worker_task.retry_id = str(uuid.uuid4())
8685
return self._enqueue_task(worker_task, delay, execute_inline, True, count_retries)
8786

8887
def _enqueue_task(self, worker_task, delay, execute_inline, is_retry, count_retries):

eb_sqs/worker/worker_task.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212

1313
class WorkerTask(object):
1414
def __init__(self, id, group_id, queue, func, args, kwargs, max_retries, retry, retry_id, use_pickle):
15-
# type: (unicode, unicode, unicode, Any, tuple, dict, int, int, unicode, bool) -> None
15+
# type: (str, unicode, unicode, Any, tuple, dict, int, int, unicode, bool) -> None
1616
super(WorkerTask, self).__init__()
1717
self.id = id
1818
self.group_id = group_id

setup.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66

77
setup(
88
name='django-eb-sqs',
9-
version='0.97',
9+
version='0.98',
1010
package_dir={'eb_sqs': 'eb_sqs'},
1111
include_package_data=True,
1212
packages=find_packages(),

0 commit comments

Comments
 (0)