Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity
2,989 Commits 43 Branches 180 Tags 25 MiB
Commit Graph

2989 Commits

Author SHA1 Message Date
Omer Katz b8a3fcac06 Update version and copyright year. 2019-02-06 18:12:08 +02:00
Omer Katz 6d5bfaee2b 4.3 Changelog (#1001) 
* Started working on changelog for 4.3.

* More changelog.

* Finish changelog.
 2019-02-06 20:24:25 +06:00
Josh Morrow bb0bb5298b Allow mutex to be noop for eventlet (#916) 2019-02-05 13:32:53 +06:00
Mads Jensen 0392c34e7d Removed Python 2.6 workarounds in test_qpid.py (#995) 2019-02-05 12:57:37 +06:00
Omer Katz 139f68de23
Catch TypeError instead of KeyError. 
Fixes #997.
 2019-02-04 21:06:19 +02:00
Ludovic Rivallain 483cadced7 traceback can be disabled for all log levels (#1000) 2019-02-04 17:06:31 +06:00
Clemens Wolff ec05b6eb50 Fix breaking change in Azure ServiceBus SDK (#998) 
See 97b71f2670/azure-servicebus (migration-from-0211-to-0500)
 2019-02-04 09:41:09 +02:00
Omer Katz b4f239cc10 Ignore flake8 errors for now due to type annotations bug in pyflakes. 2019-02-04 09:03:43 +02:00
Omer Katz 43930bbcae Happify lint. 2019-02-04 08:45:20 +02:00
Lars Rinn 024cbdc4fb import collections.ABCs from correct module (#992) 
* import collectionss.ABCs from correct model to silence deprecation warnings

* fix imports for legacy python
 2019-01-18 00:08:28 +02:00
BR 2dff21c42b Fixed kombu.me links (#988) 2019-01-13 22:26:57 +02:00
Asif Saif Uddin 4a4f1b9106
required py-amqp 2.4 as minimum version 2019-01-13 20:48:46 +06:00
Omer Katz 627964c804
Added optional support for zstd compression. (#985) 2019-01-13 09:44:44 +02:00
Omer Katz 8c88d9276a Added support for lzma compression (#984) 
* Added support for lzma compression.

* Ignore branch.
 2019-01-10 15:00:37 +06:00
Omer Katz 9dd7e7ae1f Bump PyPy to 6.0. Add PyPy3 to the build process. (#986) 2019-01-10 09:48:06 +06:00
Omer Katz 3ee3e2f48c revert. 2019-01-09 23:20:36 +02:00
Omer Katz 57a67ffa11 Move to xenial. 2019-01-09 23:01:30 +02:00
Omer Katz c86fc5c297 Move to Python 3.7. 2019-01-09 22:58:55 +02:00
Omer Katz 08771f7b05 Run flake8 with two jobs. 2019-01-09 22:56:12 +02:00
Ilya Konstantinov 5ee7c1ddcc SQS: fix trimming .fifo from queue name (#982) 
* SQS: fix trimming .fifo from queue name

* add test

* fix lint error
 2019-01-09 20:36:37 +02:00
Omer Katz 93a05f7261
Added optional support for brotli compression (#983) 
* Added optional support for brotli compression.

* Ignore import error for coverage purposes.
 2019-01-09 19:05:02 +02:00
Omer Katz fa0cb19d27 Update reference. 2019-01-09 17:28:36 +02:00
Omer Katz b37e035c39 Fixed sphinx warnings. 2019-01-09 16:51:28 +02:00
Omer Katz 05878d6790 Run sphinx checks with two jobs. 2019-01-09 16:47:52 +02:00
Omer Katz 293a1a0df3 Added missing comma for tuples with one element in __all__. 2019-01-09 16:47:11 +02:00
Omer Katz 77b1362b39 Happify lint. 2019-01-09 16:26:31 +02:00
Omer Katz c9e0ef5834 Avoid using mutable default argument. 2019-01-09 14:39:25 +02:00
Omer Katz b6510e0c36 Fixed typo. 2019-01-09 13:15:49 +02:00
Omer Katz a28e7a27fb Remove unused private method. 2019-01-08 17:25:03 +02:00
Omer Katz 41f14aa503 Added documentation to arguments. 2019-01-08 17:23:04 +02:00
Tzach Yarimi d78a8fc7a7 fixing an infinite loop when entity.channel is replaced by revive() on an connection drop (#779) 2019-01-08 20:42:59 +06:00
Omer Katz 85d0ebe179 Mention 4.2.2-post1 in changelog. 
Fixed formatting as well.
 2019-01-08 11:50:58 +02:00
Omer Katz 3e3886b245
Avoid raising StopIterator in generators. (#972) 
According to [PEP-479](https://www.python.org/dev/peps/pep-0479/) StopIteration should not be used any more to indicate the termination of a generator.
Starting from Python 3.7 this behaviour is always enforced and a RuntimeError is raised instead.
We now return instead of raising StopIteration.
 2019-01-03 22:02:32 +02:00
Omer Katz eded86487e Bump version: 4.2.1 → 4.2.2 2019-01-03 17:47:37 +02:00
Omer Katz f8a1230c13 Update Changelog. 2019-01-03 17:47:37 +02:00
Matus Valo 80584c8c9b Fix failing unittests of pyamqp transport. (#978) 
Failing unittests were caused by commit f16df2a17630c9804a6da614443c5e862271823f in pyamqp.
 2019-01-03 17:39:42 +02:00
Li Ming e4dc1688a2 fix a typo in Queue's docstring (#971) 2018-12-27 22:56:56 +06:00
vikvns da7b77e591 Corrected typo in exchange name. (#969) 2018-12-20 14:45:40 +02:00
Omer Katz 1ad6cbd35c
Happify lint. 2018-12-20 14:42:19 +02:00
Omer Katz ddd07a2923
Happify lint. 2018-12-20 14:39:37 +02:00
Omer Katz 98825c8142
Happify lint. 2018-12-20 14:36:38 +02:00
Hunter Fernandes c48d201ee2 Allow setting boto3.sqs.create_queue Attributes via transport_options (#957) 
* Allow setting boto3.sqs.create_queue Attributes via transport_options

* Add docs for sqs transport_options `sqs-creation-attributes`
 2018-12-09 18:53:12 +02:00
Jian Dai 571b0ad205 fix bytes_to_str bug (#747) 
When we were using celery , and using `pickle` format to transfer a bytes variable like a file content, for example a picture file, then we will get an exception here. 
```UnicodeDecodeError: 'utf-8' codec can't decode byte 0xff in position 0: invalid start byte```
So add `errors='replace'` to avoid the encoding error here.
 2018-11-29 22:30:52 +06:00
Brian Price a59b44e9fb Moving the handling of Sentinel failures to the redis library itself. (#813) 
* Moving the handling of Sentinel failures to the redis library itself.

Currently Celery dies if the first Sentinel servive on the list is down,
as in if you lose a machine.

* Removing the use of unittest.

* Changing how an empty list is defined.
 2018-11-29 12:38:52 +06:00
Asif Saif Uddin 01ab1a7f59
fixed bare except flake8 error by adding KeyError 2018-11-27 16:59:42 +06:00
Tim Li 7ed7df0ca1 handling non-base64-encoded SQS message (#937) 2018-11-27 16:19:47 +06:00
Irmen de Jong aa8ea28f50 Making the pyro transport available, fix it for recent Pyro4 versions, add broker daemon (#895) 
* Make the pyro transport available and fix it for recent Pyro4 version.
Implemented the missing Pyro Kombu broker to actually be able to use the Pyro transport

* code style
 2018-11-25 20:40:54 +06:00
Asif Saif Uddin 44524d590b
set email notification to false 2018-11-23 00:02:07 +06:00
Alexey Popravka 9b0694f4ed fix close of shared redis socket causing celery to hang (#954) 2018-11-22 14:42:36 +06:00
Jeppe Fihl-Pearson 5fca408a91 Correct order of Redis `zadd` dict elements (#953) 
The changed `zadd()` behaviour in redis-py 3 states:
https://github.com/andymccurdy/redis-py#mset-msetnx-and-zadd

> For ZADD, the dict is a mapping of element-names -> score.

So the dictionary generated for `zadd()` should be flipped around to have the
`delivery_tag` as the key and the score as value. This commit fixes that.
 2018-11-20 15:27:38 +02:00