Permalink
Browse files

Cosmetics

  • Loading branch information...
1 parent 7a38710 commit 641e838dd6a1bc9db55e780a5392f3f8bfec4683 @ask committed Oct 30, 2011
Showing with 442 additions and 400 deletions.
  1. +1 −0 celery/__init__.py
  2. +6 −5 celery/app/__init__.py
  3. +5 −5 celery/app/amqp.py
  4. +6 −5 celery/app/base.py
  5. +11 −0 celery/app/defaults.py
  6. +12 −1 celery/app/task/__init__.py
  7. +1 −0 celery/apps/beat.py
  8. +1 −0 celery/apps/worker.py
  9. +1 −0 celery/backends/__init__.py
  10. +1 −0 celery/backends/base.py
  11. +1 −0 celery/backends/cache.py
  12. +1 −0 celery/backends/cassandra.py
  13. +1 −0 celery/backends/database.py
  14. +1 −0 celery/backends/mongodb.py
  15. +1 −0 celery/backends/pyredis.py
  16. +1 −0 celery/backends/redis.py
  17. +1 −0 celery/backends/tyrant.py
  18. +6 −6 celery/beat.py
  19. +1 −0 celery/bin/base.py
  20. +1 −1 celery/bin/camqadm.py
  21. +1 −1 celery/bin/celerybeat.py
  22. +1 −0 celery/bin/celeryctl.py
  23. +1 −1 celery/bin/celeryd.py
  24. +1 −0 celery/bin/celeryd_detach.py
  25. +1 −0 celery/bin/celeryd_multi.py
  26. +1 −0 celery/bin/celeryev.py
  27. +1 −0 celery/concurrency/__init__.py
  28. +1 −0 celery/concurrency/base.py
  29. +1 −0 celery/concurrency/eventlet.py
  30. +1 −0 celery/concurrency/gevent.py
  31. +1 −5 celery/concurrency/processes/__init__.py
  32. +1 −2 celery/concurrency/processes/_win.py
  33. +1 −2 celery/concurrency/processes/pool.py
  34. +1 −0 celery/concurrency/solo.py
  35. +1 −0 celery/concurrency/threads.py
  36. +1 −0 celery/conf.py
  37. +1 −0 celery/contrib/abortable.py
  38. +1 −0 celery/contrib/batches.py
  39. +1 −0 celery/contrib/rdb.py
  40. +7 −7 celery/datastructures.py
  41. +1 −0 celery/db/a805d4bd.py
  42. +1 −0 celery/db/dfd042c7.py
  43. +1 −0 celery/db/models.py
  44. +1 −0 celery/db/session.py
  45. +0 −2 celery/decorators.py
  46. +8 −7 celery/events/__init__.py
  47. +7 −5 celery/events/cursesmon.py
  48. +7 −6 celery/events/dumper.py
  49. +10 −9 celery/events/snapshot.py
  50. +14 −14 celery/events/state.py
  51. +6 −14 celery/exceptions.py
  52. +1 −0 celery/execute/__init__.py
  53. +8 −7 celery/execute/trace.py
  54. +7 −6 celery/loaders/__init__.py
  55. +6 −5 celery/loaders/app.py
  56. +6 −6 celery/loaders/base.py
  57. +6 −5 celery/loaders/default.py
  58. +8 −6 celery/local.py
  59. +1 −13 celery/log.py
  60. +2 −8 celery/messaging.py
  61. +7 −9 celery/platforms.py
  62. +6 −5 celery/registry.py
  63. +7 −6 celery/result.py
  64. +8 −6 celery/routes.py
  65. +8 −6 celery/schedules.py
  66. +1 −3 celery/states.py
  67. +9 −12 celery/task/__init__.py
  68. +6 −5 celery/task/base.py
  69. +6 −5 celery/task/chords.py
  70. +7 −8 celery/task/control.py
  71. +6 −6 celery/task/http.py
  72. +2 −3 celery/task/schedules.py
  73. +6 −5 celery/task/sets.py
  74. +6 −12 celery/utils/__init__.py
  75. +8 −4 celery/utils/compat.py
  76. +2 −3 celery/utils/dispatch/__init__.py
  77. +1 −0 celery/utils/dispatch/saferef.py
  78. +1 −0 celery/utils/dispatch/signal.py
  79. +9 −7 celery/utils/encoding.py
  80. +6 −5 celery/utils/functional.py
  81. +6 −6 celery/utils/mail.py
  82. +6 −5 celery/utils/patch.py
  83. +6 −8 celery/utils/serialization.py
  84. +6 −7 celery/utils/term.py
  85. +13 −9 celery/utils/timer2.py
  86. +6 −7 celery/utils/timeutils.py
  87. +6 −5 celery/worker/__init__.py
  88. +10 −9 celery/worker/autoscale.py
  89. +11 −11 celery/worker/buckets.py
  90. +8 −7 celery/worker/consumer.py
  91. +7 −4 celery/worker/control/__init__.py
  92. +6 −11 celery/worker/control/builtins.py
  93. +7 −6 celery/worker/control/registry.py
  94. +7 −6 celery/worker/heartbeat.py
  95. +7 −8 celery/worker/job.py
  96. +12 −12 celery/worker/mediator.py
  97. +8 −11 celery/worker/state.py
  98. +4 −3 docs/conf.py
  99. +7 −1 docs/reference/celery.signals.rst
