import json
-from tasks.rgw_multi.conn import get_gateway_connection, get_gateway_secure_connection
+from .conn import get_gateway_connection, get_gateway_secure_connection
class Cluster:
""" interface to run commands against a distinct ceph cluster """
from nose.plugins.attrib import attr
from nose.plugins.skip import SkipTest
-from tasks.rgw_multi.multisite import Zone, ZoneGroup, Credentials
+from .multisite import Zone, ZoneGroup, Credentials
-from tasks.rgw_multi.conn import get_gateway_connection
-from tasks.rgw_multi.tools import assert_raises
+from .conn import get_gateway_connection
+from .tools import assert_raises
class Config:
""" test configuration """
from boto.s3.deletemarker import DeleteMarker
-from tasks.rgw_multi.tests import get_realm, \
+from .tests import get_realm, \
ZonegroupConns, \
zonegroup_meta_checkpoint, \
zone_meta_checkpoint, \
get_user, \
get_tenant
-from tasks.rgw_multi.zone_az import print_connection_info
+from .zone_az import print_connection_info
# configure logging for the tests module
from nose.tools import eq_ as eq
-from tasks.rgw_multi.multisite import *
-from tasks.rgw_multi.tests import *
-from tasks.rgw_multi.zone_es import *
+from .multisite import *
+from .tests import *
+from .zone_es import *
log = logging.getLogger(__name__)
import time
import os
from random import randint
-from tasks.rgw_multi.tests import get_realm, \
+from .tests import get_realm, \
ZonegroupConns, \
zonegroup_meta_checkpoint, \
zone_meta_checkpoint, \
gen_bucket_name, \
get_user, \
get_tenant
-from tasks.rgw_multi.zone_ps import PSTopic, \
+from .zone_ps import PSTopic, \
PSTopicS3, \
PSNotification, \
PSSubscription, \
put_object_tagging, \
get_object_tagging, \
delete_all_objects
-from tasks.rgw_multi.multisite import User
+from .multisite import User
from nose import SkipTest
from nose.tools import assert_not_equal, assert_equal
import boto.s3.tagging
import logging
-from tasks.rgw_multi.multisite import Zone
+from .multisite import Zone
log = logging.getLogger('rgw_multi.tests')
from six.moves.urllib.parse import urlparse
-from tasks.rgw_multi.multisite import *
-from tasks.rgw_multi.tools import *
+from .multisite import *
+from .tools import *
log = logging.getLogger(__name__)
except ImportError:
from itertools import zip_longest
-from tasks.rgw_multi.multisite import *
-from tasks.rgw_multi.tools import *
+from .multisite import *
+from .tools import *
log = logging.getLogger(__name__)
from six.moves import http_client
from six.moves.urllib import parse as urlparse
from time import gmtime, strftime
-from tasks.rgw_multi.multisite import Zone
+from .multisite import Zone
import boto3
from botocore.client import Config
from nose.tools import eq_ as eq
-from tasks.rgw_multi.multisite import *
+from .multisite import *
log = logging.getLogger(__name__)