From e8c60223bf1568aa60abc8800fdae3414c8c28d3 Mon Sep 17 00:00:00 2001
From: Asif Saifuddin Auvi <auvipy@gmail.com>
Date: Wed, 27 Jun 2018 11:16:46 +0600
Subject: [PATCH 1/6] renamed banckend.async to asynchronous
---
celery/backends/{async.py => asynchronous.py} | 0
1 file changed, 0 insertions(+), 0 deletions(-)
rename celery/backends/{async.py => asynchronous.py} (100%)
diff --git a/celery/backends/async.py b/celery/backends/asynchronous.py
similarity index 100%
rename from celery/backends/async.py
rename to celery/backends/asynchronous.py
From d737dec3c943632f21f73a2235409c29e3fe63e3 Mon Sep 17 00:00:00 2001
From: Asif Saifuddin Auvi <auvipy@gmail.com>
Date: Wed, 27 Jun 2018 11:19:34 +0600
Subject: [PATCH 2/6] adjust redis imports of async
---
celery/backends/redis.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/celery/backends/redis.py b/celery/backends/redis.py
index 012db0f36e..8ad8267d6c 100644
--- a/celery/backends/redis.py
+++ b/celery/backends/redis.py
@@ -19,7 +19,7 @@
from celery.utils.log import get_logger
from celery.utils.time import humanize_seconds
-from . import async, base
+from . import asynchronous, base
try:
from urllib.parse import unquote
@@ -74,7 +74,7 @@
logger = get_logger(__name__)
-class ResultConsumer(async.BaseResultConsumer):
+class ResultConsumer(asynchronous.BaseResultConsumer):
_pubsub = None
def __init__(self, *args, **kwargs):
@@ -138,7 +138,7 @@ def cancel_for(self, task_id):
self._pubsub.unsubscribe(key)
-class RedisBackend(base.BaseKeyValueStoreBackend, async.AsyncBackendMixin):
+class RedisBackend(base.BaseKeyValueStoreBackend, asynchronous.AsyncBackendMixin):
"""Redis task result store."""
ResultConsumer = ResultConsumer
From cdd7363056778a4735a2e08a0b9787fb4bea4311 Mon Sep 17 00:00:00 2001
From: Asif Saifuddin Auvi <auvipy@gmail.com>
Date: Wed, 27 Jun 2018 11:27:12 +0600
Subject: [PATCH 3/6] adjust imports of async
---
celery/backends/rpc.py | 2 +-
t/unit/backends/test_redis.py | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/celery/backends/rpc.py b/celery/backends/rpc.py
index 6e31cef75e..5e6e407ce6 100644
--- a/celery/backends/rpc.py
+++ b/celery/backends/rpc.py
@@ -17,7 +17,7 @@
from celery.five import items, range
from . import base
-from .async import AsyncBackendMixin, BaseResultConsumer
+from .asynchronous import AsyncBackendMixin, BaseResultConsumer
__all__ = ('BacklogLimitExceeded', 'RPCBackend')
diff --git a/t/unit/backends/test_redis.py b/t/unit/backends/test_redis.py
index 166aa0dc34..6a7dbbd501 100644
--- a/t/unit/backends/test_redis.py
+++ b/t/unit/backends/test_redis.py
@@ -146,7 +146,7 @@ class _RedisBackend(RedisBackend):
def get_consumer(self):
return self.get_backend().result_consumer
- @patch('celery.backends.async.BaseResultConsumer.on_after_fork')
+ @patch('celery.backends.asynchronous.BaseResultConsumer.on_after_fork')
def test_on_after_fork(self, parent_method):
consumer = self.get_consumer()
consumer.start('none')
@@ -172,7 +172,7 @@ def test_on_after_fork(self, parent_method):
parent_method.assert_called_once()
@patch('celery.backends.redis.ResultConsumer.cancel_for')
- @patch('celery.backends.async.BaseResultConsumer.on_state_change')
+ @patch('celery.backends.asynchronous.BaseResultConsumer.on_state_change')
def test_on_state_change(self, parent_method, cancel_for):
consumer = self.get_consumer()
meta = {'task_id': 'testing', 'status': states.SUCCESS}
From 989abf86c6b54d805c7dcdb56feef1d6d9efd036 Mon Sep 17 00:00:00 2001
From: Asif Saifuddin Auvi <auvipy@gmail.com>
Date: Wed, 27 Jun 2018 12:03:02 +0600
Subject: [PATCH 4/6] import style adjust
---
celery/backends/redis.py | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/celery/backends/redis.py b/celery/backends/redis.py
index 8ad8267d6c..6c311d8273 100644
--- a/celery/backends/redis.py
+++ b/celery/backends/redis.py
@@ -19,7 +19,8 @@
from celery.utils.log import get_logger
from celery.utils.time import humanize_seconds
-from . import asynchronous, base
+from .asynchronous import AsyncBackendMixin, BaseResultConsumer
+from .base import BaseKeyValueStoreBackend
try:
from urllib.parse import unquote
@@ -74,7 +75,7 @@
logger = get_logger(__name__)
-class ResultConsumer(asynchronous.BaseResultConsumer):
+class ResultConsumer(BaseResultConsumer):
_pubsub = None
def __init__(self, *args, **kwargs):
@@ -138,7 +139,7 @@ def cancel_for(self, task_id):
self._pubsub.unsubscribe(key)
-class RedisBackend(base.BaseKeyValueStoreBackend, asynchronous.AsyncBackendMixin):
+class RedisBackend(BaseKeyValueStoreBackend, AsyncBackendMixin):
"""Redis task result store."""
ResultConsumer = ResultConsumer
From ce088a3506cf369a4db6493fa29a556c8f7a45ac Mon Sep 17 00:00:00 2001
From: Asif Saifuddin Auvi <auvipy@gmail.com>
Date: Sun, 8 Jul 2018 14:08:44 +0600
Subject: [PATCH 5/6] renamed doc from async to asynchronous
---
.../{celery.backends.async.rst => celery.backends.asynchronous.rst} | 0
1 file changed, 0 insertions(+), 0 deletions(-)
rename docs/internals/reference/{celery.backends.async.rst => celery.backends.asynchronous.rst} (100%)
diff --git a/docs/internals/reference/celery.backends.async.rst b/docs/internals/reference/celery.backends.asynchronous.rst
similarity index 100%
rename from docs/internals/reference/celery.backends.async.rst
rename to docs/internals/reference/celery.backends.asynchronous.rst
From 86dff1a7d8867b5b7762cc540f6e3650d7d3e4b8 Mon Sep 17 00:00:00 2001
From: Asif Saifuddin Auvi <auvipy@gmail.com>
Date: Sun, 8 Jul 2018 14:11:49 +0600
Subject: [PATCH 6/6] renamed doc contents from async to asynchronous
---
docs/internals/reference/celery.backends.asynchronous.rst | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/docs/internals/reference/celery.backends.asynchronous.rst b/docs/internals/reference/celery.backends.asynchronous.rst
index 03d10feb33..fef524294e 100644
--- a/docs/internals/reference/celery.backends.asynchronous.rst
+++ b/docs/internals/reference/celery.backends.asynchronous.rst
@@ -1,12 +1,12 @@
=====================================
- ``celery.backends.async``
+ ``celery.backends.asynchronous``
=====================================
.. contents::
:local:
-.. currentmodule:: celery.backends.async
+.. currentmodule:: celery.backends.asynchronous
-.. automodule:: celery.backends.async
+.. automodule:: celery.backends.asynchronous
:members:
:undoc-members: