Commit Graph

56 Commits

Author SHA1 Message Date
John Koehl 39e733c143 Fixes #791 - SQS queue name gets mangled in Python 2.7 environment (#794)
* Fixes #791

* Changing to recommended patch by @georgepsarakis

* Revert "Fixes #791"

This reverts commit 5593505dd9.

* Updated to make tests pass

* Made _ensure_str a private function

* Code formatting for flake8

* Added a mock of the newstr and newbytes classes to create a failing test that simulates the issue with using python-future under 2.7.
2018-01-28 09:21:05 +02:00
Mads Jensen c13d91634d Removed an always true if-check in t/integration/transport.py (#827) 2018-01-27 11:22:49 +02:00
Arcadiy Ivanov 2f9eb53128 Virtual transport timeout does not supesede period polling (#689)
fixes #688
2018-01-13 22:39:34 +06:00
dust8 e209fa6f84 Fixed ValueError caused by mongodb rc version: invalid literal for in… (#816)
* Fixed ValueError caused by mongodb rc version: invalid literal for int () with base 10

* add test fix ValueError caused by mongodb rc version
2018-01-13 20:52:52 +06:00
Omer Katz 3a7cdb07c9
Make flake8 happy. 2017-12-17 12:15:42 +02:00
Mads Jensen 65d203c71e Prefer dict literal syntax over dict() (#787)
* Prefer dict literal syntax over dict()

* An overlooked dict-constructor in transport/SQS.py
2017-09-08 07:43:59 +03:00
David Davis 2a161a4408 Make messages durable by default in qpid (#785)
We were seeing messages disappear in durable queues when restarting
qpid. This coincides with the rabbitmq code (e.g. https://git.io/v7jNV).
2017-08-20 14:32:10 +03:00
Anthony Lukach 0f4da8d450 Pass connection options from broker_options to default_channel (#769)
* Pass connection options from broker_options to default_channel (fixes #765)

* Fixup

* Fixup
2017-08-02 12:06:47 +03:00
Anthony Lukach b1e6fa5bb1 Fix SQS requests and response handling (#754)
* Fix SQS requests and response handling

* Accurately portray empty message response
2017-07-17 18:22:40 +03:00
Gabriel Amram b2f2128928 Fix infinite loop in create_loop (#760)
* Fix infinite loop in create_loop

fixes https://github.com/celery/celery/issues/3712 

Before handling the todo items we "freeze" them by copying them aside and clearing the list.
This way if an item in the todo list appends a new callable to the list itself it will be taken care of in the next iteration of the parent loop instead of producing an infinite loop by adding it to the list we're running on.

* Changed the test to be aligned with the new implementation

* passing flake8

* Avoid copying results with each iteration of the async loop.

* Pop instead of slicing.

* fixed: todos -> todo, fixed test to use MagicMock so we can use the len() method

* MagicMock not supported in 2.7, implemented __len__ on Mock instead

* added entry to changelog
2017-07-10 21:21:49 +03:00
Mikhail Elovskikh ba873ba4f2 Fix readpreference option parsing in MongoDB transport (#751)
* Fix readpreference option parsing in MongoDB transport

* Update changelog
2017-06-08 22:41:15 +06:00
Amin Ghadersohi be79b3d4cd Re-Adding support for sqlalchemy as it is needed by Apache project Airflow (#687)
* Re-Adding support for sqlalchemy as it is needed by Apache project Airflow

* Re-Adding support for sqlalchemy as it is needed by Apache project Airflow
2017-05-17 14:17:47 +06:00
Anthony Lukach 25a9e76f3a Prevent SQS from defaulting to localhost hostname (#733)
* Prevent SQS from defaulting to localhost hostname

* Ensure cloned connection maintains NoneType hostname
2017-05-05 21:40:57 +06:00
George Psarakis da047e9c3b Parse password from Redis transport URL (#710) 2017-04-27 10:47:37 +03:00
George Psarakis 259ac2e2bf Add missing function import 2017-04-26 21:44:34 +03:00
George Psarakis a875363730 Test cases for generate_oid 2017-04-26 21:44:34 +03:00
Dima Kurguzov 221685618f Refactor chroot normalization 2017-04-21 19:29:21 +03:00
Dima Kurguzov 5f35ef996c Fix last chroot character trimming 2017-04-21 19:29:21 +03:00
Jon Dufresne f4fda3858f Remove print from tests; looks like it was left in from debugging (#719) 2017-04-17 10:24:00 +06:00
georgepsarakis 90149e4c5c PEP8 fix 2017-04-16 11:28:24 +03:00
georgepsarakis b701805cfc Re-enable unit tests and add case for endpoint URL property 2017-04-16 11:28:24 +03:00
Anthony Lukach 6c3bb07e19 Bugfix: Support Python 3.4, decode from base64 when converting messag… (#714)
* Bugfix: Support Python 3.4, decode from base64 when converting message to Python

* Use str_to_bytes
2017-04-14 23:43:06 +06:00
Mischa Spiegelmock 129a9e4ed0 Switching to boto3 only (#693)
* Switch Boto2 to Boto3 for SQS messaging

* Fixed region support

* Add SQS FIFO queue support

* Add sensible defaults for message attributes

* Asynchronous support, plus boto3 for region endpoint lookups

* Clean up imports

* Fix Python 2 support

* Fix receive_message tests

* Reformat docstring

* boto3 import changes for CI

* skip tests if boto3 not installed

* skip tests if boto3 not installed

* flake8

* noboto

* ditching boto2. got queue URL fetching, async HTTP request generation and signing working.

* request signing working kinda

* async parsing of SQS message response more or less working

* botocore sqs dep

* ripping out more old boto2 stuff

* removing tests that are no longer valid with boto3/SQS

* fix boto3 dep, min version and no botocore

* no boto2 for test

* cleaning up some SQS tests. fixing header parsing of response to msg

* fixing some sqs tests

* removing response-parsing tests that are no longer necessary as we're using the botocore response parsing machinery instead of implementing SAX parsing in kombu.

* fixing more SQS tests

* wants a region

* trying to fix py2 parsing of sqs message

* lint

* py2/py2 message header parsing stupidness

* forgot

* python 2 sux

* flake8

* Import boto3 from the right place

* Changes

* Update encode fuction

* Fix lint

* remove some unused things

* removing unused stuff

* ugh

* ugh

* ugh

* landscape ignoring

* shut up, landscape
2017-04-14 11:22:18 +06:00
Dima Kurguzov bf820b20b0 Fix byte string for kazoo.Queue in Python 3 (#713)
* Fix byte string for kazoo.Queue in Python 3

* Add test for message conversion to bytes in ZooKeeper channel
2017-04-12 11:24:04 +06:00
Jerry Seutter e2322998fc Fix a broken test in python 3 (#674) 2016-12-24 15:34:28 +06:00
Ask Solem 1464a2afbe Redis: Fixes priority tests 2016-12-08 17:06:12 -08:00
Ask Solem 5a028a6906 Fixes failing test case 2016-12-07 15:58:56 -08:00
Ask Solem 8a7ea091bf Consumer: __exit__ should not cancel if connection error (Closes #670) 2016-12-07 14:28:16 -08:00
Ask Solem e03cbbe0d8 Fixes Qpid tests 2016-12-07 14:25:49 -08:00
Ask Solem 4fd70fbda8 Fixes mongodb tests 2016-12-07 14:24:53 -08:00
Ask Solem f6b0e7267a flakes 2016-10-28 16:22:45 -07:00
Ask Solem a7fda57557 Try to fix test suite 2016-10-28 16:17:13 -07:00
Ask Solem 5946409b9c Fixes SQS tests 2016-10-28 16:07:19 -07:00
Ask Solem baeef7ac1a Ports Qpid unit tests to pytest 2016-10-28 15:46:25 -07:00
Ask Solem fb46262ee5 Signature of Message is now Message(body, channel=), not Message(channel, body=) 2016-10-27 16:55:40 -07:00
Ask Solem ded6f0c873 Entities can now be declared without binding to channel: entity.declare(channel=channel) 2016-10-27 14:22:19 -07:00
Ask Solem 719cd7b2af Producer.auto_declare now declares on first publish 2016-10-26 17:41:50 -07:00
Ask Solem 3dec40a007 Adds Queue.expires,.message_ttl,.max_length,.max_length_bytes,.max_priority (Issue #629) 2016-10-14 16:53:03 -07:00
Ask Solem 9de4785dd9 Merge branch 'master' of github.com:celery/kombu 2016-10-05 16:14:53 -07:00
Ask Solem 03790d3afc Removes kombu.syn, moves detect_environment to utils.compat 2016-10-05 16:14:42 -07:00
bkolba 25773274c6 Fix Redis SSL support (#634)
* Fix Redis SSL support

- setting connparams[‘ssl’] = True will cause an unexpected keyword
exception when initializing a redis Connection or SSLConnection
- connection_class must be redis.SSLConnection. The base Connection
class does not support SSL parameters.
- Update the comment and tests to reflect the required format since it
is different than amqplib

* Flake8
2016-10-01 00:50:24 +06:00
Ask Solem 31adb300dc conftest: Use generator fixtures 2016-09-29 14:57:42 -07:00
Ask Solem 9f507fa0e9 flakes 2016-09-29 13:10:10 -07:00
Ask Solem 47d2ec9ec3 Redis: Radical attempt at fixing #623 2016-09-29 12:28:14 -07:00
Ask Solem d21847a32c Redis: Fixes tests 2016-09-28 16:52:38 -07:00
Ask Solem ed783a02ef Small changes to #598 2016-09-07 17:33:49 -07:00
Alan Justino 74f0180576 Some python versions have no 'buffer' builtin 2016-09-07 17:30:18 -07:00
Alan Justino fd1cea31ca hashlig _digest() works only with bytes 2016-09-07 17:30:13 -07:00
Alan Justino c17861e574 Some Python versions have no string.letters 2016-09-07 17:30:06 -07:00
Ask Solem 701672c2ba Adds support for amqps:// to use pyamqp with ssl=True. Closes #610 2016-09-07 17:21:22 -07:00