View
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
"""Distributed Task Queue"""
# :copyright: (c) 2009 - 2011 by Ask Solem.
# :license: BSD, see LICENSE for more details.
View
@@ -1,11 +1,12 @@
+# -*- coding: utf-8 -*-
"""
-celery.app
-==========
+ celery.app
+ ~~~~~~~~~~
-Celery Application.
+ Celery Application.
-:copyright: (c) 2009 - 2011 by Ask Solem.
-:license: BSD, see LICENSE for more details.
+ :copyright: (c) 2009 - 2011 by Ask Solem.
+ :license: BSD, see LICENSE for more details.
"""
View
@@ -1,12 +1,12 @@
# -*- coding: utf-8 -*-
"""
-celery.app.amqp
-===============
+ celery.app.amqp
+ ~~~~~~~~~~~~~~~
-AMQ related functionality.
+ AMQ related functionality.
-:copyright: (c) 2009 - 2011 by Ask Solem.
-:license: BSD, see LICENSE for more details.
+ :copyright: (c) 2009 - 2011 by Ask Solem.
+ :license: BSD, see LICENSE for more details.
"""
from __future__ import absolute_import
View
@@ -1,11 +1,12 @@
+# -*- coding: utf-8 -*-
"""
-celery.app.base
-===============
+ celery.app.base
+ ~~~~~~~~~~~~~~~
-Application Base Class.
+ Application Base Class.
-:copyright: (c) 2009 - 2011 by Ask Solem.
-:license: BSD, see LICENSE for more details.
+ :copyright: (c) 2009 - 2011 by Ask Solem.
+ :license: BSD, see LICENSE for more details.
"""
from __future__ import absolute_import
View
@@ -1,3 +1,14 @@
+# -*- coding: utf-8 -*-
+"""
+ celery.app.defaults
+ ~~~~~~~~~~~~~~~~~~~
+
+ Configuration introspection and defaults.
+
+ :copyright: (c) 2009 - 2011 by Ask Solem.
+ :license: BSD, see LICENSE for more details.
+
+"""
from __future__ import absolute_import
import sys
@@ -1,4 +1,15 @@
-# -*- coding: utf-8 -*-"
+# -*- coding: utf-8 -*-
+"""
+ celery.app.task
+ ~~~~~~~~~~~~~~~
+
+ Tasks Implementation.
+
+ :copyright: (c) 2009 - 2011 by Ask Solem.
+ :license: BSD, see LICENSE for more details.
+
+"""
+
from __future__ import absolute_import
import sys
View
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
import atexit
View
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
import atexit
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
from .. import current_app
View
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
"""celery.backends.base"""
from __future__ import absolute_import
View
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
from ..datastructures import LRUCache
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
"""celery.backends.cassandra"""
from __future__ import absolute_import
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
from datetime import datetime
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
"""MongoDB backend for celery."""
from __future__ import absolute_import
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
"""
This is here for backwards compatibility only.
View
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
from ..exceptions import ImproperlyConfigured
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
"""celery.backends.tyrant"""
from __future__ import absolute_import
View
@@ -1,9 +1,12 @@
+# -*- coding: utf-8 -*-
"""
+ celery.beat
+ ~~~~~~~~~~~
-celery.beat
-===========
+ The Celery periodic task scheduler.
-The Celery periodic task scheduler.
+ :copyright: (c) 2009 - 2011 by Ask Solem.
+ :license: BSD, see LICENSE for more details.
"""
from __future__ import absolute_import
@@ -32,9 +35,6 @@
from .utils import cached_property, instantiate, maybe_promise
from .utils.timeutils import humanize_seconds
-__all__ = ["SchedulingError", "ScheduleEntry", "Scheduler",
- "Service", "EmbeddedService"]
-
class SchedulingError(Exception):
"""An error occured while scheduling a task."""
View
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
import os
View
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+# -*- coding: utf-8 -*-
"""camqadm
.. program:: camqadm
View
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+# -*- coding: utf-8 -*-
"""celerybeat
.. program:: celerybeat
View
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
from __future__ import with_statement
View
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+# -*- coding: utf-8 -*-
"""celeryd
.. program:: celeryd
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
from __future__ import with_statement
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
"""
Examples
View
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
from __future__ import with_statement
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
from ..utils import get_cls_by_name
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
import logging
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
import os
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
import os
@@ -1,8 +1,4 @@
-"""
-
-Process Pools.
-
-"""
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
import platform
@@ -1,9 +1,8 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
import os
-__all__ = ["get_processtree_pids", "kill_processtree"]
-
# psutil is painfully slow in win32. So to avoid adding big
# dependencies like pywin32 a ctypes based solution is preferred
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
#
# Module providing the `Pool` class for managing a process pool
#
@@ -7,8 +8,6 @@
#
from __future__ import absolute_import
-__all__ = ['Pool']
-
#
# Imports
#
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
import os
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
from UserDict import UserDict
View
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
"""
**DEPRECATED**
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
"""
=========================
Abortable tasks overview
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
"""
celery.contrib.batches
======================
View
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
"""
celery.contrib.rdb
==================
View
@@ -1,8 +1,12 @@
+# -*- coding: utf-8 -*-
"""
-celery.datastructures
-=====================
+ celery.datastructures
+ ~~~~~~~~~~~~~~~~~~~~~
-Custom types and data structures.
+ Custom types and data structures.
+
+ :copyright: (c) 2009 - 2011 by Ask Solem.
+ :license: BSD, see LICENSE for more details.
"""
from __future__ import absolute_import
@@ -17,10 +21,6 @@
from .utils.compat import UserDict, OrderedDict
-__all__ = ["AttributeDictMixin", "AttributeDict", "DictAttribute",
- "ConfigurationView", "ExceptionInfo", "LimitedSet",
- "LRUCache", "TokenBucket"]
-
class AttributeDictMixin(object):
"""Adds attribute access to mappings.
View
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
"""
a805d4bd
This module fixes a bug with pickling and relative imports in Python < 2.6.
View
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
"""
dfd042c7
View
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
from datetime import datetime
View
@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
from __future__ import absolute_import
from collections import defaultdict
View
@@ -19,8 +19,6 @@
from . import task as _task
from .exceptions import CDeprecationWarning
-__all__ = ["task", "periodic_task"]
-
warnings.warn(CDeprecationWarning("""
The `celery.decorators` module and the magic keyword arguments
View
@@ -1,11 +1,14 @@
+# -*- coding: utf-8 -*-
"""
+ celery.events
+ ~~~~~~~~~~~~~
-celery.events
-=============
+ Events are messages sent for actions happening
+ in the worker (and clients if :setting:`CELERY_SEND_TASK_SENT_EVENT`
+ is enabled), used for monitoring purposes.
-Events are messages sent for actions happening
-in the worker (and clients if :setting:`CELERY_SEND_TASK_SENT_EVENT` is
-enabled). These events can be used for monitoring.
+ :copyright: (c) 2009 - 2011 by Ask Solem.
+ :license: BSD, see LICENSE for more details.
"""
from __future__ import absolute_import
@@ -25,8 +28,6 @@
from ..app import app_or_default
from ..utils import uuid
-__all__ = ["event_exchange", "Event", "EventDispatcher", "EventReceiver"]
-
event_exchange = Exchange("celeryev", type="topic")
Oops, something went wrong.

0 comments on commit 641e838

Please sign in to comment.