summaryrefslogtreecommitdiff
path: root/redis
Commit message (Collapse)AuthorAgeFilesLines
...
* async_cluster: fix max_connections/ssl & improve args (#2217)Utkarsh Gupta2022-07-273-183/+202
| | | | | | | | | | | | | | | | | | | | | | * async_cluster: fix max_connections/ssl & improve args - set proper connection_class if ssl = True - pass max_connections/connection_class to ClusterNode - recreate startup_nodes to properly initialize - pass parser_class to Connection instead of changing it in on_connect - only pass redis_connect_func if read_from_replicas = True - add connection_error_retry_attempts parameter - skip is_connected check in acquire_connection as it is already checked in send_packed_command BREAKING: - RedisCluster args except host & port are kw-only now - RedisCluster will no longer accept unknown arguments - RedisCluster will no longer accept url as an argument. Use RedisCluster.from_url - RedisCluster.require_full_coverage defaults to True - ClusterNode args except host, port, & server_type are kw-only now * async_cluster: remove kw-only requirement from client Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
* cleaning up the readme and moving docs into readthedocs (#2291)Chayim2022-07-271-0/+2
| | | | | * cleaning up the readme and moving docs into readthedocs * examples at the end as per pr comments
* Graph - add counters for removed labels and properties (#2292)DvirDukhan2022-07-261-0/+24
| | | | | | | | | | | | | * grpah - add counters for removed labels and properties * added mock graph result set statistics * docstrings for graph result set statistics * format * isort * moved docstrings into functions
* Fix: `start_id` type for `XAUTOCLAIM` (#2257)Антон Безденежных2022-07-241-1/+1
| | | | | | | * Changed start_id type for xautoclaim * Added to changes Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
* Remove verbose logging from `redis-py/redis/cluster.py` (#2238)Nial Daly2022-07-241-56/+7
| | | | | | | | | | | | | | | | | | | | | | | | | | | * removed the logging module and its corresponding methods * updated CHANGES * except block for RedisClusterException and BusyLoadingError removed * removed unused import (redis.exceptions.BusyLoadingError) * empty commit to re-trigger Actions workflow * replaced BaseException with Exception * empty commit to re-trigger Actions workflow * empty commit to re-trigger Actions workflow * redundant logic removed * re-trigger pipeline * reverted changes * re-trigger pipeline * except logic changed
* Add support for TIMESERIES 1.8 (#2296)dvora-h2022-07-242-279/+407
| | | | | | | | | | | | | | | * Add support for timeseries 1.8 * fix info * linters * linters * fix info test * type hints * linters
* async_cluster: fix concurrent pipeline (#2280)Utkarsh Gupta2022-07-241-9/+9
| | | - each pipeline should create separate stacks for each node
* docs: Fix a few typos (#2274)Tim Gates2022-07-243-3/+3
| | | | | | | | | | | | | | | | | * docs: Fix a few typos There are small typos in: - redis/cluster.py - redis/commands/core.py - redis/ocsp.py - tests/test_cluster.py Fixes: - Should read `validity` rather than `valididy`. - Should read `reinitialize` rather than `reinitilize`. - Should read `farthest` rather than `farest`. - Should read `commands` rather than `comamnds`. * Update core.py
* Fix crash: key expire while search (#2270)dvora-h2022-07-241-1/+1
| | | | | * fix expire while search * sleep
* fix: workaround asyncio bug on connection reset by peer (#2259)Mehdi ABAAKOUK2022-07-241-1/+10
| | | Fixes #2237
* fix is_connected (#2278)dvora-h2022-07-211-1/+1
|
* Use retry mechanism in async version of Connection objects (#2271)szumka2022-07-212-2/+12
|
* Fix backwards compatibility from 4.3.2 (#2254)dvora-h2022-06-271-1/+0
|
* Fix `XAUTOCLAIM` to return the full response (#2252)dvora-h2022-06-271-1/+2
| | | | | * fix parse_xautoclaim * linters
* commands/cluster: use pipeline to execute split commands (#2230)Utkarsh Gupta2022-06-275-153/+151
| | | | | | - allow passing target_nodes to pipeline commands - move READ_COMMANDS to commands/cluster to avoid import cycle - add types to list_or_args
* Changed dynamic_startup_nodes default value to 'True' to prevent breaking ↵Bar Shaul2022-06-271-5/+5
| | | | backward compatibility (#2251)
* Added dynamic_startup_nodes configuration to RedisCluster. (#2244)Bar Shaul2022-06-231-2/+15
| | | | | | | | | * Added dynamic_startup_nodes configuration to RedisCluster. By default, uses only the initial passed startup nodes to refresh the cluster topology. If set to true, sets the startup nodes to all of the discovered nodes. * Added RedisCluster specific options to the README file and updated CHANGES * Fixed timeout_error_topology_refresh test Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
* Docs: Add a note about client_setname and client_name difference (#2247)Paweł Srokosz2022-06-231-0/+6
|
* Reuse the old nodes' connections when a cluster topology refresh is being ↵Bar Shaul2022-06-231-11/+26
| | | | | | | | | | | | | done (#2235) * A fix was made to reuse the old nodes' connections when a cluster topology refresh is being done * Fixed RedisCluster to immediately raise AuthenticationError * Updated CHANGES * Fixed cluster async bgsave test to ignore "bgsave already in progress" error * Fixed linters
* Fix retries in async mode (#2180)Eric Lemoine2022-06-195-6/+48
| | | | | | | | | * Avoid mutating a global retry_on_error list * Make retries config consistent in sync and async * Fix async retries * Add new TestConnectionConstructorWithRetry tests
* async_cluster: fix simultaneous initialize (#2231)Utkarsh Gupta2022-06-191-2/+2
| | | - close startup_nodes too during client.close(), in case they are different
* Uppercase commands in CommandsParser.get_keys (#2236)Falk2022-06-191-2/+2
|
* Fix Lock crash, and versioning 4.3.3 (#2210)v4.3.3dvora-h2022-06-021-1/+0
| | | | | * fix lock * v4.3.3
* async_cluster: improve docs (#2208)Utkarsh Gupta2022-06-021-36/+37
| | | | - move response_callbacks kwarg inside __init__ to hide it from docs - use :member-order: bysource to group similar commands together
* SHUTDOWN - add support for the new NOW, FORCE and ABORT modifiers (#2150)dvora-h2022-06-011-6/+37
| | | | | | | | | | | | | | | * add support for NOW, FORCE and ABORT modifiers * linters * test * linters * test params * fix tests Co-authored-by: Chayim <chayim@users.noreply.github.com>
* Made sync lock consistent and added types to it (#2137)Anas2022-06-014-25/+60
| | | | | | | | | * Made sync lock consistent and added types to it * Made linters happy * Fixed cluster client lock signature Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
* async_cluster: optimisations (#2205)Utkarsh Gupta2022-06-012-91/+97
| | | | | | | | | | - return true from execute_pipeline if there are any errors - use todo list to speedup retries - store initialisation node in CommandsParser object - add sync context manager for pipeline - use if/else instead of try/except - make command a function argument in _determine_nodes & _determine_slot - add async cluster pipeline benchmark script
* Add `query_params` to FT.PROFILE (#2198)dvora-h2022-06-011-11/+19
| | | | | | | * ft.profile query_params * fix pr comments * type hints
* Fix tests for Redis 7 (#2182)dvora-h2022-05-312-1/+2
| | | | | * fix tests * async
* Add default None for maxlen at xtrim command (#2188)mfgnik2022-05-311-1/+4
| | | | | | | | * Add default None for maxlen at xtrim command * Fix linter Co-authored-by: Mikhail Fedorov <mfgnik@yandex.team.ru> Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
* async_cluster: add pipeline support (#2199)Utkarsh Gupta2022-05-302-52/+390
| | | Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
* update black to 22.3.0 (#2171)Utkarsh Gupta2022-05-3010-175/+44
|
* async_cluster: add/update typing (#2195)Utkarsh Gupta2022-05-305-90/+114
| | | | | | | * async_cluster: add/update typing * async_cluster: update cleanup_kwargs with kwargs from async Connection * async_cluster: properly remove old nodes
* Fix Missing ClusterPipeline Lock (#2190)Greg Melton2022-05-303-0/+7
| | | | | | | | | | | * ClusterPipeline needs to initialize self._lock, otherwise a class instance will fail when calling get_redis_connection on the node * fix bad lint picked up from master * added change to CHANGES file * force ci build again * force ci build again
* fix: changed list type to single element type (#2203)Oleg A2022-05-301-7/+7
|
* set default response_callbacks to redis.asyncio.cluster.ClusterNode (#2201)rapidia2022-05-301-1/+1
| | | | | | | | | * set default response_callbacks to redis.asyncio.cluster.ClusterNode * add test case for ClusterNode class * fix lint error * merge test case into `test_startup_nodes`
* Support CF.MEXISTS + Clean bf/commands.py (#2184)Avital Fine2022-05-231-61/+40
| | | | | | | * Support CF.MEXISTS * Clean bf/commands.py Co-authored-by: dvora-h <67596500+dvora-h@users.noreply.github.com>
* Fix Linting and Test Failures (#2191)Greg Melton2022-05-231-1/+1
| | | | | | | * force triggering pr pipeline * fix lint error * https://github.com/RedisJSON/RedisJSON/pull/721 no longer clears strings or boolean scalars
* Fix modules links to https://redis.io/commands/ (#2185)Avital Fine2022-05-175-104/+96
|
* fix incorrect test (#2177)Avital Fine2022-05-161-3/+5
| | | | | * fix incorrect test * Fix types
* fix import (#2175)v4.3.1dvora-h2022-05-091-1/+2
|
* Get command keys for subcommands (#2170)dvora-h2022-05-083-1/+30
| | | | | * parse subcommands * fix tests
* Add support for CLUSTER SHARDS (#2151)dvora-h2022-05-082-1/+33
| | | | | | | | | * Add support for CLUSTER SHARDS * linters * add docstring * linters
* Add support for COMMAND LIST (#2149)dvora-h2022-05-081-0/+28
| | | | | * Add support for COMMAND LIST * style change
* Add Async RedisCluster (#2099)Utkarsh Gupta2022-05-0812-378/+1790
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | * Copy Cluster Client, Commands, Commands Parser, Tests for asyncio * Async Cluster Tests: Async/Await * Add Async RedisCluster * cluster: use ERRORS_ALLOW_RETRY from self.__class__ * async_cluster: rework redis_connection, initialize, & close - move redis_connection from NodesManager to ClusterNode & handle all related logic in ClusterNode class - use Locks while initializing or closing - in case of error, close connections instead of instantly reinitializing - create ResourceWarning instead of manually deleting client object - use asyncio.gather to run commands/initialize/close in parallel - inline single use functions - fix test_acl_log for py3.6 * async_cluster: add types * async_cluster: add docs * docs: update sphinx & add sphinx_autodoc_typehints * async_cluster: move TargetNodesT to cluster module * async_cluster/commands: inherit commands from sync class if possible * async_cluster: add benchmark script with aredis & aioredis-cluster * async_cluster: remove logging * async_cluster: inline functions * async_cluster: manage Connection instead of Redis Client * async_cluster/commands: optimize parser * async_cluster: use ensure_future & generators for gather * async_conn: optimize * async_cluster: optimize determine_slot * async_cluster: optimize determine_nodes * async_cluster/parser: optimize _get_moveable_keys * async_cluster: inlined check_slots_coverage * async_cluster: update docstrings * async_cluster: add concurrent test & use read_response/_update_moved_slots without lock Co-authored-by: Chayim <chayim@users.noreply.github.com>
* Replace OSError exceptions from `can_read` with `redis.ConnectionError` (#2140)Kristján Valur Jónsson2022-05-082-2/+14
| | | | | | | * Replace OSError exceptions from `can_read` with `redis.ConnectionError` * Fix formatting * Revert unintended formatting change
* ACL SETUSER - add selectors and key based permissions (#2161)dvora-h2022-05-032-4/+41
| | | | | | | * acl setuser * async tests Co-authored-by: Chayim <chayim@users.noreply.github.com>
* Add support for redis 7 streams features (#2157)dvora-h2022-05-031-1/+9
| | | | | | | | | | | | | * xadd * streams redis 7 * linters * test xinfo stream * test xinfo stream * test xclaim
* Async Connection: Allow `PubSub.run()` without previous `subscribe()` (#2148)Kristján Valur Jónsson2022-05-021-3/+12
|
* Fix incorrect return annotation in asyncio.lock (#2155)Jelle Zijlstra2022-05-021-3/+3
| | | | | NoReturn should be used only when the function never returns. In this case, the awaitable returns None if releasing the lock succeeds, so `Awaitable[None]` is right. Noticed this while reviewing python/typeshed#7676
View Lorry Controller Status