![[BACK]](/icons/back.gif){kind=icon}
Up to [cvs.NetBSD.org] / pkgsrc / net / py-kombu
Request diff between arbitrary revisions
Default branch: MAIN
Revision 1.36 / (download) - annotate - [select for diffs], Sun Jul 30 15:32:49 2023 UTC (4 months ago) by adam
Branch: MAIN
CVS Tags: pkgsrc-2023Q3-base,
pkgsrc-2023Q3,
HEAD
Changes since 1.35: +1 -8
lines
Diff to previous 1.35 (colored)
Remove dependencies for Python 3.7
Revision 1.35 / (download) - annotate - [select for diffs], Wed Mar 29 09:34:12 2023 UTC (8 months ago) by wiz
Branch: MAIN
CVS Tags: pkgsrc-2023Q2-base,
pkgsrc-2023Q2
Changes since 1.34: +3 -2
lines
Diff to previous 1.34 (colored)
*: use PYTHON_VERSION instead of _PYTHON_VERSION
Revision 1.34 / (download) - annotate - [select for diffs], Mon Jul 11 08:43:01 2022 UTC (16 months, 3 weeks ago) by adam
Branch: MAIN
CVS Tags: pkgsrc-2023Q1-base,
pkgsrc-2023Q1,
pkgsrc-2022Q4-base,
pkgsrc-2022Q4,
pkgsrc-2022Q3-base,
pkgsrc-2022Q3
Changes since 1.33: +3 -3
lines
Diff to previous 1.33 (colored)
py-kombu: updated to 5.2.4 5.2.4 Allow getting recoverable_connection_errors without an active transport. Prevent KeyError: ãàÏÑurelibãàby removing INSTALLED_SCHEME hack from setup.py. Revert ãà×Õry 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.
Revision 1.33 / (download) - annotate - [select for diffs], Tue Feb 15 14:37:06 2022 UTC (21 months, 2 weeks ago) by wiz
Branch: MAIN
CVS Tags: pkgsrc-2022Q2-base,
pkgsrc-2022Q2,
pkgsrc-2022Q1-base,
pkgsrc-2022Q1
Changes since 1.32: +5 -6
lines
Diff to previous 1.32 (colored)
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
Revision 1.32 / (download) - annotate - [select for diffs], Tue Jan 4 20:54:28 2022 UTC (22 months, 3 weeks ago) by wiz
Branch: MAIN
Changes since 1.31: +2 -1
lines
Diff to previous 1.31 (colored)
*: bump PKGREVISION for egg.mk users They now have a tool dependency on py-setuptools instead of a DEPENDS
Revision 1.31 / (download) - annotate - [select for diffs], Wed Jul 14 20:15:38 2021 UTC (2 years, 4 months ago) by adam
Branch: MAIN
CVS Tags: pkgsrc-2021Q4-base,
pkgsrc-2021Q4,
pkgsrc-2021Q3-base,
pkgsrc-2021Q3
Changes since 1.30: +2 -2
lines
Diff to previous 1.30 (colored)
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 ãà×¢dded redis transport key_prefix from envvarsãà Redis Transport: Small improvements of SentinelChannel Fix pidbox not using default channels. Revert ãà×Ðn 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
Revision 1.30 / (download) - annotate - [select for diffs], Sat May 8 06:01:18 2021 UTC (2 years, 6 months ago) by adam
Branch: MAIN
CVS Tags: pkgsrc-2021Q2-base,
pkgsrc-2021Q2
Changes since 1.29: +4 -3
lines
Diff to previous 1.29 (colored)
py-kompu: shuffle PYTHON_VERSIONS_INCOMPATIBLE
Revision 1.29 / (download) - annotate - [select for diffs], Fri May 7 18:00:35 2021 UTC (2 years, 6 months ago) by adam
Branch: MAIN
Changes since 1.28: +6 -8
lines
Diff to previous 1.28 (colored)
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ãàÑÔ version in SphinxãàÑÔ 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
Revision 1.28 / (download) - annotate - [select for diffs], Sat May 16 18:00:31 2020 UTC (3 years, 6 months ago) by adam
Branch: MAIN
CVS Tags: pkgsrc-2021Q1-base,
pkgsrc-2021Q1,
pkgsrc-2020Q4-base,
pkgsrc-2020Q4,
pkgsrc-2020Q3-base,
pkgsrc-2020Q3,
pkgsrc-2020Q2-base,
pkgsrc-2020Q2
Changes since 1.27: +4 -2
lines
Diff to previous 1.27 (colored)
pytest from versioned depends
Revision 1.27 / (download) - annotate - [select for diffs], Sun Apr 12 11:01:36 2020 UTC (3 years, 7 months ago) by adam
Branch: MAIN
Changes since 1.26: +3 -3
lines
Diff to previous 1.26 (colored)
py-kombu: updated to 4.6.8 4.6.8: Unknown changes
Revision 1.26 / (download) - annotate - [select for diffs], Wed Dec 11 14:42:01 2019 UTC (3 years, 11 months ago) by adam
Branch: MAIN
CVS Tags: pkgsrc-2020Q1-base,
pkgsrc-2020Q1,
pkgsrc-2019Q4-base,
pkgsrc-2019Q4
Changes since 1.25: +6 -3
lines
Diff to previous 1.25 (colored)
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.
Revision 1.25 / (download) - annotate - [select for diffs], Wed Nov 13 20:38:37 2019 UTC (4 years ago) by adam
Branch: MAIN
Changes since 1.24: +4 -4
lines
Diff to previous 1.24 (colored)
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
Revision 1.24 / (download) - annotate - [select for diffs], Mon Sep 2 09:59:15 2019 UTC (4 years, 3 months ago) by adam
Branch: MAIN
CVS Tags: pkgsrc-2019Q3-base,
pkgsrc-2019Q3
Changes since 1.23: +4 -3
lines
Diff to previous 1.23 (colored)
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
Revision 1.23 / (download) - annotate - [select for diffs], Fri Jun 21 11:25:00 2019 UTC (4 years, 5 months ago) by adam
Branch: MAIN
CVS Tags: pkgsrc-2019Q2-base,
pkgsrc-2019Q2
Changes since 1.22: +4 -4
lines
Diff to previous 1.22 (colored)
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
Revision 1.22 / (download) - annotate - [select for diffs], Fri Apr 5 12:53:46 2019 UTC (4 years, 7 months ago) by adam
Branch: MAIN
Changes since 1.21: +2 -2
lines
Diff to previous 1.21 (colored)
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.
Revision 1.21 / (download) - annotate - [select for diffs], Wed Mar 6 18:43:55 2019 UTC (4 years, 8 months ago) by adam
Branch: MAIN
CVS Tags: pkgsrc-2019Q1-base,
pkgsrc-2019Q1
Changes since 1.20: +2 -2
lines
Diff to previous 1.20 (colored)
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.
Revision 1.20 / (download) - annotate - [select for diffs], Wed Feb 13 16:24:15 2019 UTC (4 years, 9 months ago) by adam
Branch: MAIN
Changes since 1.19: +3 -3
lines
Diff to previous 1.19 (colored)
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.
Revision 1.19 / (download) - annotate - [select for diffs], Sun Dec 16 14:38:18 2018 UTC (4 years, 11 months ago) by adam
Branch: MAIN
CVS Tags: pkgsrc-2018Q4-base,
pkgsrc-2018Q4
Changes since 1.18: +8 -2
lines
Diff to previous 1.18 (colored)
py-kombu: updated to 4.2.2 4.2.2 - Support both Redis client version 2.x and version 3.x.
Revision 1.18 / (download) - annotate - [select for diffs], Mon Jun 18 07:11:11 2018 UTC (5 years, 5 months ago) by adam
Branch: MAIN
CVS Tags: pkgsrc-2018Q3-base,
pkgsrc-2018Q3,
pkgsrc-2018Q2-base,
pkgsrc-2018Q2
Changes since 1.17: +2 -2
lines
Diff to previous 1.17 (colored)
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
Revision 1.17 / (download) - annotate - [select for diffs], Sat Sep 16 19:27:05 2017 UTC (6 years, 2 months ago) by wiz
Branch: MAIN
CVS Tags: pkgsrc-2018Q1-base,
pkgsrc-2018Q1,
pkgsrc-2017Q4-base,
pkgsrc-2017Q4,
pkgsrc-2017Q3-base,
pkgsrc-2017Q3
Changes since 1.16: +2 -2
lines
Diff to previous 1.16 (colored)
Reset maintainer
Revision 1.16 / (download) - annotate - [select for diffs], Sat Jul 22 06:49:43 2017 UTC (6 years, 4 months ago) by adam
Branch: MAIN
Changes since 1.15: +2 -2
lines
Diff to previous 1.15 (colored)
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`.
Revision 1.15 / (download) - annotate - [select for diffs], Sun Apr 9 17:14:41 2017 UTC (6 years, 7 months ago) by adam
Branch: MAIN
CVS Tags: pkgsrc-2017Q2-base,
pkgsrc-2017Q2
Changes since 1.14: +3 -5
lines
Diff to previous 1.14 (colored)
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.
Revision 1.14 / (download) - annotate - [select for diffs], Wed Jun 8 17:43:36 2016 UTC (7 years, 5 months ago) by wiz
Branch: MAIN
CVS Tags: pkgsrc-2017Q1-base,
pkgsrc-2017Q1,
pkgsrc-2016Q4-base,
pkgsrc-2016Q4,
pkgsrc-2016Q3-base,
pkgsrc-2016Q3,
pkgsrc-2016Q2-base,
pkgsrc-2016Q2
Changes since 1.13: +2 -2
lines
Diff to previous 1.13 (colored)
Switch to MASTER_SITES_PYPI.
Revision 1.13 / (download) - annotate - [select for diffs], Sun Nov 9 20:40:01 2014 UTC (9 years ago) by rodent
Branch: MAIN
CVS Tags: pkgsrc-2016Q1-base,
pkgsrc-2016Q1,
pkgsrc-2015Q4-base,
pkgsrc-2015Q4,
pkgsrc-2015Q3-base,
pkgsrc-2015Q3,
pkgsrc-2015Q2-base,
pkgsrc-2015Q2,
pkgsrc-2015Q1-base,
pkgsrc-2015Q1,
pkgsrc-2014Q4-base,
pkgsrc-2014Q4
Changes since 1.12: +2 -2
lines
Diff to previous 1.12 (colored)
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.
Revision 1.12 / (download) - annotate - [select for diffs], Wed Jul 16 23:18:37 2014 UTC (9 years, 4 months ago) by rodent
Branch: MAIN
CVS Tags: pkgsrc-2014Q3-base,
pkgsrc-2014Q3
Changes since 1.11: +2 -2
lines
Diff to previous 1.11 (colored)
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.
Revision 1.11 / (download) - annotate - [select for diffs], Sun Jun 15 15:36:00 2014 UTC (9 years, 5 months ago) by rodent
Branch: MAIN
CVS Tags: pkgsrc-2014Q2-base,
pkgsrc-2014Q2
Changes since 1.10: +2 -2
lines
Diff to previous 1.10 (colored)
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``.
Revision 1.10 / (download) - annotate - [select for diffs], Mon Jun 9 00:16:23 2014 UTC (9 years, 5 months ago) by rodent
Branch: MAIN
Changes since 1.9: +7 -4
lines
Diff to previous 1.9 (colored)
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`
Revision 1.9 / (download) - annotate - [select for diffs], Sun May 18 20:36:10 2014 UTC (9 years, 6 months ago) by rodent
Branch: MAIN
Changes since 1.8: +2 -2
lines
Diff to previous 1.8 (colored)
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.
Revision 1.8 / (download) - annotate - [select for diffs], Thu Apr 17 01:55:21 2014 UTC (9 years, 7 months ago) by rodent
Branch: MAIN
Changes since 1.7: +3 -3
lines
Diff to previous 1.7 (colored)
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.
Revision 1.7 / (download) - annotate - [select for diffs], Mon Apr 7 03:46:37 2014 UTC (9 years, 7 months ago) by rodent
Branch: MAIN
Changes since 1.6: +3 -3
lines
Diff to previous 1.6 (colored)
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.
Revision 1.6 / (download) - annotate - [select for diffs], Sun Feb 16 21:44:22 2014 UTC (9 years, 9 months ago) by rodent
Branch: MAIN
CVS Tags: pkgsrc-2014Q1-base,
pkgsrc-2014Q1
Changes since 1.5: +3 -3
lines
Diff to previous 1.5 (colored)
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.
Revision 1.5 / (download) - annotate - [select for diffs], Sun Feb 2 13:58:34 2014 UTC (9 years, 10 months ago) by rodent
Branch: MAIN
Changes since 1.4: +3 -3
lines
Diff to previous 1.4 (colored)
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.
Revision 1.4 / (download) - annotate - [select for diffs], Sun Jan 26 08:46:00 2014 UTC (9 years, 10 months ago) by wiz
Branch: MAIN
Changes since 1.3: +3 -7
lines
Diff to previous 1.3 (colored)
py-amqp works with python-3.x, as does this.
Revision 1.3 / (download) - annotate - [select for diffs], Thu Jan 2 04:49:16 2014 UTC (9 years, 11 months ago) by dholland
Branch: MAIN
Changes since 1.2: +4 -2
lines
Diff to previous 1.2 (colored)
Turn off py33 until py-amqp supports py33; fixes pbulk resolve failure.
Revision 1.2 / (download) - annotate - [select for diffs], Tue Dec 31 14:12:17 2013 UTC (9 years, 11 months ago) by rodent
Branch: MAIN
Changes since 1.1: +6 -3
lines
Diff to previous 1.1 (colored)
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.
Revision 1.1 / (download) - annotate - [select for diffs], Tue Jul 2 11:05:21 2013 UTC (10 years, 5 months ago) by rodent
Branch: MAIN
CVS Tags: pkgsrc-2013Q4-base,
pkgsrc-2013Q4,
pkgsrc-2013Q3-base,
pkgsrc-2013Q3
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.