Skip to content

Commit 926bd28

Browse files
committed
Use enqueue from string as a base for enqueue
1 parent 5c8cd4c commit 926bd28

File tree

1 file changed

+2
-7
lines changed

1 file changed

+2
-7
lines changed

pyres/__init__.py

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -212,17 +212,12 @@ def enqueue(self, klass, *args):
212212
queue = getattr(klass,'queue', None)
213213
if queue:
214214
class_name = '%s.%s' % (klass.__module__, klass.__name__)
215-
self.push(queue, {'class':class_name,'args':args})
216-
logging.info("enqueued '%s' job on queue %s" % (class_name, queue))
217-
if args:
218-
logging.debug("job arguments: %s" % str(args))
219-
else:
220-
logging.debug("no arguments passed in.")
215+
self.enqueue_from_string(class_name, queue, *args)
221216
else:
222217
logging.warning("unable to enqueue job with class %s" % str(klass))
223218

224219
def enqueue_from_string(self, klass_as_string, queue, *args, **kwargs):
225-
payload = {'class':klass_as_string, 'queue': queue, 'args':args}
220+
payload = {'class':klass_as_string, 'args':args}
226221
if 'first_attempt' in kwargs:
227222
payload['first_attempt'] = kwargs['first_attempt']
228223
self.push(queue, payload)

0 commit comments

Comments
 (0)