summaryrefslogtreecommitdiff
path: root/t/unit
Commit message (Collapse)AuthorAgeFilesLines
* autopep8.remove-python2-supportOmer Katz2020-08-043-1/+3
|
* Remove five usage from tests.Omer Katz2020-07-2320-90/+37
|
* pyupgradeOmer Katz2020-07-1360-210/+84
|
* Add an SQS transport option for custom botocore configKrzysztof Jagiello2020-07-011-0/+13
|
* Revert incompatible changes in #1193 and additional improvements (#1211)Matus Valo2020-06-102-17/+19
| | | | | | | * Revert incompatible changes introduced in #1193 * Improved integration tests covering connection * Fix unittests on python2 + flake8 fixes
* default_channel should reconnect automatically (#1209)Matus Valo2020-06-051-0/+12
|
* reuse connectionConor Stevenson2020-06-021-0/+4
|
* set _connection in _ensure_connection (#1205)v4.6.9Conor Stevenson2020-06-011-0/+2
| | | Co-authored-by: Conor Stevenson <conor@lendingblock.com>
* Fix broken compatibility with CeleryMatus Valo2020-06-011-4/+4
|
* Ensure connection when connecting to brokerMatus Valo2020-06-012-33/+35
|
* Fix for issue #1198: Celery crashes in cases where there aren’t enough ↵Ihar Nauros2020-05-271-0/+79
| | | | | | | | | | | | | | | available workers to start acting on “in-flight” messages in the SQS queue (#1199) * Fix for the issue #1172 * Unit test for the fix relating to the issue #1172 * Fix for issue #1198: Celery crashes in cases where there aren’t enough available workers to start acting on “in-flight” messages in the SQS queue * Fix for issue #1198: fixed lint issues * Fix for issue #1198: added unit tests Co-authored-by: inauros <inauros@copyright.com>
* Fix connection imaybe_declare (#1196)Oleh Kuchuk2020-05-261-0/+15
|
* Revert "Raise RecoverableConnectionError in maybe_declare with retry on and ↵Matus Valo2020-05-251-15/+0
| | | | | dropped connection" (#1195) This reverts commit 90f51bcbbd32146998e7c7e4491150344343776b.
* Modified Mutex to use redis LuaLock implementationVinay Karanam2020-05-171-41/+32
| | | | Fixes #1190
* fix 100% cpu usage on linux while using sqsAndrii Maletskyi2020-05-151-16/+14
| | | | fix https://github.com/celery/celery/issues/5299
* Unit test for the fix relating to the issue #1172Ihar Nauros2020-04-221-1/+3
|
* Raise RecoverableConnectionError in maybe_declare with retry on and dropped ↵Oleh Kuchuk2020-04-151-0/+15
| | | | connection
* Travis CI: Fix travis validation issues (#1159)Christian Clauss2020-03-031-1/+1
| | | | | | | | * Travis CI: Fix travis validation issues * Whitespace fix for flake8 issue * Whitespace fix for flake8 issue
* #1149 Enabled ssl certificate verification against ca certificates when ↵Piyush Agarwal2020-02-281-0/+9
| | | | | | | | amqps is used for pyamqp transport (#1151) * enabled ssl certificate verification when amqps is used for pyamqp transport * unit tests
* Add predefined_queues option to SQS transport (#1156)Jonathan Ingram2020-02-262-17/+108
|
* Issue 701 (#1141)Shai Berger2020-02-021-3/+4
| | | | | | | | | | * Make Redis-Mutex test fail as it should (#701) See https://github.com/celery/kombu/issues/701 * Fix issue #701 - decode lock_id returned from Redis Thanks @zaro
* Support standard values for ssl_cert_reqs query parameter. (#1139)Dave Peticolas2020-02-021-2/+23
| | | | | | * Support standard values for ssl_cert_reqs query parameter. * Pick lint.
* Adding retry_on_timeout parameter (#1150)Konstantin Seleznev2020-02-021-2/+4
| | | | | | | | | | | | | | * added retry_on_timeout connparam * added retry_on_timeout to tests * updated Pyro4 * revert Pyro4 in requirements * Trigger notification * Trigger rebuild
* Add support for health_check_interval option in broker_transport_options. ↵Kevin Fox2020-01-112-0/+53
| | | | | | | | | | | | | | | | | | | | (#1145) * Add support for health_check_interval option in broker_transport_options. #1114 * Added Keivn Fox to authors. * Do not use default arg for pop() method. * Add dedicated test case for configurable health_check * Add test case for when health_check_interval is not supported by connection_class in redis. * Fix Flake8 * Added more test cases for redis. * Updated tests.
* Add peek lock settings to be changed using transport options (#1119)Nicolas Mota2019-12-021-7/+19
|
* Fix redis health checks (#1122)Ashish Bansal (mrphantom)2019-12-022-2/+28
| | | | | | | | * Fix redis transport health checks functionality * Add tests for accepts_argument util function * Reduce default health check interval to 25s
* reset ready before execute callback (#1126)Smite Chow2019-12-021-1/+4
| | | | | | * reset ready before execute callback * add test to cover hub._ready reset to empty
* Add missing parameter queue_args in kombu.connection.SimpleBuffer (#1128)Mario Rodriguez Molins2019-11-232-2/+84
| | | | | | | | | | | | | | | | | | | * Add missing parameter queue_args in kombu.connection.SimpleBuffer `queue_args` parameter was introduced in `kombu.simple.SimpleQueue` class and at the same time in `kombu.connection.SimpleQueue` method. However, `kombu.connection.SimpleBuffer` was not updated in the same way. As `kombu.connection.SimpleBuffer` is using positional arguments to create a `kombu.simple.SimpleBuffer` object, `exchange_opts` value in that instance would be None and `queue_args` is going to bet set with the expected `exchange_opts` value. * Add tests for SimpleBuffer and SimpleQueue - Add tests for SimpleBuffer/SimpleQueue methods in kombu.simple module - Add tests for SimpleQueue and SimpleBuffer tasks in kombu.connection
* Revert "Revert "Revert "Use SIMEMBERS instead of SMEMBERS to check for queue ↵Asif Saif Uddin2019-11-101-3/+0
| | | | | (redis broker) (#1041)" (#1058)" (#1068)" (#1117) This reverts commit 052f7601d3a1e09263cc0ebda7ef8c16e6b90175.
* Revert "Issue #1087 redis fix (#1089)" (#1106)Asif Saif Uddin2019-11-021-610/+253
| | | This reverts commit 2f6f5f6a5df1cf52bf8fd45ee9fb3c93d793d637.
* Fix 'NoneType' object has no attribute 'can_read' (#1107)Aliaksei Urbanski2019-10-241-0/+12
| | | | | | The root cause of the issue is that the connection can be erased during an execution of self._receive_one(c). So c.connection should be checked before every iteration, not only before the first one.
* Add wait timeout settings to receive queue message (#1110)Nicolas Mota2019-10-231-0/+232
| | | | | | | | * Add wait timeout settings to receive queue message * add tests * add more tests and remove servicebus from coveragerc
* Issue #1019 Fix redis transport socket timeout (#1113)Kris Ciccarello2019-10-231-3/+4
| | | | | | | | | | | | * Issue #1019 Fix redis transport socket timeout Patch from @jschwartzentruber https://github.com/celery/kombu/issues/1019#issuecomment-535157400 * Fix test_register_with_event_loop redis test * Fix linter * Bump redis to 3.3.11
* fixes #1097 (#1099)Shekhar Kamble2019-09-101-0/+8
| | | | | | | | | | * sanitise url when include_password is false (fixes #1085) * fix flake8 error * fixes #1097 * fix flake8 errors
* sanitise url when include_password is false (fixes #1085) (#1095)Shekhar Kamble2019-09-031-0/+7
| | | | | | * sanitise url when include_password is false (fixes #1085) * fix flake8 error
* Issue #1087 redis fix (#1089)Matt Davis2019-08-311-253/+610
| | | | | | | | | | * issue-1087 Revert _lookup api and correct redis implemetnation. Update variable naming to be self documenting and more readable by non native speakers. Major overhaul of redis test cases by adding more full featured fakeredis module. * Add more test cases to boost coverage of kombu redis transport. * Refactor the producer consumer test cases to be based on original mocks and be passing * Fix lingering line length issue in test.
* Make sure that max_retries=0 is treated differently than None (#1080)Eric Higdon2019-08-131-1/+16
| | | | | | | | | | | | * Make sure that max_retries=0 is treated differently than None When max_retries=0, it should not retry at all instead of retrying infinitely. * retry_always should use max_retries=None instead of 0. * Added test for zero retries * Removed Offending spaces from blank line
* Fixing MongoDB backend to work properly with TTL (#1076)Marcin Puhacz2019-08-071-3/+3
| | | | | | | | | | | | | * Fixing MongoDB backend to work properly with TTL Bumping pymongo version to 3.8.0 * Updating authors * Adding dependencies to travis config * Fixing travis test cases * Changing pymongo version to align with mongo result backend
* Switch from pkg_resources importlib-metadata (#1071)David Szotten2019-07-061-15/+11
| | | | | | See e.g. https://github.com/pypa/setuptools/issues/510#issuecomment-463667124 On a moderatly large project (~200 packages) at $work this saves ~150 ms on `python -c 'from kombu import Exchange'`
* Revert "Revert "Use SIMEMBERS instead of SMEMBERS to check for queue (redis ↵Asif Saif Uddin2019-06-291-0/+3
| | | | | broker) (#1041)" (#1058)" (#1068) This reverts commit fcb8e05cc95bcaf18a23092416f654b88b015163.
* Issue 129 fix maybe declare (#1066)Matt Davis2019-06-291-21/+71
| | | | | | | | | | | | | | | | | | * Factor out the binding of channel to entity into a method that can be shared and does not use assert. * do not use assertion in production because it can be stripped in optimize and is best left for unit tests. * dont reassign entity here because it breaks a bunch of tests. * fix pydoc complaints * Add TDD style test that fails in master and passes in my branch * finish refactor of existing maybe_declare tests to use shared fixtures * py2/py3 print difference means skip printing. * fix pep8 line length
* don't stop receiving tasks on 503 SQS error. (#1064)Eugene Beseda2019-06-251-1/+2
| | | | | | * don't stop receiving tasks on 503 SQS error. * fix linter errors
* Allow users to switch URLs while omitting the resource identifier (#1032)ngie-eign2019-06-241-0/+10
| | | | | | | | | | | Prior to this change, one needed to specify a URL using a URI identifier, e.g., `pyamqp://foo.bar`. This change makes it so calling `.switch(..)` again results in switching the host, not switching the resource identifier. This simplifies setting up connections with just hostnames specifying the resource identifier once, separately. Signed-off-by: Enji Cooper <yaneurabeya@gmail.com>
* return an empty list on SQS internal error. (#1059)Eugene Beseda2019-06-131-0/+20
| | | | | | * return empty list on SQS internal error. * add test for on_list_ready error codes
* Revert "Use SIMEMBERS instead of SMEMBERS to check for queue (redis broker) ↵Asif Saif Uddin2019-06-111-3/+0
| | | | | (#1041)" (#1058) This reverts commit 73d2219887dfc5469c0c1ea382baf4749049aef2.
* Add events field on memory channel (#1053)Gabriele Santomaggio2019-06-041-0/+18
| | | | | | | | | | | | | | * Add events field on memory channel Part of https://github.com/celery/kombu/issues/1050, with this fix the function does not raise the exception. The init `defaultdict(set)` is the same init from amqp lib. * Add unit test * Add more detail test * FIx flake8
* Use SIMEMBERS instead of SMEMBERS to check for queue (redis broker) (#1041)Stevan Milic2019-05-291-0/+3
| | | | | | | | | | | | | * Add `_lookup_direct` method to virtual channel. (#994) Add possibility to optimize lookup for queue in direct exchange set. * Add `_lookup_direct` method to redis virtual channel. (#994) Use `SISMEMBER` instead of `SMEMBERS` command to check if queue exists in a set. Time complexity is increased from O(N) to O(1) where N is the set cardinality.
* qpid: ensure supported exchange types are declared (#1034)Rohan McGovern2019-04-041-0/+6
| | | | | | | | | | | | | This is a follow-up to ddba8aeaf0f68. Prior to that commit, "implements" was missing entirely for qpid. The earlier commit added it, but only declared that the transport was async-capable. Turns out it's important also to declare the supported exchange types. In particular, if the transport doesn't declare support for the 'fanout' exchange type, pidbox wouldn't be used[1] and so it would still not be possible to revoke a task with terminate=True when using the qpid transport. [1] https://github.com/celery/celery/commit/2f58c35340f648
* Reintroduce unqiue broadcast queue name generation as optional. (#1033)Omer Katz2019-03-311-6/+20
|
* qpid: correctly declare support for async event loop (#1029)Rohan McGovern2019-03-301-3/+4
| | | | | | | | | | | | | qpid transport supports an async interface, but this wasn't declared properly. It was missing an appropriate 'implements' class property. This seems to have been missed because: - kombu 4.x was branched from 3.0.21 - qpid transport was originally added after that in 3.0.24 - Transport.implements was added in commit 6a1abb7e9 on the 4.x branch only, before the qpid transport was in that branch - qpid transport code was then copied between 3.x and 4.x branches but addition of Transport.implements was missed.
View Lorry Controller Status