Browse Source

Fix typos

pull/7041/head
Kian-Meng, Ang 10 months ago committed by Asif Saif Uddin
parent
commit
5d68d781de
  1. 2
      celery/app/autoretry.py
  2. 4
      celery/concurrency/asynpool.py
  3. 2
      celery/contrib/pytest.py
  4. 2
      celery/loaders/base.py
  5. 2
      celery/utils/functional.py
  6. 4
      celery/utils/text.py
  7. 2
      celery/utils/threads.py
  8. 2
      docker/Dockerfile
  9. 2
      docs/history/changelog-4.4.rst
  10. 2
      docs/history/whatsnew-3.0.rst
  11. 2
      docs/history/whatsnew-4.4.rst
  12. 2
      extra/generic-init.d/celerybeat
  13. 2
      t/unit/backends/test_redis.py
  14. 2
      t/unit/tasks/test_canvas.py
  15. 2
      t/unit/utils/test_collections.py
  16. 2
      t/unit/worker/test_worker.py

2
celery/app/autoretry.py

@ -33,7 +33,7 @@ def add_autoretry_behaviour(task, **options):
try:
return task._orig_run(*args, **kwargs)
except Ignore:
# If Ignore signal occures task shouldn't be retried,
# If Ignore signal occurs task shouldn't be retried,
# even if it suits autoretry_for list
raise
except Retry:

4
celery/concurrency/asynpool.py

