The NetBSD Project

CVS log for pkgsrc/net/py-kombu/Makefile

[BACK] Up to [] / 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)


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

Allow getting recoverable_connection_errors without an active transport.
Prevent KeyError: urelibby removing INSTALLED_SCHEME hack from
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.


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 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 autoupdate by @pre-commit-ci in #1478


What's Changed

    [] pre-commit autoupdate by @pre-commit-ci in #1430
    [] pre-commit autoupdate by @pre-commit-ci in #1436
    pin redis under 4.0.0 for now by @auvipy in #1437


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


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 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 autoupdate by @pre-commit-ci in #1359
    Add support for Python 3.9 by @D3X in #1363
    [] pre-commit autoupdate by @pre-commit-ci in #1364
    Use hostname from URI when server_host is None by @matusvalo in #1366
    [] 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 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 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 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 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/ by @matusvalo in #1397
    [] pre-commit autoupdate by @pre-commit-ci in #1396
    Fix test_pidbox unittests to support non-linux platforms by @matusvalo in #1398
    [] 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 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 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

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.

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
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)


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


Bump required amqp version to 5.0.0.


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


BREAKING CHANGE: Dropped support for Python 2
Add an SQS transport option for custom botocore config


Revert incompatible changes in
Default_channel should reconnect automatically


Doc improvement.
set _connection in _ensure_connection
Fix for the issue
reuse connection [bug fix]


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

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

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

- 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

- 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 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

- 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

- Revert FastUUID for kombu 4.6

- Fix sbugs and regressions

- 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

- 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

- Restore bz2 import checks in compression module.
  The checks were removed in celery/kombu-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 <>_.
  Instead bump the required redis-py dependency to 3.2.0
  to include this fix andymccurdy/redis-py@4e1e748 <>_.
- 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

- 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 is replaced by revive() on connection
- 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

- 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

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.

- Now passing max_retries, interval_start, interval_step,
  interval_max parameters from broker transport_options to
  :meth:~kombu.Connection.ensure_connection when returning
- 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)


- 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

- 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

    - 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

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

- 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)


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)


- 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.


- 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)

- Fixed remaining bug in ``maybe_declare`` for ``auto_delete`` exchanges.
- MongoDB: Creating a channel now properly evaluates a connection (Issue #363).

- 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)


- 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

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:


- A typo introduced in 3.0.17 caused kombu.async.hub to crash (Issue #360).


- ``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:

    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

    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):
                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
- 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
    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:


- 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.


- 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


- 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.


- 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:

- 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`.

- Fixes Python 2.6 compatibility.
- Redis: Fixes 'bad file descriptor' issue.

- 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.

- 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.

- common.QoS: ``decrement_eventually`` now makes sure the value
  does not go below 1 if a prefetch count is enabled.

- SQS: Properly reverted patch that caused delays between messages.
- select: Clear all registerd fds on poller.cloe
- Eventloop: unregister if EBADF raised.

- Now depends on :mod:`amqp` version 1.3.2.
- select: Fixed problem where unregister did not properly remove
  the fd.

- 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.


- 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
- 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`
- 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`:
- Experimental new `SoftLayer MQ`_ transport (:mod:`kombu.transport.SLMQ`).
.. _`SoftLayer MQ`:
- 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`:


- Python3: Fixed problem with dependencies not being installed.

- 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``
- Fixes Python 2.5 compatibility.
- Fixes tests after python-msgpack changes.
- ``Queue.get``: Now supports ``accept`` argument.


- safe_str did not work properly resulting in
  :exc:`UnicodeDecodeError` (Issue #248).

- 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.

This form allows you to request diff's between any two revisions of a file. You may select a symbolic revision name using the selection box or you may type in a numeric name using the type-in text box.

CVSweb <>