| Commit message (Collapse) | Author | Age | Files | Lines |
|---|
| |\ |
|
| | |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| | |
* support JSON.MERGE Command
* linters
* try with abc instead person
* change @skip_ifmodversion_lt to latest ReJSON 2.4.7
* change version
* fix test
* linters
* add async test
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
| | | |
|
| |/ |
|
| |
|
|
|
|
|
|
|
|
|
|
| |
SentinelManagedConnection.read_response() (#2756)
* Increase timeout for a test which would hang completely if failing.
Timeouts in virtualized CI backends can occasionally fail if too short.
* add "disconnect_on_error" argument to SentinelManagedConnection
* update Changes
* lint
|
| | |
|
| |
|
|
|
|
|
|
|
| |
* Fix xadd allow non negative maxlen
* Update change log
---------
Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
|
| | |
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* Add client no-touch
* Update redis/commands/core.py
Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
* Update test_commands.py
Improve test_client_no_touch
* Update test_commands.py
Add async version test case
* Chore remove whitespace
Oops
---------
Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
|
| |
|
|
|
|
|
|
|
|
|
|
|
| |
* Add regression tests and fixes for issue #1128
* Fix tests for resumable read_response to use "disconnect_on_error"
* undo prevision fix attempts in async client and cluster
* re-enable cluster test
* Suggestions from code review
* Add CHANGES
|
| | |
|
| | |
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* feat: adding support for cluster myshardid
* lint fix
* fix: comment fix and async test
* fix: adding version check
* fix lint:
* linters
---------
Co-authored-by: Anuragkillswitch <70265851+Anuragkillswitch@users.noreply.github.com>
Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
Co-authored-by: dvora-h <dvora.heller@redis.com>
|
| |
|
| |
Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* Use provided redis address. Bind to IPv4
* Add missing "await" and perform the correct test for pipe eimpty
* Wait for a send event, rather than rely on sleep time. Excpect cancel errors.
* set delay to 0 except for operation we want to cancel
This speeds up the unit tests considerably by eliminating unnecessary delay.
* Release resources in test
* Fix cluster test to use address_remap and multiple proxies.
* Use context manager to manage DelayProxy
* Mark failing pipeline tests
* lint
* Use a common "master_host" test fixture
|
| | |
|
| |
|
| |
Co-authored-by: Nick Gerow <nick.gerow@enlightedinc.com>
|
| | |
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* add cluster "host_port_remap" feature for asyncio.RedisCluster
* Add a unittest for asyncio.RedisCluster
* Add host_port_remap to _sync_ RedisCluster
* add synchronous tests
* rename arg to `address_remap` and take and return an address tuple.
* Add class documentation
* Add CHANGES
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
When the disconnect() function is called twice in parallel it is possible that
one thread deletes the self._sock reference, while the other thread will
attempt to call .close() on it, leading to an AttributeError.
This situation can routinely be encountered by closing the connection in a
PubSubWorkerThread error handler in a blocking thread (ie. with
sleep_time==None), and then calling .close() on the PubSub object.
The main thread will then run into the disconnect() function, and the listener
thread is woken up by the closure and will race into the disconnect()
function, too.
This can be fixed easily by copying the object reference before doing the
None-check, similar to what we do in the redis.client.close() function.
|
| |
|
|
|
| |
* Fix `ClusterCommandProtocol` not itself being marked as a protocol
* Update CHANGES
|
| |
|
|
|
|
|
|
|
| |
* add withscores to zrevrank
* change 0 -> 2
* fix errors
* split test
|
| |
|
|
|
|
|
|
|
| |
* return response in case of KeyError
* fix code linters error
* fix linters 2
* fix linters 3
|
| |
|
|
|
|
|
| |
Make MasterNotFoundError exception more precise in the case of
ConnectionError and TimeoutError to help the user to identify
configuration errors
Co-authored-by: Marc Schöchlin <marc.schoechlin@flipapp.de>
|
| | |
|
| |
|
|
|
|
|
| |
In the execute_command of the async Sentinel, the once flag was being
used incorrectly, with its meaning inverted. To fix we just needed to invert
the if and else bodies. This isn't being caught by the tests currently
because the tests of commands that use this flag do not check their
results/effects (for example the "test_ckquorum" test).
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
* update vss docs
* add embeddings creation and storage examples
* update based on feedback
* fix version and link
* include more realistic search examples and clean up indices
* completely remove initial cap reference
---------
Co-authored-by: Chayim <chayim@users.noreply.github.com>
|
| |
|
| |
When creating index, fields should be passed inside an iterable (e.g. list or tuple)
|
| | |
|
| |
|
|
|
|
|
| |
480253037afe4c12e38a0f98cadd3019a3724254 made async-timeout required
only on Python 3.11.2 and earlier. However, according to PEP-508,
python_version marker is compared to first two numbers of Python version
tuple - so it will evaluate to True also on 3.11.3, and install a
package as a dependency.
|
| | |
|
| | |
|
| |
|
|
|
| |
Co-authored-by: James R T <jamestiotio@gmail.com>
Co-authored-by: dvora-h <dvora.heller@redis.com>
|
| | |
|
| | |
|
| | |
|
| |
|
|
|
|
|
|
|
|
|
|
| |
There's an issue in asyncio's timeout lib before 3.11.3 that causes
async calls to raise `CancelledError`.
This is a cpython issue that was fixed in this commit [1] and
cherry-picked to previous versions, meaning 3.11.3 will work correctly.
Check [2] for more info.
[1] https://github.com/python/cpython/commit/04adf2df395ded81922c71360a5d66b597471e49
[2] https://github.com/redis/redis-py/issues/2633
|
| | |
|
