delta/python-packages/kombu.git/t/unit/test_common.py, branch remove-python2-support github.com: celery/kombu.git Remove five usage from tests. 2020-07-23T13:33:40+00:00 Omer Katz omer.drow@gmail.com 2020-07-23T13:33:40+00:00 2c75db39e0d91c41384f5c2593ec2e630c8e7420 






pyupgrade
2020-07-13T13:58:06+00:00

Omer Katz
omer.drow@gmail.com

2020-07-13T13:58:06+00:00

7a6e7cc45b9afe799770313a66c4211d1986ff30












Fix connection imaybe_declare (#1196)
2020-05-26T19:03:22+00:00

Oleh Kuchuk
kuchuklehjs@gmail.com

2020-05-26T19:03:22+00:00

246cb9e996b39be80aa9b50194e2ffa8e024efde












Revert "Raise RecoverableConnectionError in maybe_declare with retry on and dropped connection" (#1195)
2020-05-24T22:06:38+00:00

Matus Valo
matusvalo@users.noreply.github.com

2020-05-24T22:06:38+00:00

4644a5e9400beac6668f326c16078286f7d60b64

This reverts commit 90f51bcbbd32146998e7c7e4491150344343776b.




This reverts commit 90f51bcbbd32146998e7c7e4491150344343776b.






Raise RecoverableConnectionError in maybe_declare with retry on and dropped connection
2020-04-15T15:08:18+00:00

Oleh Kuchuk
kuchuklehjs@gmail.com

2020-04-15T12:16:57+00:00

90f51bcbbd32146998e7c7e4491150344343776b












Issue 129 fix maybe declare (#1066)
2019-06-29T05:34:35+00:00

Matt Davis
matteius@gmail.com

2019-06-29T05:34:35+00:00

ac6c7b975469cf335b88760ec349ab3b149105fa

* Factor out the binding of channel to entity into a method that can be shared and does not use assert.

* do not use assertion in production because it can be stripped in optimize and is best left for unit tests.

* dont reassign entity here because it breaks a bunch of tests.

* fix pydoc complaints

* Add TDD style test that fails in master and passes in my branch

* finish refactor of existing maybe_declare tests to use shared fixtures

* py2/py3 print difference means skip printing.

* fix pep8 line length





* Factor out the binding of channel to entity into a method that can be shared and does not use assert.

* do not use assertion in production because it can be stripped in optimize and is best left for unit tests.

* dont reassign entity here because it breaks a bunch of tests.

* fix pydoc complaints

* Add TDD style test that fails in master and passes in my branch

* finish refactor of existing maybe_declare tests to use shared fixtures

* py2/py3 print difference means skip printing.

* fix pep8 line length







Reintroduce unqiue broadcast queue name generation as optional. (#1033)
2019-03-31T14:37:15+00:00

Omer Katz
omer.drow@gmail.com

2019-03-31T14:37:15+00:00

892f400355e2aae382691c0105cd29c398cc6250












Revert "fix/Broadcast-fail-by-give-queue-kwargs (#906)" (#1031)
2019-03-27T13:51:13+00:00

Omer Katz
omer.drow@gmail.com

2019-03-27T13:51:13+00:00

5e08ad55b11d6e0135558e45de0ce70d1b143ff2

This reverts commit 87d6423289caa776fc10a8d7cdb3d4b741460cfa.




This reverts commit 87d6423289caa776fc10a8d7cdb3d4b741460cfa.






Fix a deprecation warning about logger.warn() (#924)
2018-09-27T13:12:44+00:00

Bruno Alla
browniebroke@users.noreply.github.com

2018-09-27T13:12:44+00:00

62087a67cfbae4e87718fbb917f5140aa66e8287

* Fix a deprecation warning about logger.warn()

This fixes a deprecation warning from the standard library's logging module:

> The 'warn' method is deprecated, use 'warning' instead

* Update test





* Fix a deprecation warning about logger.warn()

This fixes a deprecation warning from the standard library's logging module:

> The 'warn' method is deprecated, use 'warning' instead

* Update test







fix/Broadcast-fail-by-give-queue-kwargs (#906)
2018-08-15T10:59:33+00:00

KUAN Hsuan-Tso
kst920106@gmail.com

2018-08-15T10:59:33+00:00

87d6423289caa776fc10a8d7cdb3d4b741460cfa

* If give queue kwargs broadcast will fail

Because give Broadcast(name='xxx', queue='xxx'),
it will create one specific name for queue,
and if launch more worker for consuming this queue,
this specific name queue already exist then it will not create new queue to
binding fanout exchange.
So all worker will consuming same queue, and exchange only binding this
queue then lose the effect of broadcasting.

* modify test_Broadcast





* If give queue kwargs broadcast will fail

Because give Broadcast(name='xxx', queue='xxx'),
it will create one specific name for queue,
and if launch more worker for consuming this queue,
this specific name queue already exist then it will not create new queue to
binding fanout exchange.
So all worker will consuming same queue, and exchange only binding this
queue then lose the effect of broadcasting.

* modify test_Broadcast