summaryrefslogtreecommitdiff
path: root/t
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-1365-235/+99
|
* 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-105-20/+73
| | | | | | | * 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-052-0/+17
|
* 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-014-37/+77
|
* 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 flake8Matus Valo2020-05-151-1/+1
|
* Improve integration test suitMatus Valo2020-05-151-1/+17
|
* fix 100% cpu usage on linux while using sqsAndrii Maletskyi2020-05-151-16/+14
| | | | fix https://github.com/celery/celery/issues/5299
* Improved Priority integration testsMatus Valo2020-05-132-26/+35
|
* Added priority integration tests for RedisMatus Valo2020-05-122-7/+96
|
* Added integration tests for priority queuesMatus Valo2020-05-082-1/+91
|
* Added TTL integration testsMatus Valo2020-05-062-1/+56
|
* Added Integration tests for direct, topic and fanout exchange typesMatus Valo2020-05-063-2/+104
|
* Use explicit py-amqp transport instead of amqp in integration testsMatus Valo2020-05-041-1/+1
|
* Added Simple Buffer integration testsMatus Valo2020-05-041-2/+13
|
* Rename test classes for better test outputMatus Valo2020-05-032-2/+2
|
* Removed scripts depending on RabbitMQMatus Valo2020-05-031-10/+0
|
* Create common class of integration testsMatus Valo2020-05-033-99/+62
|
* Initial redis integration tests implementationMatus Valo2020-05-031-0/+73
|
* Added basic integration tests for RabbitMQMatus Valo2020-04-301-0/+50
|
* Added integration testing infrastructure for RabbitMQMatus Valo2020-04-3016-545/+39
|
* 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
View Lorry Controller Status