![[BACK]](/icons/back.gif){kind=icon}
Up to [cvs.NetBSD.org] / pkgsrc / net / py-kombu
Request diff between arbitrary revisions
Keyword substitution: kv
Default branch: MAIN
py-kombu: updated to 5.3.7 5.3.7 The release of v5.3.6 was missing the bumbversion commit so v5.3.7 is only released to sync it back. 5.3.6 boto3>=1.26.143 Always convert azureservicebus namespace to fully qualified Pin pytest-sugar to latest version 1.0.0 Upgrade to pytest v8 that removed nose compatibility fix warning for usage of utcfromtimestamp Update pytest to 8.0.2 Hotfix: Fix CI failures (limit redis to <5.0.2 instead of <6.0.0) Expose cancel callback from py-amqp channel.basic_consume Update mypy to 1.9.0 Update pytest to 8.1.1 Pin hypothesis to hypothesis<7 redis>=4.5.2,<5.0.2,!=4.5.5 -> redis>=4.5.2,!=5.0.2,!=4.5.5 add escape hatch for custom JSON serialization Pin pytest-cov to latest version 5.0.0
py-kombu: updated to 5.3.5 5.3.5 Fix ReadTheDocs CI fix(docs): add Redis to the list of transports where SSL is supported Fixed Improper Method Call: Replaced mktemp Bump actions/setup-python from 4 to 5 Bump github/codeql-action from 2 to 3 fix: freeze set during ticks iter in async hub azure service bus: fix TypeError when using Managed Identities Fix unacknowledge typo in restore_visible() Changed pyup -> dependabot for updating dependencies Bump pytest from 7.4.3 to 7.4.4 Bump flake8 from 6.0.0 to 7.0.0 Bump mypy from 1.3.0 to 1.8.0 Fix crash when using global_keyprefix with a sentinel connection Fixed version_dev in docs/conf.py 5.3.4 Use the correct protocol for SQS requests 5.3.3 Raise access denied error when ack. test redis 5.0.0. fix azure servicebus using managed identity support Added as_uri method to MongoDB transport Revert Use boto3 for SQS async requests Create a lock on cached_property if not present Bump kafka deps versions & fix integration test failures Added Python 3.12 support. Fix: redis requeue concurrency bug 5.3.2 Reverted unwanted constraint introduced in 1629 with max_retries Doc fix Python3.12: fix imports in kombu/utils/objects.py Use boto3 for SQS async requests docs: Remove SimpleQueue import Fixed pre-commit issues azure service bus: add managed identity support fix: Prevent redis task loss when closing connection while in poll Kombu & celery with SQS syntax correction 5.3.1 Update pycurl version. Declare python 3.11 support Fix: allow deserializing any version of UUID. Update PyCurl version in SQS 5.3.0 Support for Kafka as transport. Add fanout to filesystem Added possibility to serialize and deserialize binary messages in json Support pymongo 4.x Support redis-py 4.5.x. Upgrade Azure Storage Queues transport to version 12 Add support to SQS DelaySeconds Add WATCH to prefixed complex commands. Avoid losing type of UUID when serializing/deserializing Added HLEN to the list of prefixed redis commands Add managed identity support to azure storage queue Add Support of sqlalchemy v2.0. Deprecate pytz and use zoneinfo
py-kombu: fix invalid pattern Fixes build
py-kombu: updated to 5.2.4 5.2.4 Allow getting recoverable_connection_errors without an active transport. Prevent KeyError: ‘purelib’ by removing INSTALLED_SCHEME hack from setup.py. Revert “try pining setuptools Fix issue 789: Async http code not allowing for proxy config Fix The incorrect times of retrying. Set redelivered property for Celery with Redis Remove use of OrderedDict in various places Warn about missing hostname only when default one is available All supported versions of Python define __package__. Added global_keyprefix support for pubsub clients try pytest 7 Add an option to not base64-encode SQS messages. Fix SQS extract_task_name message reference.
py-kombu: update to 5.2.3.
5.2.3
What's Changed
create codeql actions by @auvipy in #1441
create security policy doc by @auvipy in #1440
drop as we dont use travis by @auvipy in #1442
[pre-commit.ci] pre-commit autoupdate by @pre-commit-ci in #1443
Fix PyPy CI jobs by @illia-v in #1446
Allow redis >= 4.0.2 by @illia-v in #1445
SQS transport: detect FIFO queue properly by checking queue URL by @n0061q in #1450
Ensure that restore is atomic in redis transport by @matusvalo in #1444
test pyaqp v5.0.7 by @auvipy in #1457
try restrict setuptool in CI by @auvipy in #1472
try pining setuptools by @auvipy in #1466
test amqp v5.0.9 by @auvipy in #1462
reduce memory usage of Transport by @pawl in #1470
prevent event loop polling on closed redis transports (and causing leak) by @pawl in #1476
respect connection timeout by @mehdipourfar in #1458
prevent redis event loop stopping on 'consumer: Cannot connect' by @pawl in #1477
[pre-commit.ci] pre-commit autoupdate by @pre-commit-ci in #1478
5.2.2
What's Changed
[pre-commit.ci] pre-commit autoupdate by @pre-commit-ci in #1430
[pre-commit.ci] pre-commit autoupdate by @pre-commit-ci in #1436
pin redis under 4.0.0 for now by @auvipy in #1437
5.2.1
What's Changed
Added integration test of failed authentication to redis by @matusvalo in #1423
Bump redis version to >= 3.4.1 by @matusvalo in #1422
add python 3.10 to classifier by @auvipy in #1424
python !=3.12.1 by @auvipy in #1427
Update librabbitmq.txt by @auvipy in #1426
try latest sqs dependencies by @auvipy in #1428
5.2.0
What's Changed
Revert "Added redis transport key_prefix from envvars" by @matusvalo in #1249
Redis Transport: Small improvements of SentinelChannel by @matusvalo in #1253
Fix pidbox not using default channels on master by @lambacck in #1258
Added self to AUTHORS by @vinayinvicible in #1260
Revert "on worker restart - restore visible regardless to time (#905)" by @vinayinvicible in #1259
Add vine to install dependencies by @chrisburr in #1265
Reformat and improve kombu transport reference docs by @matusvalo in #1264
Pin urllib3<1.26 to fix failing unittests. by @matusvalo in #1273
Add timeout to producer publish by @RezaSi in #1269
Added 4.6.8 changelog by @KFoxder in #1276
Remove python2 compatibility code by @matusvalo in #1277
redis: Support Sentinel with SSL by @auvipy in #1275
Update connections.rst with Redis sentinel example by @anudeepsamaiya in #1285
docs: fix simple typo, propery -> property by @timgates42 in #1286
Support for Azure Service Bus 7.0.0 by @terrycain in #1284
Allow specifying session token by @flying-sheep in #1283
Fix Azure Service Bus URL parsing by @terrycain in #1287
Python 3 style print statement by @rednafi in #1289
min py-amqp to 5.0.5 by @auvipy in #1292
attempt to update to tox docker 2.0 by @auvipy in #1293
http/curl: missing _set_timeout by @raittes in #1296
Stop treating namedtuple as an object when using simplejson by @Hardtack in #1297
SQS back-off policy by @galCohen88 in #1301
SQS retry policy documentation improvement by @galCohen88 in #1304
Port of redis code improvements from prior revision by @matteius in #1132
Revert "Port of redis code improvements from prior revision" by @matusvalo in #1307
Fixed SQS unittests by @matusvalo in #1308
fix: non kombu json message decoding in SQS transport by @moaddib666 in #1306
Add Github Actions CI by @matusvalo in #1309
Update default pickle protocol version to 4 by @illia-v in #1314
Update connection.py by @Krogsager in #1311
Drop support for the lzma backport by @thedrow in #1317
Fix tiny mistake in introduction by @der-gabe in #1312
Drop obsolete code importing pickle by @illia-v in #1315
Small doc fixes by @der-gabe in #1319
Update default login method for librabbitmq and pyamqp by @daviskirk in #936
SQS Broker - handle STS authentication with AWS by @galCohen88 in #1322
min py-amqp to v5.0.6 by @auvipy in #1325
Use a thread-safe implementation of cached_property by @thedrow in #1316
Azure Service Bus - versatile queue names fix by @tsunday in #1324
Fix CI failure by @thedrow in #1327
Add support for SQLAlchemy 1.4 by @thedrow in #1328
Opencollective bot is now configured by @thedrow in #1331
re order CI jobs to make lint the last by @auvipy in #1332
Coerce seconds argument to a floating point number. by @thedrow in #1330
Make flake8 and pydocstyle happy by @matusvalo in #1333
Remove unused appveyor and travis configuration files by @matusvalo in #1335
Ignore kombu.transport.librabbitmq in apicheck. by @matusvalo in #1334
chore: Refactor code quality issues by @akshgpt7 in #1320
Revert "chore: Refactor code quality issues" by @matusvalo in #1342
add accept parameter to SimpleQueue class by @lsaavedr in #1140
prepare_accept_content() now raises SerializerNotInstalled instead of KeyError by @matusvalo in #1343
Remove backward compatible code not used anymore by @matusvalo in #1344
Move pytest.importorskip to run earlier by @felixonmars in #1346
Add support for setting redis username by @gabor-boros in #1351
enable pre-commit by @graingert in #1355
[pre-commit.ci] pre-commit autoupdate by @pre-commit-ci in #1359
Add support for Python 3.9 by @D3X in #1363
[pre-commit.ci] pre-commit autoupdate by @pre-commit-ci in #1364
Use hostname from URI when server_host is None by @matusvalo in #1366
[pre-commit.ci] pre-commit autoupdate by @pre-commit-ci in #1367
Use Python's built-in json module by default, instead of simplejson by @nikolas in #1368
Fixed type comment by @SchizmOne in #1371
SQS Channel.predefined_queues should be {} if not defined by @infinitewarp in #1372
[pre-commit.ci] pre-commit autoupdate by @pre-commit-ci in #1374
Add global key prefix for keys set by Redis transporter by @gabor-boros in #1349
fix: raise BrokenPipeError exit on brokenpipe instead of hanging around by @jagguli in #1231
[FAL-2030] fix: add missing commands to prefix by @gabor-boros in #1376
Make BrokerState Transport specific by @matusvalo in #1378
Run integration tests for kombu also with global_keyprefix by @matusvalo in #1380
[pre-commit.ci] pre-commit autoupdate by @pre-commit-ci in #1379
v 1.4.x by @auvipy in #1338
stop mentioning librabbitmq by @auvipy in #1381
test new pytest version by @auvipy in #1383
drop python 3.6 from CI by @auvipy in #1382
Fix missing dependency to redis in docs requirements by @matusvalo in #1386
[pre-commit.ci] pre-commit autoupdate by @pre-commit-ci in #1387
Remove dependency to case by @matusvalo in #1389
Fix: check redis response type by @kaiix in #1390
[pre-commit.ci] pre-commit autoupdate by @pre-commit-ci in #1393
py3.7+ on setup by @auvipy in #1392
Prevent caching of oid in pidbox by @matusvalo in #1394
fix flake8 in kombu/asynchronous/aws/connection.py by @matusvalo in #1397
[pre-commit.ci] pre-commit autoupdate by @pre-commit-ci in #1396
Fix test_pidbox unittests to support non-linux platforms by @matusvalo in #1398
[pre-commit.ci] pre-commit autoupdate by @pre-commit-ci in #1400
removre bdist by @auvipy in #1406
add python 3.10 to CI & fix other issues by @auvipy in #1402
try to fix CI by @auvipy in #1407
Dont failfast when pypy3 tests fail by @matusvalo in #1408
Return empty list instead of InconsistencyError when exchange table is empty by @matusvalo in #1404
[pre-commit.ci] pre-commit autoupdate by @pre-commit-ci in #1410
5.2.0 release notes by @naomielst in #1417
net: Replace RMD160 checksums with BLAKE2s checksums All checksums have been double-checked against existing RMD160 and SHA512 hashes Not committed (merge conflicts...): net/radsecproxy/distinfo The following distfiles could not be fetched (fetched conditionally?): ./net/citrix_ica/distinfo citrix_ica-10.6.115659/en.linuxx86.tar.gz ./net/djbdns/distinfo dnscache-1.05-multiple-ip.patch ./net/djbdns/distinfo djbdns-1.05-test28.diff.xz ./net/djbdns/distinfo djbdns-1.05-ignoreip2.patch ./net/djbdns/distinfo djbdns-1.05-multiip.diff ./net/djbdns/distinfo djbdns-cachestats.patch
net: Remove SHA1 hashes for distfiles
py-kombu: updated to 5.1.0 5.1.0 Fix queue names special characters replacement for Azure Service Bus. Add support for SQLAlchemy 1.4. Coerce seconds argument to a floating point number in Timer.enter_after. Add accept parameter to SimpleQueue class. prepare_accept_content() now raises SerializerNotInstalled instead of KeyError. 5.1.0b1 Wheels are no longer universal. Revert “Added redis transport key_prefix from envvars”. Redis Transport: Small improvements of SentinelChannel Fix pidbox not using default channels. Revert “on worker restart - restore visible regardless to time Add vine to dependencies. Pin urllib3<1.26 to fix failing unittests. Add timeout to producer publish Remove python2 compatibility code redis: Support Sentinel with SSL. Support for Azure Service Bus 7.0.0 Allow specifying session token kombu/asynchronous/http/curl: implement _set_timeout. Disable namedtuple to object feature in simplejson Update to tox docker 2.0. SQS back-off policy Fixed SQS unittests. Fix: non kombu json message decoding in SQS transport Add Github Actions CI Update default pickle protocol version to 4 Update connection.py Drop support for the lzma backport. Drop obsolete code importing pickle Update default login method for librabbitmq and pyamqp SQS Broker - handle STS authentication with AWS Min py-amqp version is v5.0.6 Numerous docs & example fixes. Use a thread-safe implementation of cached_property
py-kombu: updated to 5.0.2 5.0.2 Bump required amqp version to 5.0.0. 5.0.1 Removed kombu.five from the reference documentation since it no longer exists Adjusted the stable documentation’s version in Sphinx’s configuration since that was overlooked in the latest release 5.0.0 BREAKING CHANGE: Dropped support for Python 2 Add an SQS transport option for custom botocore config 4.6.11 Revert incompatible changes in Default_channel should reconnect automatically 4.6.10 Doc improvement. set _connection in _ensure_connection Fix for the issue reuse connection [bug fix] 4.6.9 Prevent failure if AWS creds are not explicitly defined on predefined. Raise RecoverableConnectionError in maybe_declare with retry on and. Fix for the issue possible fix for Fix: make SQLAlchemy Channel init thread-safe Added integration testing infrastructure for RabbitMQ Initial redis integration tests implementation SQLAlchemy transport: Use Query.with_for_update() instead of deprecated Fix Consumer Encoding Added Integration tests for direct, topic and fanout exchange types Added TTL integration tests Added integration tests for priority queues fix 100% cpu usage on linux while using sqs Modified Mutex to use redis LuaLock implementation Fix: eliminate remaining race conditions from SQLAlchemy Channel Fix connection imaybe_declare Fix for issue Ensure connection when connecting to broker update pyamqp to 2.6 with optional cythonization
py-kombu: updated to 4.6.8 4.6.8: Unknown changes
py-kombu: updated to 4.6.7 4.6.7: Use importlib.metadata from the standard library on Python 3.8+. Add peek lock settings to be changed using transport options. Fix redis health checks. Reset ready before execute callback. Add missing parameter queue_args in kombu.connection.SimpleBuffer.
py-kombu: updated to 4.6.6 4.6.6 - Revert _lookup_direct and related changes of redis. - Python 3.8 support - Fix 'NoneType' object has no attribute 'can_read' bug of redis transport - Fix redis transport socket timeout - Add wait timeout settings to receive queue message - Bump py-amqp to 2.5.2 4.6.5 - Revert _lookup api and correct redis implemetnation. - 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. - Sanitise url when include_password is false - Pinned pycurl to 7.43.0.2 as it is the latest build with wheels provided - Bump py-amqp to 2.5.2
py-kombu: updated to 4.6.4 4.6.4 - Use importlib-metadata instead of pkg_resources for better performance - Allow users to switch URLs while omitting the resource identifier - Don't stop receiving tasks on 503 SQS error. - Fix maybe declare - Revert "Revert "Use SIMEMBERS instead of SMEMBERS to check for queue (Redis Broker) - Fix MongoDB backend to work properly with TTL - Make sure that max_retries=0 is treated differently than None - Bump py-amqp to 2.5.1
py-kombu: updated to 4.6.3 4.6.3 - Revert FastUUID for kombu 4.6 4.6.2 - Fix sbugs and regressions 4.6.1 - Fix some newly introduced bug in kombu 4.6
py-kombu: updated to 4.5.0 4.5.0: - The Redis transport now supports a custom separator for keys. - When the SQS server returns a timeout we ignore it and keep trying instead of raising an error. - Properly declare async support for the Qpid transport.
py-kombu: updated to 4.4.0 4.4.0: - Restore bz2 import checks in compression module. The checks were removed in celery/kombu-938 <https://github.com/celery/kombu/pull/938>_ due to assumption that it only affected Jython. However, bz2 support can be missing in Pythons built without bz2 support. - Fix regression that occurred in 4.3.0 when parsing Redis Sentinel master URI containing password. - Handle the case when only one Redis Sentinel node is provided. - Support SSL URL parameters correctly for rediss:// URIs. - Revert celery/kombu-954 <https://github.com/celery/kombu/pull/954>_. Instead bump the required redis-py dependency to 3.2.0 to include this fix andymccurdy/redis-py@4e1e748 <https://github.com/andymccurdy/redis-py/commit/4e1e74809235edc19e03edb79c97c80a3e4e9eca>_. - Added support for broadcasting using a regular expression pattern or a glob pattern to multiple Pidboxes.
py-kombu: updated to 4.3.0 4.3.0: - Added Python 3.7 support. - Avoid caching queues which are declared with a TTL. Queues that are declared with a TTL are now also be excluded from the in-memory cache in case they expire between publishes on the same channel. - Added an index to the Message table for the SQLAlchemy transport. The index allows to effectively sorting the table by the message's timestamp. - Added a timeout that limits the amount of time we retry to reconnect to a transport. - :class:celery.asynchronous.hub.Hub is now reentrant. This allows calling :func:celery.bin.celery.main to revive a worker in the same process after rescuing from shutdown (:class:SystemExit). - Queues now accept string exchange names as arguments as documented. Tests were added to avoid further regressions. - Specifying names for broadcast queues now work as expected. Previously, named broadcast queues did not create multiple queues per worker. They incorrectly declared the named queue which resulted in one queue per fanout exchange, thus missing the entire point of a fanout exchange. The behavior is now matched to unnamed broadcast queues. - When initializing the Redis transport in conjunction with gevent restore all unacknowledged messages to queue. - Allow :class:kombu.simple.SimpleQueue to pass queue_arguments to Queue object. This allows :class:kombu.simple.SimpleQueue to connect to RabbitMQ queues with custom arguments like 'x-queue-mode'='lazy'. - Add support for 'rediss' scheme for secure Redis connections. The rediss scheme defaults to the least secure form, as there is no suitable default location for ca_certs. The recommendation would still be to follow the documentation and specify broker_use_ssl if coming from celery. - Added the Azure Storage Queues transport. The transport is implemented on top of Azure Storage Queues. This offers a simple but scalable and low-cost PaaS transport for Celery users in Azure. The transport is intended to be used in conjunction with the Azure Block Blob Storage backend. - Added the Azure Service Bus transport. The transport is implemented on top of Azure Service Bus and offers PaaS support for more demanding Celery workloads in Azure. The transport is intended to be used in conjunction with the Azure CosmosDB backend. - Drop remaining mentions of Jython support completely. - When publishing messages to the Pidbox, retry if an error occurs. - Fix infinite loop in :method:kombu.asynchronous.hub.Hub.create_loop. - Worker shutdown no longer duplicates messages when using the SQS broker. - When using the SQS broker, prefer boto's default region before our hardcoded default. - Fixed closing of shared redis sockets which previously caused Celery to hang. - the Pyro_ transport (:mod:kombu.transport.pyro) now works with recent Pyro versions. Also added a Pyro Kombu Broker that this transport needs for its queues. - Handle non-base64-encoded SQS messages. - Move the handling of Sentinel failures to the redis library itself. Previously, Redis Sentinel worked only if the first node's sentinel service in the URI was up. A server outage would have caused downtime. - When using Celery and the pickle serializer with binary data as part of the payload, UnicodeDecodeError would be raised as the content was not utf-8. We now replace on errors. - Allow setting :method:boto3.sqs.create_queue Attributes via transport_options. - Fixed infinite loop when entity.channel is replaced by revive() on connection drop. - Added optional support for Brotli compression. - When using the SQS broker, FIFO queues with names that ended with the 'f' letter were incorrectly parsed. This is now fixed. - Added optional support for LZMA compression. - Added optional support for ZStandard compression. - Require py-amqp 2.4.0 as the minimum version. - The value of DISABLE_TRACEBACKS environment variable is now respected on debug, info and warning logger level.
py-kombu: updated to 4.2.2 4.2.2 - Support both Redis client version 2.x and version 3.x.
py-kombu: updated to 4.2.1 4.2.1: The 4.2.0 release contained remains of the async module by accident. This is now fixed. - Handle librabbitmq fileno raising a ValueError when socket is not connected. 4.2.0: - Now passing max_retries, interval_start, interval_step, interval_max parameters from broker transport_options to :meth:~kombu.Connection.ensure_connection when returning :meth:~kombu.Connection.default_connection - Qpid: messages are now durable by default - Kombu now requires version 2.10.4 or greater of the redis library, in line with Celery - Fixed ImportError in some environments with outdated simplejson - MongoDB: fixed failure on MongoDB versions with an "-rc" tag - Ensure periodic polling frequency does not exceed timeout in virtual transport - Fixed string handling when using python-future module - Replaced "async" with "asynchronous" in preparation for Python 3.7 - Allow removing pool size limit when in use
4.1.0
- SQS: Added support for long-polling on all supported queries. Fixed bug
causing error on parsing responses with no retrieved messages from SQS.
- Async hub: Fixed potential infinite loop while performing todo tasks
- Qpid: Fixed bug where messages could have duplicate ``delivery_tag``
- MongoDB: Fixed problem with using ``readPreference`` option at pymongo 3.x.
- Re-added support for :pypi:``SQLAlchemy``
- SQS: Fixed bug where hostname would default to ``localhost`` if not specified
in settings.
- Redis: Added support for reading password from transport URL
- RabbitMQ: Ensured safer encoding of queue arguments.
- Added fallback to :func:``uuid.uuid5`` in :func:``generate_oid`` if
:func:``uuid.uuid3`` fails.
- Fixed race condition and innacurrate timeouts for
:class:``kombu.simple.SimpleBase``
- Zookeeper: Fixed last chroot character trimming
- RabbitMQ: Fixed bug causing an exception when attempting to close an
already-closed connection
- Removed deprecated use of StopIteration in generators and invalid regex
escape sequence.
- Added Python 3.6 to CI testing.
- SQS: Allowed endpoint URL to be specified in the boto3 connection.
- SQS: Added support for Python 3.4.
- SQS: ``kombu[sqs]`` now depends on :pypi:`boto3` (no longer using
:pypi:`boto)`.
- Adds support for Python 3.4+
- Adds support for FIFO queues
- Avoids issues around a broken endpoints file
- Zookeeper: Added support for delaying task with Python 3.
- SQS: Fixed bug where :meth:`kombu.transport.SQS.drain_events` did not support
callback argument
- Fixed bug around modifying dictionary size while iterating over it
- etcd: Added handling for :exc:`EtcdException` exception rather than
:exc:`EtcdError`.
Changes 4.0.2:
- Now depends on :mod:`amqp` 2.1.4
This new version takes advantage of TCP Keepalive settings on Linux,
making it better at detecting closed connections, also in failover
conditions.
- Redis: Priority was reversed so, e.g. priority 0 became priority 9.
Add SHA512 digests for distfiles for net category Problems found with existing digests: Package haproxy distfile haproxy-1.5.14.tar.gz 159f5beb8fdc6b8059ae51b53dc935d91c0fb51f [recorded] da39a3ee5e6b4b0d3255bfef95601890afd80709 [calculated] Problems found locating distfiles: Package bsddip: missing distfile bsddip-1.02.tar.Z Package citrix_ica: missing distfile citrix_ica-10.6.115659/en.linuxx86.tar.gz Package djbdns: missing distfile djbdns-1.05-test25.diff.bz2 Package djbdns: missing distfile djbdns-cachestats.patch Package djbdns: missing distfile 0002-dnscache-cache-soa-records.patch Package gated: missing distfile gated-3-5-11.tar.gz Package owncloudclient: missing distfile owncloudclient-2.0.2.tar.xz Package poink: missing distfile poink-1.6.tar.gz Package ra-rtsp-proxy: missing distfile rtspd-src-1.0.0.0.tar.gz Package ucspi-ssl: missing distfile ucspi-ssl-0.70-ucspitls-0.1.patch Package waste: missing distfile waste-source.tar.gz Otherwise, existing SHA1 digests verified and found to be the same on the machine holding the existing distfiles (morden). All existing SHA1 digests retained for now as an audit trail.
3.0.23
======
- Django: Fixed bug in the Django 1.7 compatibility improvements related
to autocommit handling.
- Django: The Django transport models would not be created on syncdb
after app label rename.
3.0.22
======
- kombu.async: Min. delay between waiting for timer was always increased to
one second.
- Fixed bug in itermessages where message is received after the with
statement exits the block.
- Connection.autoretry: Now works with functions missing wrapped attributes
(``__module__``, ``__name__``, ``__doc__``).
- Django: Now sets custom app label for ``kombu.transport.django`` to work
with recent changes in Django 1.7.
- SimpleQueue removed messages from the wrong end of buffer.
- Tests: Now using ``unittest.mock`` if available.
3.0.21 ====== - Fixed remaining bug in ``maybe_declare`` for ``auto_delete`` exchanges. - MongoDB: Creating a channel now properly evaluates a connection (Issue #363). 3.0.20 ====== - Reverts change in 3.0.17 where ``maybe_declare`` caches the declaration of auto_delete queues and exchanges. - Redis: Fixed race condition when using gevent and the channel is closed.
3.0.19 ====== - The wheel distribution did not support Python 2.6 by failing to list the extra dependencies required. - Durable and auto_delete queues/exchanges can be be cached using ``maybe_declare``.
CATEGORIES+=python. Use options framework to enable user to select all options supported by this package, with none enabled by default. Changelog: 3.0.18 ====== - A typo introduced in 3.0.17 caused kombu.async.hub to crash (Issue #360). 3.0.17 ====== - ``kombu[librabbitmq]`` now depends on librabbitmq 1.5.2. - Async: Event loop now selectively removes file descriptors for the mode it failed in, and keeps others (e.g read vs write). - CouchDB: Now works without userid set. - SQLAlchemy: Now supports recovery from connection errors. - Redis: Restore at shutdown now works when ack emulation is disabled. - :func:`kombu.common.eventloop` accidentally swallowed socket errors. - Adds :func:`kombu.utils.url.sanitize_url`
Update to latest release, 3.0.16. From ChangeLog: - ``kombu[librabbitmq]`` now depends on librabbitmq 1.5.1. - Redis: Fixes ``TypeError`` problem in ``unregister`` (Issue #342). - Tests: Some unit tests accidentally required the `redis-py` library. - librabbitmq: Would crash when using an older version of :mod:`librabbitmq`, now emits warning instead.
Update to 3.0.15. From Changelog:
- Now depends on :mod:`amqp` 1.4.5.
- RabbitMQ 3.3 changes QoS semantics (Issue #339).
See the RabbitMQ release notes here:
http://www.rabbitmq.com/blog/2014/04/02/breaking-things-with-rabbitmq-3-3/
A new connection property has been added that can be used to detect
whether the remote server is using this new QoS behavior::
>>> Connection('amqp://').qos_behavior_matches_spec
False
so if your application depends on the old semantics you can
use this to set the ``apply_global`` flag appropriately::
def update_prefetch_count(channel, new_value):
channel.basic_qos(
0, new_value,
not channel.connection.client.qos_behavior_matches_spec,
)
- Users of :mod:`librabbitmq` is encouraged to upgrade to librabbitmq 1.5.0.
The ``kombu[librabbitmq]`` extra has been updated to depend on this
version.
- Pools: Now takes transport options into account when comparing connections
(Issue #333).
- MongoDB: Fixes Python 3 compatibility.
- Async: select: Ignore socket errors when attempting to unregister handles
from the loop.
- Pidbox: Can now be configured to use a serializer other than json,
but specifying a serializer argument to :class:`~kombu.pidbox.Mailbox`.
- Message decompression now works with Python 3.
Updated to latest release, 3.0.14. From ChangeLog:
- **MongoDB**: Now endures a connection failover (Issue #123).
- **MongoDB**: Fixed ``KeyError`` when a replica set member is removed.
Also fixes celery#971 and celery/#898.
- **MongoDB**: Fixed MongoDB broadcast cursor re-initialization bug.
- **Async**: Fixed bug in lax semaphore implementation where in
some usage patterns the limit was not honored correctly.
- **Redis**: Fixed problem with fanout when using Python 3 (Issue #324).
- **Redis**: Fixed ``AttributeError`` from attempting to close a non-existing
connection (Issue #320).
- Redis: Fixed serious race condition that could lead to data loss.
The delivery tags were accidentally set to be an incremental number
local to the channel, but the delivery tags need to be globally
unique so that a message can not overwrite an older message
in the backup store.
This change is not backwards incompatible and you are encouraged
to update all your system using a previous version as soon as possible.
- Now depends on :mod:`amqp` 1.4.4.
- Pidbox: Now makes sure message encoding errors are handled by default,
so that a custom error handler does not need to be specified.
- Redis: The fanout exchange can now use AMQP patterns to route and filter
messages.
This change is backwards incompatible and must be enabled with
the ``fanout_patterns`` transport option::
>>> conn = kombu.Connection('redis://', transport_options={
... 'fanout_patterns': True,
... })
When enabled the exchange will work like an amqp topic exchange
if the binding key is a pattern.
This is planned to be default behavior in the future.
- Redis: Fixed ``cycle`` no such attribute error.
Updated to latest release, 3.0.12. From Changelog:
3.0.12
======
- Now depends on :mod:`amqp` 1.4.3.
- Fixes Python 3.4 logging incompatibility (Issue #311).
- Redis: Now properly handles unknown pub/sub messages.
- amqplib: Fixed bug where more bytes were requested from the socket
than necessary.
3.0.11
======
- Now depends on :mod:`amqp` 1.4.2.
- Now always trusts messages of type `application/data` and `application/text`
or which have an unspecified content type (Issue #306).
- Compression errors are now handled as decode errors and will trigger
the ``Consumer.on_decode_error`` callback if specified.
- New ``kombu.Connection.get_heartbeat_interval()`` method that can be
used to access the negotiated heartbeat value.
- `kombu.common.oid_for` no longer uses the MAC address of the host, but
instead uses a process-wide UUID4 as a node id.
This avoids a call to `uuid.getnode()` at module scope.
- Hub.add: Now normalizes registered fileno.
- SQS: Fixed bug where the prefetch count limit was not respected.
Updated to latest release, 3.0.10. Now depends on net/py-amqp>=1.4.1. From
Changelog:
3.0.10
======
- Now depends on :mod:`amqp` 1.4.1.
- ``maybe_declare`` now raises a "recoverable connection error" if
the channel is disconnected instead of a :exc:`ChannelError` so that
the operation can be retried.
- Redis: ``Consumer.cancel()`` is now thread safe.
This fixes an issue when using gevent/eventlet and a
message is handled after the consumer is cancelled resulting
in a "message for queue without consumers" error.
- Retry operations would not always respect the interval_start
value when calculating the time to sleep for (Issue #303).
- Timer: Fixed "unhashable type" error on Python 3.
- Hub: Do not attempt to unregister operations on an already closed
poller instance.
3.0.9
=====
- Now depends on :mod:`amqp` 1.4.0.
- Redis: Basic cancel for fanout based queues now sends a corresponding
``UNSUBSCRIBE`` command to the server.
This fixes an issue with pidbox where reply messages could be received
after the consumer was cancelled, giving the ``"message to queue without
consumers"`` error.
- MongoDB: Improved connection string and options handling
(Issue #266 + Issue #120).
- SQS: Limit the number of messages when receiving in batch to 10.
This is a hard limit enforced by Amazon so the sqs transport
must not exceeed this value.
- ConsumerMixin: ``consume`` now checks heartbeat every time the
socket times out.
- Retry Policy: A max retries of 0 did not retry forever.
- Simple: If passing a Queue object the simple utils will now take
default routing key from that queue.
- ``repr(producer)`` no longer evaluates the underlying channnel.
- Redis: The map of Redis error classes are now exposed at the module level
using the :func:`kombu.transport.redis.get_redis_error_classes` function.
- Async: ``Hub.close`` now sets ``.poller`` to None.
Depend on py-amqp>=1.3.3. Only accept python versions 33, 27, 26. Both as
per documentation. Updated to latest release, 3.0.8. From Changelog:
3.0.8
=====
- Serializer: loads and dumps now wraps exceptions raised into
:exc:`~kombu.exceptions.DecodeError` and
:exc:`kombu.exceptions.EncodeError` respectively.
- Redis: Would attempt to read from the wrong connection if a
select/epoll/kqueue exception event happened.
- Redis: Disabling ack emulation now works properly.
- Redis: :exc:`IOError` and :exc:`OSError` are now treated as recoverable
connection errors.
- SQS: Improved performance by reading messages in bulk.
- Connection Pool: Attempting to acquire from a closed pool will now
raise :class:`RuntimeError`.
3.0.7
=====
- Fixes Python 2.6 compatibility.
- Redis: Fixes 'bad file descriptor' issue.
3.0.6
=====
- Timer: No longer attempts to hash keyword arguments (Issue #275).
- Async: Did not account for the long type for file descriptors.
- PyPy: kqueue support was broken.
- Redis: Bad pub/sub payloads no longer crashes the consumer.
- Redis: Unix socket URLs can now specify a virtual host by including
it as a query parameter.
- ``kombu.VERSION`` is now a named tuple.
3.0.5
=====
- Now depends on :mod:`amqp` 1.3.3.
- Redis: Fixed Python 3 compatibility problem (Issue #270).
- MongoDB: Fixed problem with URL parsing when authentication used.
- pyamqp: Fixed small issue when publishing the message and
the property dictionary was set to None.
- Fixed problem in ``repr(LaxBoundedSemaphore)``.
- Tests now passing on Python 3.3.
3.0.4
=====
- common.QoS: ``decrement_eventually`` now makes sure the value
does not go below 1 if a prefetch count is enabled.
3.0.3
=====
- SQS: Properly reverted patch that caused delays between messages.
- select: Clear all registerd fds on poller.cloe
- Eventloop: unregister if EBADF raised.
3.0.2
=====
- Now depends on :mod:`amqp` version 1.3.2.
- select: Fixed problem where unregister did not properly remove
the fd.
3.0.1
=====
- Now depends on :mod:`amqp` version 1.3.1.
- Redis: New option ``fanout_keyprefix``
This transport option is recommended for all users as it ensures
that broadcast (fanout) messages sent is only seen by the current
virtual host:
Connection('redis://', transport_options={'fanout_keyprefix': True})
However, enabling this means that you cannot send or receive messages
from older Kombu versions so make sure all of your participants
are upgraded and have the transport option enabled.
This will be the default behavior in Kombu 4.0.
- Distribution: Removed file ``requirements/py25.txt``.
- MongoDB: Now disables ``auto_start_request``.
- MongoDB: Enables ``use_greenlets`` if eventlet/gevent used.
- Pidbox: Fixes problem where expires header was None,
which is a value not supported by the amq protocol.
- ConsumerMixin: New ``consumer_context`` method for starting
the consumer without draining events.
3.0.0
=====
- Now depends on :mod:`amqp` version 1.3.
- No longer supports Python 2.5
The minimum Python version supported is now Python 2.6.0 for Python2,
and Python 3.3 for Python3.
- Dual codebase supporting both Python 2 and 3.
No longer using ``2to3``, making it easier to maintain support for
both versions.
- pickle, yaml and msgpack deserialization is now disabled by default.
This means that Kombu will by default refuse to handle any content type
other than json.
- kombu.async: Experimental event loop implementation.
- Utility function ``kombu.common.ipublish`` has been removed.
Use ``Producer(..., retry=True)`` instead.
- Utility function ``kombu.common.isend_reply`` has been removed
Use ``send_reply(..., retry=True)`` instead.
- ``kombu.common.entry_to_queue`` and ``kombu.messaging.entry_to_queue``
has been removed.
Use ``Queue.from_dict(name, **options)`` instead.
- Redis: Messages are now restored at the end of the list.
- ``StdConnectionError`` and ``StdChannelError`` is removed
and :exc:`amqp.ConnectionError` and :exc:`amqp.ChannelError` is used
instead.
- Message object implementation has moved to :class:`kombu.message.Message`.
- Serailization: Renamed functions encode/decode to
:func:`~kombu.serialization.dumps` and :func:`~kombu.serialization.loads`.
For backward compatibility the old names are still available as aliases.
- The ``kombu.log.anon_logger`` function has been removed.
Use :func:`~kombu.log.get_logger` instead.
- ``queue_declare`` now returns namedtuple with ``queue``, ``message_count``,
and ``consumer_count`` fields.
- LamportClock: Can now set lock class
- :mod:`kombu.utils.clock`: Utilities for ordering events added.
- :class:`~kombu.simple.SimpleQueue` now allows you to override
the exchange type used.
- Zookeeper transport updated to support new changes in the :mod:`kazoo`
library.
- pyamqp/librabbitmq: Transport options are now forwarded as keyword arguments
to the underlying connection (Issue #214).
- Transports may now distinguish between recoverable and irrecoverable
connection and channel errors.
- ``kombu.utils.Finalize`` has been removed: Use
:mod:`multiprocessing.util.Finalize` instead.
- Memory transport now supports the fanout exchange type.
- Experimental new `Pyro`_ transport (:mod:`kombu.transport.pyro`).
.. _`Pyro`: http://pythonhosted.org/Pyro
- Experimental new `SoftLayer MQ`_ transport (:mod:`kombu.transport.SLMQ`).
.. _`SoftLayer MQ`: http://www.softlayer.com/services/additional/message-queue
- Eventio: Kqueue breaks in subtle ways so select is now used instead.
- SQLAlchemy transport: Can now specify table names using the
``queue_tablename`` and ``message_tablename`` transport options.
Redis transport: Now supports using local UNIX sockets to communicate with the
Redis server (Issue #1283)
To connect using a UNIX socket you have to use the ``redis+socket``
URL-prefix: ``redis+socket:///tmp/redis.sock``.
This functionality was merged from the `celery-redis-unixsocket`_ project.
Contributed by Maxime Rouyrre.
ZeroMQ transport: drain_events now supports timeout.
.. _`celery-redis-unixsocket`:
https://github.com/piquadrat/celery-redis-unixsocket
2.5.16
======
- Python3: Fixed problem with dependencies not being installed.
2.5.15
======
- Declaration cache: Now only keeps hash of declaration
so that it does not keep a reference to the channel.
- Declaration cache: Now respects ``entity.can_cache_declaration``
attribute.
- Fixes Python 2.5 compatibility.
- Fixes tests after python-msgpack changes.
- ``Queue.get``: Now supports ``accept`` argument.
2.5.14
======
- safe_str did not work properly resulting in
:exc:`UnicodeDecodeError` (Issue #248).
2.5.13
======
- Now depends on :mod:`amqp` 1.0.13
- Fixed typo in Django functional tests.
- safe_str now returns Unicode in Python 2.x
- amqp: Transport options are now merged with arguments
supplied to the connection.
- Tests no longer depends on distribute, which was deprecated
and merged back into setuptools.
- ConsumerMixin now also restarts on channel related errors.
Import py27-kombu-2.5.12 as net/py-kombu. Kombu is a messaging framework for Python. The aim of Kombu is to make messaging in Python as easy as possible by providing an idiomatic high-level interface for the AMQ protocol, and also provide proven and tested solutions to common messaging problems.