Merge "chore: Sync local (marconi) requirements with global reqs"

This commit is contained in:
Jenkins 2014-01-09 18:00:12 +00:00 committed by Gerrit Code Review
commit c317e646f8
7 changed files with 22 additions and 15 deletions

View File

@ -24,7 +24,8 @@ Serves to construct an association between a project + queue -> shard
""" """
import marconi.openstack.common.log as logging import marconi.openstack.common.log as logging
from marconi.queues.storage import base, errors from marconi.queues.storage import base
from marconi.queues.storage import errors
from marconi.queues.storage.mongodb import utils from marconi.queues.storage.mongodb import utils

View File

@ -27,7 +27,8 @@ Schema:
import functools import functools
from marconi.common import utils as common_utils from marconi.common import utils as common_utils
from marconi.queues.storage import base, errors from marconi.queues.storage import base
from marconi.queues.storage import errors
from marconi.queues.storage.mongodb import utils from marconi.queues.storage.mongodb import utils
SHARDS_INDEX = [ SHARDS_INDEX = [

View File

@ -27,7 +27,8 @@ from marconi.common.transport.wsgi import helpers
from marconi.openstack.common.gettextutils import _ from marconi.openstack.common.gettextutils import _
import marconi.openstack.common.log as logging import marconi.openstack.common.log as logging
from marconi.queues import transport from marconi.queues import transport
from marconi.queues.transport import auth, validation from marconi.queues.transport import auth
from marconi.queues.transport import validation
_WSGI_OPTIONS = [ _WSGI_OPTIONS = [
cfg.StrOpt('bind', default='127.0.0.1', cfg.StrOpt('bind', default='127.0.0.1',

View File

@ -12,15 +12,19 @@
# implied. # implied.
# See the License for the specific language governing permissions and # See the License for the specific language governing permissions and
# limitations under the License. # limitations under the License.
"""marconi-queues (public): handles all the routes for queuing, """marconi-queues public interface.
messaging, and claiming.
Handles all the routes for queuing, messaging, and claiming.
""" """
from marconi.common.transport.wsgi import health from marconi.common.transport.wsgi import health
from marconi.queues.transport.wsgi import ( from marconi.queues.transport.wsgi import claims
claims, driver, messages, metadata, queues, stats, v1, from marconi.queues.transport.wsgi import driver
) from marconi.queues.transport.wsgi import messages
from marconi.queues.transport.wsgi import metadata
from marconi.queues.transport.wsgi import queues
from marconi.queues.transport.wsgi import stats
from marconi.queues.transport.wsgi import v1
class Driver(driver.DriverBase): class Driver(driver.DriverBase):

View File

@ -2,15 +2,15 @@ pbr>=0.5.21,<1.0
Babel>=1.3 Babel>=1.3
netaddr>=0.7.6 netaddr>=0.7.6
falcon>=0.1.6,<0.1.7 falcon>=0.1.6,<0.2.0
jsonschema>=1.3.0,!=1.4.0 jsonschema>=1.3.0,!=1.4.0
iso8601>=0.1.8 iso8601>=0.1.8
msgpack-python msgpack-python
pymongo>=2.4 pymongo>=2.4
python-keystoneclient>=0.4.1 python-keystoneclient>=0.4.1
python-memcached python-memcached>=1.48
WebOb>=1.2.3,<1.3 WebOb>=1.2.3,<1.3
stevedore>=0.10 stevedore>=0.12
six>=1.4.1 six>=1.4.1
oslo.config>=1.2.0 oslo.config>=1.2.0
sqlalchemy>=0.7.8,<=0.7.99 sqlalchemy>=0.7.8,<=0.7.99

View File

@ -1,5 +1,5 @@
# Metrics and style # Metrics and style
hacking>=0.5.6,<0.8 hacking>=0.8.0,<0.9
# Packaging # Packaging
mock>=1.0 mock>=1.0
@ -8,7 +8,7 @@ mock>=1.0
ddt>=0.4.0 ddt>=0.4.0
discover discover
fixtures>=0.3.14 fixtures>=0.3.14
httpretty>=0.6.3 httpretty>=0.7.1
python-subunit python-subunit
testrepository>=0.0.17 testrepository>=0.0.17
testtools>=0.9.32 testtools>=0.9.32

View File

@ -357,7 +357,7 @@ class QueueFaultyDriverTests(base.TestBaseFaulty):
result = self.simulate_get(path + '/metadata', '480924') result = self.simulate_get(path + '/metadata', '480924')
result_doc = json.loads(result[0]) result_doc = json.loads(result[0])
self.assertEqual(self.srmock.status, falcon.HTTP_503) self.assertEqual(self.srmock.status, falcon.HTTP_503)
self.assertNotEquals(result_doc, json.loads(doc)) self.assertNotEqual(result_doc, json.loads(doc))
self.simulate_get(path + '/stats', '480924') self.simulate_get(path + '/stats', '480924')
self.assertEqual(self.srmock.status, falcon.HTTP_503) self.assertEqual(self.srmock.status, falcon.HTTP_503)