@@ -213,7 +213,7 @@ def enqueue(self, klass, *args):
213213 if queue :
214214 class_name = '%s.%s' % (klass .__module__ , klass .__name__ )
215215 self .push (queue , {'class' :class_name ,'args' :args })
216- logging .info ("enqueued '%s' job" % class_name )
216+ logging .info ("enqueued '%s' job on queue %s " % ( class_name , queue ) )
217217 if args :
218218 logging .debug ("job arguments: %s" % str (args ))
219219 else :
@@ -226,7 +226,7 @@ def enqueue_from_string(self, klass_as_string, queue, *args, **kwargs):
226226 if 'first_attempt' in kwargs :
227227 payload ['first_attempt' ] = kwargs ['first_attempt' ]
228228 self .push (queue , payload )
229- logging .info ("enqueued '%s' job" % klass_as_string )
229+ logging .info ("enqueued '%s' job on queue %s " % ( klass_as_string , queue ) )
230230 if args :
231231 logging .debug ("job arguments: %s" % str (args ))
232232 else :
@@ -286,8 +286,8 @@ def close(self):
286286
287287 def enqueue_at (self , datetime , klass , * args , ** kwargs ):
288288 class_name = '%s.%s' % (klass .__module__ , klass .__name__ )
289- logging .info ("enqueued '%s' job for execution at %s" % ( class_name ,
290- datetime ))
289+ logging .info ("scheduled '%s' job on queue %s for execution at %s" %
290+ ( class_name , klass . queue , datetime ))
291291 if args :
292292 logging .debug ("job arguments are: %s" % str (args ))
293293 payload = {'class' :class_name , 'queue' : klass .queue , 'args' :args }
0 commit comments