Add enqueue_at_from_string

Author: c-oreills

pyres/__init__.py

@@ -281,11 +281,14 @@ def close(self):
 
     def enqueue_at(self, datetime, klass, *args, **kwargs):
         class_name = '%s.%s' % (klass.__module__, klass.__name__)
+        self.enqueue_at_from_string(datetime, class_name, klass.queue, *args, **kwargs)
+
+    def enqueue_at_from_string(self, datetime, klass_as_string, queue, *args, **kwargs):
         logging.info("scheduled '%s' job on queue %s for execution at %s" %
-                     (class_name, klass.queue, datetime))
+                     (klass_as_string, queue, datetime))
         if args:
             logging.debug("job arguments are: %s" % str(args))
-        payload = {'class':class_name, 'queue': klass.queue, 'args':args}
+        payload = {'class': klass_as_string, 'queue': queue, 'args': args}
         if 'first_attempt' in kwargs:
             payload['first_attempt'] = kwargs['first_attempt']
         self.delayed_push(datetime, payload)