File tree Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Expand file tree Collapse file tree 2 files changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -66,7 +66,7 @@ def next_item(self, timestamp):
66
66
def handle_delayed_items (self ):
67
67
for timestamp in self .next_timestamp ():
68
68
_setproctitle ('Handling timestamp %s' % timestamp )
69
- logger .info ('handling timestamp: %s' % timestamp )
69
+ logger .debug ('handling timestamp: %s' % timestamp )
70
70
for item in self .next_item (timestamp ):
71
71
logger .debug ('queueing item %s' % item )
72
72
klass = item ['class' ]
Original file line number Diff line number Diff line change @@ -130,6 +130,7 @@ def work(self, interval=5):
130
130
131
131
"""
132
132
self ._setproctitle ("Starting" )
133
+ logger .info ("starting" )
133
134
self .startup ()
134
135
135
136
while True :
@@ -260,7 +261,7 @@ def process(self, job=None):
260
261
self ._handle_job_exception (job )
261
262
262
263
if not job_failed :
263
- logger .info ('completed job' )
264
+ logger .debug ('completed job' )
264
265
logger .debug ('job details: %s' % job )
265
266
finally :
266
267
self .done_working (job )
@@ -291,7 +292,7 @@ def working_on(self, job):
291
292
logger .debug (self .resq .redis ["resque:worker:%s" % str (self )])
292
293
293
294
def done_working (self , job ):
294
- logger .info ('done working on %s' , job )
295
+ logger .debug ('done working on %s' , job )
295
296
self .processed ()
296
297
self .resq .redis .delete ("resque:worker:%s" % str (self ))
297
298
You can’t perform that action at this time.
0 commit comments