diff options
author | David Gilman <dgilman@aidentified.com> | 2022-12-14 04:18:41 -0500 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-12-14 11:18:41 +0200 |
commit | 3fb65de645bf4dd1beb8e893bdaa2c4766bbd1fa (patch) | |
tree | d5074882a70d502c91122f252788f27f1670901e /redis/asyncio | |
parent | 6487f9555ba2d08083a081df9b65b642427361fa (diff) | |
download | redis-py-3fb65de645bf4dd1beb8e893bdaa2c4766bbd1fa.tar.gz |
Combine auto-concatenated strings (#2482)
Diffstat (limited to 'redis/asyncio')
-rw-r--r-- | redis/asyncio/client.py | 6 | ||||
-rw-r--r-- | redis/asyncio/lock.py | 6 |
2 files changed, 6 insertions, 6 deletions
diff --git a/redis/asyncio/client.py b/redis/asyncio/client.py index abe7d67..5a2c496 100644 --- a/redis/asyncio/client.py +++ b/redis/asyncio/client.py @@ -1132,7 +1132,7 @@ class Pipeline(Redis): # lgtm [py/init-calls-subclass] raise RedisError("Cannot issue nested calls to MULTI") if self.command_stack: raise RedisError( - "Commands without an initial WATCH have already " "been issued" + "Commands without an initial WATCH have already been issued" ) self.explicit_transaction = True @@ -1157,7 +1157,7 @@ class Pipeline(Redis): # lgtm [py/init-calls-subclass] if self.watching: await self.reset() raise WatchError( - "A ConnectionError occurred on while " "watching one or more keys" + "A ConnectionError occurred on while watching one or more keys" ) # if retry_on_timeout is not set, or the error is not # a TimeoutError, raise it @@ -1345,7 +1345,7 @@ class Pipeline(Redis): # lgtm [py/init-calls-subclass] # indicates the user should retry this transaction. if self.watching: raise WatchError( - "A ConnectionError occurred on while " "watching one or more keys" + "A ConnectionError occurred on while watching one or more keys" ) # if retry_on_timeout is not set, or the error is not # a TimeoutError, raise it diff --git a/redis/asyncio/lock.py b/redis/asyncio/lock.py index 7f45c8b..2f78d69 100644 --- a/redis/asyncio/lock.py +++ b/redis/asyncio/lock.py @@ -259,7 +259,7 @@ class Lock: keys=[self.name], args=[expected_token], client=self.redis ) ): - raise LockNotOwnedError("Cannot release a lock" " that's no longer owned") + raise LockNotOwnedError("Cannot release a lock that's no longer owned") def extend( self, additional_time: float, replace_ttl: bool = False @@ -289,7 +289,7 @@ class Lock: client=self.redis, ) ): - raise LockNotOwnedError("Cannot extend a lock that's" " no longer owned") + raise LockNotOwnedError("Cannot extend a lock that's no longer owned") return True def reacquire(self) -> Awaitable[bool]: @@ -309,5 +309,5 @@ class Lock: keys=[self.name], args=[self.local.token, timeout], client=self.redis ) ): - raise LockNotOwnedError("Cannot reacquire a lock that's" " no longer owned") + raise LockNotOwnedError("Cannot reacquire a lock that's no longer owned") return True |