Skip to content

Commit

Permalink
Remove left-over print statements
Browse files Browse the repository at this point in the history
  • Loading branch information
ask committed Jan 29, 2011
1 parent b05a6ea commit a0c6c70
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 8 deletions.
3 changes: 0 additions & 3 deletions celery/apps/worker.py
Original file line number Diff line number Diff line change
Expand Up @@ -295,7 +295,6 @@ def _stop(signum, frame):
if multiprocessing:
process_name = multiprocessing.current_process().name
if not process_name or process_name == "MainProcess":
print("TERMINATING")
worker.logger.warn("celeryd: Cold shutdown (%s)" % (
process_name))
worker.terminate(in_sighandler=True)
Expand All @@ -310,9 +309,7 @@ def _stop(signum, frame):
process_name = None
if multiprocessing:
process_name = multiprocessing.current_process().name
print("SHOULD STOP? %r" % (process_name, ))
if not process_name or process_name == "MainProcess":
print("STOPPING")
worker.logger.warn("celeryd: Warm shutdown (%s)" % (
process_name))
worker.stop(in_sighandler=True)
Expand Down
5 changes: 0 additions & 5 deletions celery/worker/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -151,11 +151,6 @@ def __init__(self, concurrency=None, logfile=None, loglevel=None,
self.db = db or conf.CELERYD_STATE_DB
self.disable_rate_limits = disable_rate_limits or \
conf.CELERY_DISABLE_RATE_LIMITS

# FIXME
# For some reason disable rate limits does not work currently,
# needs to be fixed for v2.2.0.
self.disable_rate_limits = False
self.queues = queues

self._finalize = Finalize(self, self.stop, exitpriority=1)
Expand Down

0 comments on commit a0c6c70

Please sign in to comment.