Make __all__ immutable. (#4315)

celery/__init__.py

@@ -23,12 +23,12 @@ __keywords__ = 'task job queue distributed messaging actor'
 
 # -eof meta-
 
-__all__ = [
+__all__ = (
     'Celery', 'bugreport', 'shared_task', 'task',
     'current_app', 'current_task', 'maybe_signature',
     'chain', 'chord', 'chunks', 'group', 'signature',
     'xmap', 'xstarmap', 'uuid',
-]
+)
 
 VERSION_BANNER = '{0} ({1})'.format(__version__, SERIES)
 

celery/__main__.py

@@ -3,7 +3,7 @@ from __future__ import absolute_import, print_function, unicode_literals
 import sys
 from . import maybe_patch_concurrency
 
-__all__ = ['main']
+__all__ = ('main',)
 
 
 def main():

celery/_state.py

@@ -14,11 +14,11 @@ import weakref
 from celery.local import Proxy
 from celery.utils.threads import LocalStack
 
-__all__ = [
+__all__ = (
     'set_default_app', 'get_current_app', 'get_current_task',
     'get_current_worker_task', 'current_app', 'current_task',
     'connect_on_app_finalize',
-]
+)
 
 #: Global default app used when no current app.
 default_app = None

celery/app/__init__.py

@@ -10,11 +10,11 @@ from celery._state import (
 from .base import Celery
 from .utils import AppPickler
 
-__all__ = [
+__all__ = (
     'Celery', 'AppPickler', 'app_or_default', 'default_app',
     'bugreport', 'enable_trace', 'disable_trace', 'shared_task',
     'push_current_task', 'pop_current_task',
-]
+)
 
 #: Proxy always returning the app set as default.
 default_app = Proxy(lambda: _state.default_app)

celery/app/amqp.py

@@ -25,7 +25,7 @@ from celery.utils.time import maybe_make_aware
 
 from . import routes as _routes
 
-__all__ = ['AMQP', 'Queues', 'task_message']
+__all__ = ('AMQP', 'Queues', 'task_message')
 
 PY3 = sys.version_info[0] == 3
 

celery/app/annotations.py

@@ -15,7 +15,7 @@ from celery.utils.imports import instantiate
 _first_match = firstmethod('annotate')
 _first_match_any = firstmethod('annotate_any')
 
-__all__ = ['MapAnnotation', 'prepare', 'resolve_all']
+__all__ = ('MapAnnotation', 'prepare', 'resolve_all')
 
 
 class MapAnnotation(dict):

celery/app/backends.py

@@ -8,7 +8,7 @@ from celery._state import current_app
 from celery.five import reraise
 from celery.utils.imports import load_extension_class_names, symbol_by_name
 
-__all__ = ['by_name', 'by_url']
+__all__ = ('by_name', 'by_url')
 
 UNKNOWN_BACKEND = """
 Unknown result backend: {0!r}.  Did you spell that correctly? ({1!r})

celery/app/base.py

@@ -57,7 +57,7 @@ from .utils import (
 # Load all builtin tasks
 from . import builtins  # noqa
 
-__all__ = ['Celery']
+__all__ = ('Celery',)
 
 logger = get_logger(__name__)
 

celery/app/builtins.py

@@ -7,7 +7,7 @@ from __future__ import absolute_import, unicode_literals
 from celery._state import connect_on_app_finalize
 from celery.utils.log import get_logger
 
-__all__ = []
+__all__ = ()
 logger = get_logger(__name__)
 
 

celery/app/control.py

@@ -13,7 +13,7 @@ from kombu.utils.objects import cached_property
 from celery.exceptions import DuplicateNodenameWarning
 from celery.utils.text import pluralize
 
-__all__ = ['Inspect', 'Control', 'flatten_reply']
+__all__ = ('Inspect', 'Control', 'flatten_reply')
 
 W_DUPNODE = """\
 Received multiple replies from node {0}: {1}.

celery/app/defaults.py

@@ -8,7 +8,7 @@ from celery.five import items, keys, python_2_unicode_compatible
 from celery.utils.functional import memoize
 from celery.utils.serialization import strtobool
 
-__all__ = ['Option', 'NAMESPACES', 'flatten', 'find']
+__all__ = ('Option', 'NAMESPACES', 'flatten', 'find')
 
 is_jython = sys.platform.startswith('java')
 is_pypy = hasattr(sys, 'pypy_version_info')

celery/app/log.py

@@ -30,7 +30,7 @@ from celery.utils.log import (
 from celery.utils.nodenames import node_format
 from celery.utils.term import colored
 
-__all__ = ['TaskFormatter', 'Logging']
+__all__ = ('TaskFormatter', 'Logging')
 
 MP_LOG = os.environ.get('MP_LOG', False)
 

celery/app/registry.py

@@ -7,7 +7,7 @@ from celery._state import get_current_app
 from celery.exceptions import NotRegistered, InvalidTaskError
 from celery.five import items
 
-__all__ = ['TaskRegistry']
+__all__ = ('TaskRegistry',)
 
 
 class TaskRegistry(dict):

celery/app/routes.py

@@ -14,7 +14,7 @@ from celery.utils.collections import lpmerge
 from celery.utils.functional import maybe_evaluate, mlazy
 from celery.utils.imports import symbol_by_name
 
-__all__ = ['MapRoute', 'Router', 'prepare']
+__all__ = ('MapRoute', 'Router', 'prepare')
 
 
 def glob_to_re(glob, quote=string.punctuation.replace('*', '')):

celery/app/task.py

@@ -26,7 +26,7 @@ from .annotations import resolve_all as resolve_all_annotations
 from .registry import _unpickle_task_v2
 from .utils import appstr
 
-__all__ = ['Context', 'Task']
+__all__ = ('Context', 'Task')
 
 #: extracts attributes related to publishing a message from an object.
 extract_exec_options = mattrgetter(

celery/app/trace.py

@@ -43,10 +43,10 @@ from celery.utils.serialization import (
     get_pickleable_exception, get_pickled_exception, get_pickleable_etype,
 )
 
-__all__ = [
+__all__ = (
     'TraceInfo', 'build_tracer', 'trace_task',
     'setup_worker_optimizations', 'reset_worker_optimizations',
-]
+)
 
 logger = get_logger(__name__)
 

celery/app/utils.py

@@ -24,10 +24,10 @@ from .defaults import (
     DEFAULTS, SETTING_KEYS, find,
 )
 
-__all__ = [
+__all__ = (
     'Settings', 'appstr', 'bugreport',
     'filter_hidden_settings', 'find_app',
-]
+)
 
 #: Format used to generate bug-report information.
 BUGREPORT_INFO = """

celery/apps/beat.py

@@ -18,7 +18,7 @@ from celery.utils.imports import qualname
 from celery.utils.log import LOG_LEVELS, get_logger
 from celery.utils.time import humanize_seconds
 
-__all__ = ['Beat']
+__all__ = ('Beat',)
 
 STARTUP_INFO_FMT = """
 LocalTime -> {timestamp}

celery/apps/multi.py

@@ -22,7 +22,7 @@ from celery.utils.nodenames import (
 )
 from celery.utils.saferepr import saferepr
 
-__all__ = ['Cluster', 'Node']
+__all__ = ('Cluster', 'Node')
 
 CELERY_EXE = 'celery'
 

celery/apps/worker.py

@@ -36,7 +36,7 @@ from celery.utils.log import get_logger, in_sighandler, set_in_sighandler
 from celery.utils.text import pluralize
 from celery.worker import WorkController
 
-__all__ = ['Worker']
+__all__ = ('Worker',)
 
 logger = get_logger(__name__)
 is_jython = sys.platform.startswith('java')

celery/backends/amqp.py

@@ -17,7 +17,7 @@ from celery.utils.log import get_logger
 
 from .base import BaseBackend
 
-__all__ = ['BacklogLimitExceeded', 'AMQPBackend']
+__all__ = ('BacklogLimitExceeded', 'AMQPBackend')
 
 logger = get_logger(__name__)
 

celery/backends/async.py

@@ -16,10 +16,10 @@ from celery.exceptions import TimeoutError
 from celery.five import Empty, monotonic
 from celery.utils.threads import THREAD_TIMEOUT_MAX
 
-__all__ = [
+__all__ = (
     'AsyncBackendMixin', 'BaseResultConsumer', 'Drainer',
     'register_drainer',
-]
+)
 
 drainers = {}
 

celery/backends/base.py

@@ -42,7 +42,7 @@ from celery.utils.serialization import (
     create_exception_cls,
 )
 
-__all__ = ['BaseBackend', 'KeyValueStoreBackend', 'DisabledBackend']
+__all__ = ('BaseBackend', 'KeyValueStoreBackend', 'DisabledBackend')
 
 EXCEPTION_ABLE_CODECS = frozenset({'pickle'})
 PY3 = sys.version_info >= (3, 0)

celery/backends/cache.py

@@ -8,7 +8,7 @@ from celery.exceptions import ImproperlyConfigured
 from celery.utils.functional import LRUCache
 from .base import KeyValueStoreBackend
 
-__all__ = ['CacheBackend']
+__all__ = ('CacheBackend',)
 
 _imp = [None]
 

celery/backends/cassandra.py

@@ -14,7 +14,7 @@ except ImportError:  # pragma: no cover
     cassandra = None   # noqa
 
 
-__all__ = ['CassandraBackend']
+__all__ = ('CassandraBackend',)
 
 logger = get_logger(__name__)
 

celery/backends/consul.py

@@ -16,7 +16,7 @@ except ImportError:
 
 logger = get_logger(__name__)
 
-__all__ = ['ConsulBackend']
+__all__ = ('ConsulBackend',)
 
 CONSUL_MISSING = """\
 You need to install the python-consul library in order to use \

celery/backends/couchbase.py

@@ -13,7 +13,7 @@ try:
 except ImportError:
     Couchbase = Connection = NotFoundError = None   # noqa
 
-__all__ = ['CouchbaseBackend']
+__all__ = ('CouchbaseBackend',)
 
 
 class CouchbaseBackend(KeyValueStoreBackend):

celery/backends/couchdb.py

@@ -9,7 +9,7 @@ try:
 except ImportError:
     pycouchdb = None  # noqa
 
-__all__ = ['CouchBackend']
+__all__ = ('CouchBackend',)
 
 ERR_LIB_MISSING = """\
 You need to install the pycouchdb library to use the CouchDB result backend\

celery/backends/database/__init__.py

@@ -28,7 +28,7 @@ except ImportError:  # pragma: no cover
 
 logger = logging.getLogger(__name__)
 
-__all__ = ['DatabaseBackend']
+__all__ = ('DatabaseBackend',)
 
 
 @contextmanager

celery/backends/database/models.py

@@ -8,7 +8,7 @@ from celery import states
 from celery.five import python_2_unicode_compatible
 from .session import ResultModelBase
 
-__all__ = ['Task', 'TaskSet']
+__all__ = ('Task', 'TaskSet')
 
 
 @python_2_unicode_compatible

celery/backends/database/session.py

@@ -9,7 +9,7 @@ from kombu.utils.compat import register_after_fork
 
 ResultModelBase = declarative_base()
 
-__all__ = ['SessionManager']
+__all__ = ('SessionManager',)
 
 
 def _after_fork_cleanup_session(session):

celery/backends/dynamodb.py

@@ -15,7 +15,7 @@ try:
 except ImportError:  # pragma: no cover
     boto3 = ClientError = None  # noqa
 
-__all__ = ['DynamoDBBackend']
+__all__ = ('DynamoDBBackend',)
 
 
 # Helper class that describes a DynamoDB attribute

celery/backends/elasticsearch.py

@@ -12,7 +12,7 @@ try:
 except ImportError:
     elasticsearch = None  # noqa
 
-__all__ = ['ElasticsearchBackend']
+__all__ = ('ElasticsearchBackend',)
 
 E_LIB_MISSING = """\
 You need to install the elasticsearch library to use the Elasticsearch \

celery/backends/mongodb.py

@@ -27,7 +27,7 @@ else:                                       # pragma: no cover
     class InvalidDocument(Exception):       # noqa
         pass
 
-__all__ = ['MongoBackend']
+__all__ = ('MongoBackend',)
 
 BINARY_CODECS = frozenset(['pickle', 'msgpack'])
 

celery/backends/redis.py

@@ -28,7 +28,7 @@ except ImportError:                 # pragma: no cover
     redis = None                    # noqa
     get_redis_error_classes = None  # noqa
 
-__all__ = ['RedisBackend']
+__all__ = ('RedisBackend',)
 
 E_REDIS_MISSING = """
 You need to install the redis library in order to use \

celery/backends/riak.py

@@ -12,7 +12,7 @@ try:
 except ImportError:  # pragma: no cover
     riak = RiakClient = last_written_resolver = None  # noqa
 
-__all__ = ['RiakBackend']
+__all__ = ('RiakBackend',)
 
 E_BUCKET_NAME = """\
 Riak bucket names must be composed of ASCII characters only, not: {0!r}\

celery/backends/rpc.py

@@ -19,7 +19,7 @@ from celery.five import items, range
 from . import base
 from .async import AsyncBackendMixin, BaseResultConsumer
 
-__all__ = ['BacklogLimitExceeded', 'RPCBackend']
+__all__ = ('BacklogLimitExceeded', 'RPCBackend')
 
 E_NO_CHORD_SUPPORT = """
 The "rpc" result backend does not support chords!

celery/beat.py

@@ -32,10 +32,10 @@ from .utils.imports import load_extension_class_names, symbol_by_name
 from .utils.time import humanize_seconds
 from .utils.log import get_logger, iter_open_logger_fds
 
-__all__ = [
+__all__ = (
     'SchedulingError', 'ScheduleEntry', 'Scheduler',
     'PersistentScheduler', 'Service', 'EmbeddedService',
-]
+)
 
 event_t = namedtuple('event_t', ('time', 'priority', 'entry'))
 

celery/bin/__init__.py

@@ -1,4 +1,4 @@
 from __future__ import absolute_import, unicode_literals
 from .base import Option
 
-__all__ = ['Option']
+__all__ = ('Option',)

celery/bin/amqp.py

@@ -21,7 +21,7 @@ from celery.bin.base import Command
 from celery.five import string_t
 from celery.utils.serialization import strtobool
 
-__all__ = ['AMQPAdmin', 'AMQShell', 'Spec', 'amqp']
+__all__ = ('AMQPAdmin', 'AMQShell', 'Spec', 'amqp')
 
 # Map to coerce strings to other types.
 COERCE = {bool: strtobool}

celery/bin/base.py

@@ -42,9 +42,9 @@ try:
 except NameError:  # pragma: no cover
     pass
 
-__all__ = [
+__all__ = (
     'Error', 'UsageError', 'Extensions', 'Command', 'Option', 'daemon_options',
-]
+)
 
 # always enable DeprecationWarnings, so our users can see them.
 for warning in (CDeprecationWarning, CPendingDeprecationWarning):

celery/bin/beat.py

@@ -69,7 +69,7 @@ from functools import partial
 from celery.platforms import detached, maybe_drop_privileges
 from celery.bin.base import Command, daemon_options
 
-__all__ = ['beat']
+__all__ = ('beat',)
 
 HELP = __doc__
 

celery/bin/celery.py

@@ -284,7 +284,7 @@ from celery.bin.shell import shell
 from celery.bin.worker import worker
 from celery.bin.upgrade import upgrade
 
-__all__ = ['CeleryCommand', 'main']
+__all__ = ('CeleryCommand', 'main')
 
 HELP = """
 ---- -- - - ---- Commands- -------------- --- ------------

celery/bin/celeryd_detach.py

@@ -15,7 +15,8 @@ from celery.utils.log import get_logger
 from celery.utils.nodenames import default_nodename, node_format
 from celery.bin.base import daemon_options
 
-__all__ = ['detached_celeryd', 'detach']
+__all__ = ('detached_celeryd', 'detach')
+
 logger = get_logger(__name__)
 C_FAKEFORK = os.environ.get('C_FAKEFORK')
 

celery/bin/events.py

@@ -71,7 +71,7 @@ from functools import partial
 from celery.platforms import detached, set_process_title, strargv
 from celery.bin.base import Command, daemon_options
 
-__all__ = ['events']
+__all__ = ('events',)
 
 HELP = __doc__
 

celery/bin/graph.py

@@ -9,7 +9,7 @@ from celery.five import items, python_2_unicode_compatible
 from celery.utils.graph import DependencyGraph, GraphFormatter
 from .base import Command
 
-__all__ = ['graph']
+__all__ = ('graph',)
 
 
 class graph(Command):

celery/bin/logtool.py

@@ -10,7 +10,7 @@ from collections import Counter
 from fileinput import FileInput
 from .base import Command
 
-__all__ = ['logtool']
+__all__ = ('logtool',)
 
 RE_LOG_START = re.compile(r'^\[\d\d\d\d\-\d\d-\d\d ')
 RE_TASK_RECEIVED = re.compile(r'.+?\] Received')

celery/bin/multi.py

@@ -105,7 +105,7 @@ from celery.platforms import EX_FAILURE, EX_OK, signals
 from celery.utils import term
 from celery.utils.text import pluralize
 
-__all__ = ['MultiTool']
+__all__ = ('MultiTool',)
 
 USAGE = """\
 usage: {prog_name} start <node1 node2 nodeN|range> [worker options]

celery/bin/worker.py

@@ -185,7 +185,7 @@ from celery.platforms import maybe_drop_privileges
 from celery.utils.log import LOG_LEVELS, mlevel
 from celery.utils.nodenames import default_nodename
 
-__all__ = ['worker', 'main']
+__all__ = ('worker', 'main')
 
 HELP = __doc__
 

celery/bootsteps.py

@@ -21,7 +21,7 @@ except ImportError:  # pragma: no cover
 else:
     IGNORE_ERRORS = (GreenletExit,)
 
-__all__ = ['Blueprint', 'Step', 'StartStopStep', 'ConsumerStep']
+__all__ = ('Blueprint', 'Step', 'StartStopStep', 'ConsumerStep')
 
 #: States
 RUN = 0x1

celery/canvas.py

@@ -33,10 +33,10 @@ from celery.utils.functional import (
 from celery.utils.objects import getitem_property
 from celery.utils.text import truncate, remove_repeating_from_task
 
-__all__ = [
+__all__ = (
     'Signature', 'chain', 'xmap', 'xstarmap', 'chunks',
     'group', 'chord', 'signature', 'maybe_signature',
-]
+)
 
 PY3 = sys.version_info[0] == 3
 

celery/concurrency/__init__.py

@@ -7,7 +7,7 @@ from __future__ import absolute_import, unicode_literals
 # too much (e.g., for eventlet patching)
 from kombu.utils.imports import symbol_by_name
 
-__all__ = ['get_implementation']
+__all__ = ('get_implementation',)
 
 ALIASES = {
     'prefork': 'celery.concurrency.prefork:TaskPool',

celery/concurrency/asynpool.py

@@ -76,7 +76,7 @@ except (ImportError, NameError):  # pragma: no cover
     def unpack_from(fmt, iobuf, unpack=struct.unpack):  # noqa
         return unpack(fmt, iobuf.getvalue())  # <-- BytesIO
 
-__all__ = ['AsynPool']
+__all__ = ('AsynPool',)
 
 logger = get_logger(__name__)
 error, debug = logger.error, logger.debug

celery/concurrency/base.py

@@ -16,7 +16,7 @@ from celery.utils import timer2
 from celery.utils.text import truncate
 from celery.utils.log import get_logger
 
-__all__ = ['BasePool', 'apply_target']
+__all__ = ('BasePool', 'apply_target')
 
 logger = get_logger('celery.pool')
 

celery/concurrency/eventlet.py

@@ -4,7 +4,7 @@ from __future__ import absolute_import, unicode_literals
 import sys
 from kombu.five import monotonic
 
-__all__ = ['TaskPool']
+__all__ = ('TaskPool',)
 
 W_RACE = """\
 Celery module with %s imported before eventlet patched\

celery/concurrency/gevent.py

@@ -9,7 +9,7 @@ try:
 except ImportError:  # pragma: no cover
     Timeout = None  # noqa
 
-__all__ = ['TaskPool']
+__all__ = ('TaskPool',)
 
 # pylint: disable=redefined-outer-name
 # We cache globals and attribute lookups, so disable this warning.

celery/concurrency/prefork.py

@@ -22,7 +22,7 @@ from celery.utils.log import get_logger
 
 from .asynpool import AsynPool
 
-__all__ = ['TaskPool', 'process_initializer', 'process_destructor']
+__all__ = ('TaskPool', 'process_initializer', 'process_destructor')
 
 #: List of signals to reset when a child process starts.
 WORKER_SIGRESET = {

celery/concurrency/solo.py

@@ -4,7 +4,7 @@ from __future__ import absolute_import, unicode_literals
 import os
 from .base import BasePool, apply_target
 
-__all__ = ['TaskPool']
+__all__ = ('TaskPool',)
 
 
 class TaskPool(BasePool):

celery/contrib/abortable.py

@@ -87,7 +87,7 @@ from __future__ import absolute_import, unicode_literals
 from celery import Task
 from celery.result import AsyncResult
 
-__all__ = ['AbortableAsyncResult', 'AbortableTask']
+__all__ = ('AbortableAsyncResult', 'AbortableTask')
 
 
 """

celery/contrib/migrate.py

@@ -16,12 +16,12 @@ from celery.five import python_2_unicode_compatible, string, string_t
 from celery.utils.nodenames import worker_direct
 from celery.utils.text import str_to_list
 
-__all__ = [
+__all__ = (
     'StopFiltering', 'State', 'republish', 'migrate_task',
     'migrate_tasks', 'move', 'task_id_eq', 'task_id_in',
     'start_filter', 'move_task_by_id', 'move_by_idmap',
     'move_by_taskmap', 'move_direct', 'move_direct_by_id',
-]
+)
 
 MOVING_PROGRESS_FMT = """\
 Moving task {state.filtered}/{state.strtotal}: \

celery/contrib/rdb.py

@@ -50,10 +50,10 @@ from pdb import Pdb
 from billiard.process import current_process
 from celery.five import range
 
-__all__ = [
+__all__ = (
     'CELERY_RDB_HOST', 'CELERY_RDB_PORT', 'DEFAULT_PORT',
     'Rdb', 'debugger', 'set_trace',
-]
+)
 
 DEFAULT_PORT = 6899
 

celery/events/__init__.py

@@ -10,7 +10,7 @@ from .dispatcher import EventDispatcher
 from .event import Event, event_exchange, get_exchange, group_from
 from .receiver import EventReceiver
 
-__all__ = [
+__all__ = (
     'Event', 'EventDispatcher', 'EventReceiver',
     'event_exchange', 'get_exchange', 'group_from',
-]
+)

celery/events/cursesmon.py

@@ -18,7 +18,7 @@ from celery.app import app_or_default
 from celery.five import items, values
 from celery.utils.text import abbr, abbrtask
 
-__all__ = ['CursesMonitor', 'evtop']
+__all__ = ('CursesMonitor', 'evtop')
 
 BORDER_SPACING = 4
 LEFT_BORDER_OFFSET = 3

celery/events/dispatcher.py

@@ -16,7 +16,7 @@ from celery.utils.time import utcoffset
 
 from .event import Event, get_exchange, group_from
 
-__all__ = ['EventDispatcher']
+__all__ = ('EventDispatcher',)
 
 
 class EventDispatcher(object):

celery/events/dumper.py

@@ -11,7 +11,7 @@ from celery.app import app_or_default
 from celery.utils.functional import LRUCache
 from celery.utils.time import humanize_seconds
 
-__all__ = ['Dumper', 'evdump']
+__all__ = ('Dumper', 'evdump')
 
 TASK_NAMES = LRUCache(limit=0xFFF)
 

celery/events/event.py

@@ -4,9 +4,9 @@ import time
 from copy import copy
 from kombu import Exchange
 
-__all__ = [
+__all__ = (
     'Event', 'event_exchange', 'get_exchange', 'group_from',
-]
+)
 
 #: Exchange used to send events on.
 #: Note: Use :func:`get_exchange` instead, as the type of

celery/events/receiver.py

@@ -15,7 +15,7 @@ from celery.utils.time import adjust_timestamp
 
 from .event import get_exchange
 
-__all__ = ['EventReceiver']
+__all__ = ('EventReceiver',)
 
 CLIENT_CLOCK_SKEW = -1
 

celery/events/snapshot.py

@@ -17,7 +17,7 @@ from celery.utils.imports import instantiate
 from celery.utils.log import get_logger
 from celery.utils.time import rate
 
-__all__ = ['Polaroid', 'evcam']
+__all__ = ('Polaroid', 'evcam')
 
 logger = get_logger('celery.evcam')
 

celery/events/state.py

@@ -35,7 +35,7 @@ from celery.five import items, python_2_unicode_compatible, values
 from celery.utils.functional import LRUCache, memoize, pass1
 from celery.utils.log import get_logger
 
-__all__ = ['Worker', 'Task', 'State', 'heartbeat_expires']
+__all__ = ('Worker', 'Task', 'State', 'heartbeat_expires')
 
 # pylint: disable=redefined-outer-name
 # We cache globals and attribute lookups, so disable this warning.

celery/exceptions.py

@@ -55,7 +55,7 @@ from billiard.exceptions import (
 )
 from kombu.exceptions import OperationalError
 
-__all__ = [
+__all__ = (
     # Warnings
     'CeleryWarning',
     'AlwaysEagerIgnored', 'DuplicateNodenameWarning',
@@ -86,7 +86,7 @@ __all__ = [
 
     # Worker shutdown semi-predicates (inherits from SystemExit).
     'WorkerShutdown', 'WorkerTerminate',
-]
+)
 
 UNREGISTERED_FMT = """\
 Task of kind {0} never registered, please make sure it's imported.\

celery/fixups/django.py

@@ -15,7 +15,7 @@ from celery import _state
 from celery import signals
 from celery.exceptions import FixupWarning, ImproperlyConfigured
 
-__all__ = ['DjangoFixup', 'fixup']
+__all__ = ('DjangoFixup', 'fixup')
 
 ERR_NOT_INSTALLED = """\
 Environment variable DJANGO_SETTINGS_MODULE is defined

celery/loaders/__init__.py

@@ -7,7 +7,7 @@ when workers start, when tasks are executed and so on.
 from __future__ import absolute_import, unicode_literals
 from celery.utils.imports import symbol_by_name, import_from_cwd
 
-__all__ = ['get_loader_cls']
+__all__ = ('get_loader_cls',)
 
 LOADER_ALIASES = {
     'app': 'celery.loaders.app:AppLoader',

celery/loaders/app.py

@@ -3,7 +3,7 @@
 from __future__ import absolute_import, unicode_literals
 from .base import BaseLoader
 
-__all__ = ['AppLoader']
+__all__ = ('AppLoader',)
 
 
 class AppLoader(BaseLoader):

celery/loaders/base.py

@@ -21,7 +21,7 @@ from celery.utils.imports import (
     import_from_cwd, symbol_by_name, NotAPackage, find_module,
 )
 
-__all__ = ['BaseLoader']
+__all__ = ('BaseLoader',)
 
 _RACE_PROTECTION = False
 

celery/loaders/default.py

@@ -8,7 +8,7 @@ from celery.utils.collections import DictAttribute
 from celery.utils.serialization import strtobool
 from .base import BaseLoader
 
-__all__ = ['Loader', 'DEFAULT_CONFIG_MODULE']
+__all__ = ('Loader', 'DEFAULT_CONFIG_MODULE')
 
 DEFAULT_CONFIG_MODULE = 'celeryconfig'
 

celery/local.py

@@ -14,7 +14,7 @@ from importlib import import_module
 from types import ModuleType
 from .five import bytes_if_py2, items, string, string_t
 
-__all__ = ['Proxy', 'PromiseProxy', 'try_import', 'maybe_evaluate']
+__all__ = ('Proxy', 'PromiseProxy', 'try_import', 'maybe_evaluate')
 
 __module__ = __name__  # used by Proxy class body
 

celery/platforms.py

@@ -39,7 +39,7 @@ pwd = try_import('pwd')
 grp = try_import('grp')
 mputil = try_import('multiprocessing.util')
 
-__all__ = [
+__all__ = (
     'EX_OK', 'EX_FAILURE', 'EX_UNAVAILABLE', 'EX_USAGE', 'SYSTEM',
     'IS_macOS', 'IS_WINDOWS', 'SIGMAP', 'pyimplementation', 'LockFailed',
     'get_fdmax', 'Pidfile', 'create_pidlock', 'close_open_fds',
@@ -47,7 +47,7 @@ __all__ = [
     'initgroups', 'setgid', 'setuid', 'maybe_drop_privileges', 'signals',
     'signal_name', 'set_process_title', 'set_mp_process_title',
     'get_errno_name', 'ignore_errno', 'fd_by_path', 'isatty',
-]
+)
 
 # exitcodes
 EX_OK = getattr(os, 'EX_OK', 0)

celery/result.py

@@ -27,10 +27,10 @@ try:
 except ImportError:
     tblib = None
 
-__all__ = [
+__all__ = (
     'ResultBase', 'AsyncResult', 'ResultSet',
     'GroupResult', 'EagerResult', 'result_from_tuple',
-]
+)
 
 E_WOULDBLOCK = """\
 Never call result.get() within a task!

celery/schedules.py

@@ -19,10 +19,10 @@ from .utils.time import (
     timezone, maybe_make_aware, ffwd, localize
 )
 
-__all__ = [
+__all__ = (
     'ParseException', 'schedule', 'crontab', 'crontab_parser',
     'maybe_schedule', 'solar',
-]
+)
 
 schedstate = namedtuple('schedstate', ('is_due', 'next'))
 

celery/security/__init__.py

@@ -24,7 +24,7 @@ configuration settings to use the auth serializer.
 Please see the configuration reference for more information.
 """
 
-__all__ = ['setup_security']
+__all__ = ('setup_security',)
 
 
 def setup_security(allowed_serializers=None, key=None, cert=None, store=None,

celery/security/certificate.py

@@ -8,7 +8,7 @@ from celery.exceptions import SecurityError
 from celery.five import values
 from .utils import crypto, reraise_errors
 
-__all__ = ['Certificate', 'CertStore', 'FSCertStore']
+__all__ = ('Certificate', 'CertStore', 'FSCertStore')
 
 
 class Certificate(object):

celery/security/key.py

@@ -4,7 +4,7 @@ from __future__ import absolute_import, unicode_literals
 from kombu.utils.encoding import ensure_bytes
 from .utils import crypto, reraise_errors
 
-__all__ = ['PrivateKey']
+__all__ = ('PrivateKey',)
 
 
 class PrivateKey(object):

celery/security/serialization.py

@@ -12,7 +12,7 @@ from .certificate import Certificate, FSCertStore
 from .key import PrivateKey
 from .utils import reraise_errors
 
-__all__ = ['SecureSerializer', 'register_auth']
+__all__ = ('SecureSerializer', 'register_auth')
 
 
 class SecureSerializer(object):

celery/security/utils.py

@@ -10,7 +10,7 @@ try:
 except ImportError:  # pragma: no cover
     crypto = None    # noqa
 
-__all__ = ['reraise_errors']
+__all__ = ('reraise_errors',)
 
 
 @contextmanager

celery/signals.py

@@ -14,7 +14,7 @@ functions are called whenever a signal is called.
 from __future__ import absolute_import, unicode_literals
 from .utils.dispatch import Signal
 
-__all__ = [
+__all__ = (
     'before_task_publish', 'after_task_publish',
     'task_prerun', 'task_postrun', 'task_success',
     'task_retry', 'task_failure', 'task_revoked', 'celeryd_init',
@@ -24,7 +24,7 @@ __all__ = [
     'beat_init', 'beat_embedded_init', 'heartbeat_sent',
     'eventlet_pool_started', 'eventlet_pool_preshutdown',
     'eventlet_pool_postshutdown', 'eventlet_pool_apply',
-]
+)
 
 # - Task
 before_task_publish = Signal(

celery/states.py

@@ -54,11 +54,11 @@ Misc
 """
 from __future__ import absolute_import, unicode_literals
 
-__all__ = [
+__all__ = (
     'PENDING', 'RECEIVED', 'STARTED', 'SUCCESS', 'FAILURE',
     'REVOKED', 'RETRY', 'IGNORED', 'READY_STATES', 'UNREADY_STATES',
     'EXCEPTION_STATES', 'PROPAGATE_STATES', 'precedence', 'state',
-]
+)
 
 #: State precedence.
 #: None represents the precedence of an unknown state.

celery/task/__init__.py

@@ -10,10 +10,10 @@ from __future__ import absolute_import, unicode_literals
 from celery._state import current_app, current_task as current
 from celery.local import LazyModule, Proxy, recreate_module
 
-__all__ = [
+__all__ = (
     'BaseTask', 'Task', 'PeriodicTask', 'task', 'periodic_task',
     'group', 'chord', 'subtask',
-]
+)
 
 
 STATICA_HACK = True

celery/task/base.py

@@ -15,7 +15,7 @@ from celery.local import Proxy, class_property, reclassmethod
 from celery.schedules import maybe_schedule
 from celery.utils.log import get_task_logger
 
-__all__ = ['Context', 'Task', 'TaskType', 'PeriodicTask', 'task']
+__all__ = ('Context', 'Task', 'TaskType', 'PeriodicTask', 'task')
 
 #: list of methods that must be classmethods in the old API.
 _COMPAT_CLASSMETHODS = (

celery/utils/__init__.py

@@ -9,8 +9,8 @@ import sys
 from .functional import memoize  # noqa
 from .nodenames import worker_direct, nodename, nodesplit
 
-__all__ = ['worker_direct', 'gen_task_name', 'nodename', 'nodesplit',
-           'cached_property', 'uuid']
+__all__ = ('worker_direct', 'gen_task_name', 'nodename', 'nodesplit',
+           'cached_property', 'uuid')
 
 PY3 = sys.version_info[0] == 3
 

celery/utils/abstract.py

@@ -5,7 +5,7 @@ from abc import ABCMeta, abstractmethod, abstractproperty
 from collections import Callable
 from celery.five import with_metaclass
 
-__all__ = ['CallableTask', 'CallableSignature']
+__all__ = ('CallableTask', 'CallableSignature')
 
 
 def _hasattr(C, attr):

celery/utils/collections.py

@@ -30,12 +30,12 @@ except ImportError:
         pass
     LazySettings = LazyObject  # noqa
 
-__all__ = [
+__all__ = (
     'AttributeDictMixin', 'AttributeDict', 'BufferMap', 'ChainMap',
     'ConfigurationView', 'DictAttribute', 'Evictable',
     'LimitedSet', 'Messagebuffer', 'OrderedDict',
     'force_mapping', 'lpmerge',
-]
+)
 
 PY3 = sys.version_info[0] >= 3
 

celery/utils/debug.py

@@ -18,10 +18,10 @@ try:
 except ImportError:
     Process = None  # noqa
 
-__all__ = [
+__all__ = (
     'blockdetection', 'sample_mem', 'memdump', 'sample',
     'humanbytes', 'mem_rss', 'ps', 'cry',
-]
+)
 
 UNITS = (
     (2 ** 40.0, 'TB'),

celery/utils/deprecated.py

@@ -5,7 +5,7 @@ import warnings
 from vine.utils import wraps
 from celery.exceptions import CPendingDeprecationWarning, CDeprecationWarning
 
-__all__ = ['Callable', 'Property', 'warn']
+__all__ = ('Callable', 'Property', 'warn')
 
 
 PENDING_DEPRECATION_FMT = """

celery/utils/dispatch/__init__.py

@@ -3,4 +3,4 @@
 from __future__ import absolute_import, unicode_literals
 from .signal import Signal
 
-__all__ = ['Signal']
+__all__ = ('Signal',)

celery/utils/dispatch/signal.py

@@ -17,7 +17,7 @@ try:
 except ImportError:
     from .weakref_backports import WeakMethod  # noqa
 
-__all__ = ['Signal']
+__all__ = ('Signal',)
 
 PY3 = sys.version_info[0] >= 3
 logger = get_logger(__name__)

celery/utils/functional.py

@@ -16,12 +16,12 @@ from vine import promise
 
 from celery.five import UserList, getfullargspec, range
 
-__all__ = [
+__all__ = (
     'LRUCache', 'is_list', 'maybe_list', 'memoize', 'mlazy', 'noop',
     'first', 'firstmethod', 'chunks', 'padlist', 'mattrgetter', 'uniq',
     'regen', 'dictfilter', 'lazy', 'maybe_evaluate', 'head_from_fun',
     'maybe', 'fun_accepts_kwargs',
-]
+)
 
 IS_PY3 = sys.version_info[0] == 3
 

celery/utils/graph.py

@@ -6,7 +6,7 @@ from textwrap import dedent
 from kombu.utils.encoding import safe_str, bytes_to_str
 from celery.five import items, python_2_unicode_compatible
 
-__all__ = ['DOT', 'CycleError', 'DependencyGraph', 'GraphFormatter']
+__all__ = ('DOT', 'CycleError', 'DependencyGraph', 'GraphFormatter')
 
 
 class DOT:

celery/utils/imports.py

@@ -16,11 +16,11 @@ from celery.five import reload
 #: task to be that of ``App.main``.
 MP_MAIN_FILE = os.environ.get('MP_MAIN_FILE')
 
-__all__ = [
+__all__ = (
     'NotAPackage', 'qualname', 'instantiate', 'symbol_by_name',
     'cwd_in_path', 'find_module', 'import_from_cwd',
     'reload_from_cwd', 'module_file', 'gen_task_name',
-]
+)
 
 
 class NotAPackage(Exception):

celery/utils/iso8601.py

@@ -37,7 +37,7 @@ import re
 from datetime import datetime
 from pytz import FixedOffset
 
-__all__ = ['parse_iso8601']
+__all__ = ('parse_iso8601',)
 
 # Adapted from http://delete.me.uk/2005/03/iso8601.html
 ISO8601_REGEX = re.compile(

celery/utils/log.py

@@ -18,12 +18,12 @@ from celery.five import string_t, text_t
 
 from .term import colored
 
-__all__ = [
+__all__ = (
     'ColorFormatter', 'LoggingProxy', 'base_logger',
     'set_in_sighandler', 'in_sighandler', 'get_logger',
     'get_task_logger', 'mlevel',
     'get_multiprocessing_logger', 'reset_multiprocessing_logger',
-]
+)
 
 _process_aware = False
 _in_sighandler = False