@ -1068,7 +1068,7 @@ class AsynPool(_pool.Pool):
if owner is None)
def on_grow(self, n):
"""Grow the pool by ``n`` proceses."""
"""Grow the pool by ``n`` processes."""
diff = max(self._processes - len(self._queues), 0)
if diff:
self._queues.update({
@ -1248,7 +1248,7 @@ class AsynPool(_pool.Pool):
"""Called when a job was partially written to exited child."""
# worker terminated by signal:
# we cannot reuse the sockets again, because we don't know if
# the process wrote/read anything frmo them, and if so we cannot
# the process wrote/read anything from them, and if so we cannot
# restore the message boundaries.
if not job._accepted:
# job was not acked, so find another worker to send it to.

2
celery/contrib/pytest.py

@ -22,7 +22,7 @@ NO_WORKER = os.environ.get('NO_WORKER')
def pytest_configure(config):
"""Register additional pytest configuration."""
# add the pytest.mark.celery() marker registration to the pytest.ini [markers] section
# this prevents pytest 4.5 and newer from issueing a warning about an unknown marker
# this prevents pytest 4.5 and newer from issuing a warning about an unknown marker
# and shows helpful marker documentation when running pytest --markers.
config.addinivalue_line(
"markers", "celery(**overrides): override celery configuration for a test case"

2
celery/loaders/base.py

@ -251,7 +251,7 @@ def autodiscover_tasks(packages, related_name='tasks'):
def find_related_module(package, related_name):
"""Find module in package."""
# Django 1.7 allows for speciying a class name in INSTALLED_APPS.
# Django 1.7 allows for specifying a class name in INSTALLED_APPS.
# (Issue #2248).
try:
module = importlib.import_module(package)

2
celery/utils/functional.py

@ -1,4 +1,4 @@
"""Functional-style utilties."""
"""Functional-style utilities."""
import inspect
import sys
from collections import UserList

4
celery/utils/text.py

@ -33,13 +33,13 @@ def str_to_list(s):
def dedent_initial(s, n=4):
# type: (str, int) -> str
"""Remove identation from first line of text."""
"""Remove indentation from first line of text."""
return s[n:] if s[:n] == ' ' * n else s
def dedent(s, n=4, sep='\n'):
# type: (str, int, str) -> str
"""Remove identation."""
"""Remove indentation."""
return sep.join(dedent_initial(l) for l in s.splitlines())

2
celery/utils/threads.py

@ -282,7 +282,7 @@ class LocalManager:
def get_ident(self):
"""Return context identifier.
This is the indentifer the local objects use internally
This is the identifier the local objects use internally
for this context. You cannot override this method to change the
behavior but use it to link other context local objects (such as
SQLAlchemy's scoped sessions) to the Werkzeug locals.

2
docker/Dockerfile

@ -47,7 +47,7 @@ ENV PATH="$HOME/.pyenv/bin:$PATH"
# Copy and run setup scripts
WORKDIR $PROVISIONING
#COPY docker/scripts/install-couchbase.sh .
# Scripts will lose thier executable flags on copy. To avoid the extra instructions
# Scripts will lose their executable flags on copy. To avoid the extra instructions
# we call the shell directly.
#RUN sh install-couchbase.sh
COPY docker/scripts/create-linux-user.sh .

2
docs/history/changelog-4.4.rst

@ -25,7 +25,7 @@ an overview of what's new in Celery 4.4.
- Fix REMAP_SIGTERM=SIGQUIT not working
- (Fixes#6258) MongoDB: fix for serialization issue (#6259)
- Make use of ordered sets in Redis opt-in
- Test, CI, Docker & style and minor doc impovements.
- Test, CI, Docker & style and minor doc improvements.
4.4.6
=======

2
docs/history/whatsnew-3.0.rst

@ -524,7 +524,7 @@ stable and is now documented as part of the official API.
.. code-block:: pycon
>>> celery.control.pool_grow(2, destination=['w1.example.com'])
>>> celery.contorl.pool_shrink(2, destination=['w1.example.com'])
>>> celery.control.pool_shrink(2, destination=['w1.example.com'])
or using the :program:`celery control` command:

2
docs/history/whatsnew-4.4.rst

@ -51,7 +51,7 @@ This release has been codenamed `Cliffs <https://www.youtube.com/watch?v=i524g6J
which is one of my favorite tracks.
This release focuses on mostly bug fixes and usability improvement for developers.
Many long standing bugs, usability issues, documentation issues & minor ehancement
Many long standing bugs, usability issues, documentation issues & minor enhancement
issues were squashed which improve the overall developers experience.
Celery 4.4 is the first release to support Python 3.8 & pypy36-7.2.

2
extra/generic-init.d/celerybeat

@ -25,7 +25,7 @@ echo "celery init v${VERSION}."
if [ $(id -u) -ne 0 ]; then
echo "Error: This program can only be used by the root user."
echo " Unpriviliged users must use 'celery beat --detach'"
echo " Unprivileged users must use 'celery beat --detach'"
exit 1
fi

2
t/unit/backends/test_redis.py

@ -143,7 +143,7 @@ class Redis(mock.MockCallbacks):
def zrange(self, key, start, stop):
# `stop` is inclusive in Redis so we use `stop + 1` unless that would
# cause us to move from negative (right-most) indicies to positive
# cause us to move from negative (right-most) indices to positive
stop = stop + 1 if stop != -1 else None
return [e[1] for e in self._get_sorted_set(key)[start:stop]]

2
t/unit/tasks/test_canvas.py

@ -1251,7 +1251,7 @@ class test_chord(CanvasCase):
# When we freeze the chord, its body will be cloned and options set
top_group.freeze()
with subtests.test(
msg="Validate body group indicies count from 0 after freezing"
msg="Validate body group indices count from 0 after freezing"
):
assert all(
embedded_body_elem is not body_elem

2
t/unit/utils/test_collections.py

@ -178,7 +178,7 @@ class test_LimitedSet:
def test_purge(self):
# purge now enforces rules
# cant purge(1) now. but .purge(now=...) still works
# can't purge(1) now. but .purge(now=...) still works
s = LimitedSet(maxlen=10)
[s.add(i) for i in range(10)]
s.maxlen = 2

2
t/unit/worker/test_worker.py

@ -893,7 +893,7 @@ class test_WorkController(ConsumerCase):
worker.pool._pool.on_poll_start()
# Then: test did not raise OSError
# Given: a mock object that fakes whats required to do whats next
# Given: a mock object that fakes what's required to do what's next
proc = Mock(_sentinel_poll=42)
# When: Calling again to register with event loop ...

Loading…
Cancel
Save