Rename namespace -> platform in scenarios

- It's better to provide this paramter explicitly, otherwise for
  anybody newbie it'ss going to be hard to understand that
  this plugins is related to openstack platform. As well it's
  actually part of full name: "<name>@<platform>"

- Fix all places

Change-Id: I15b5ba8b33c542cc3f642dc7940a2eb1677ffefb
This commit is contained in:
Boris Pavlovic 2017-07-21 19:11:17 -07:00
parent 752e2f1618
commit e6a17e6f3b
57 changed files with 605 additions and 352 deletions

View File

@ -21,7 +21,7 @@ from osprofiler import profiler
from rally import osclients
from rally.task import scenario
configure = functools.partial(scenario.configure, namespace="openstack")
configure = functools.partial(scenario.configure, platform="openstack")
CONF = cfg.CONF

View File

@ -22,7 +22,7 @@ from rally.task import validation
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="Authenticate.keystone")
@scenario.configure(name="Authenticate.keystone", platform="openstack")
class Keystone(scenario.OpenStackScenario):
@atomic.action_timer("authenticate.keystone")
@ -33,7 +33,7 @@ class Keystone(scenario.OpenStackScenario):
@validation.add("number", param_name="repetitions", minval=1)
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="Authenticate.validate_glance")
@scenario.configure(name="Authenticate.validate_glance", platform="openstack")
class ValidateGlance(scenario.OpenStackScenario):
def run(self, repetitions):
@ -56,7 +56,7 @@ class ValidateGlance(scenario.OpenStackScenario):
@validation.add("number", param_name="repetitions", minval=1)
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="Authenticate.validate_nova")
@scenario.configure(name="Authenticate.validate_nova", platform="openstack")
class ValidateNova(scenario.OpenStackScenario):
def run(self, repetitions):
@ -77,7 +77,8 @@ class ValidateNova(scenario.OpenStackScenario):
@validation.add("number", param_name="repetitions", minval=1)
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="Authenticate.validate_ceilometer")
@scenario.configure(name="Authenticate.validate_ceilometer",
platform="openstack")
class ValidateCeilometer(scenario.OpenStackScenario):
def run(self, repetitions):
@ -98,7 +99,7 @@ class ValidateCeilometer(scenario.OpenStackScenario):
@validation.add("number", param_name="repetitions", minval=1)
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="Authenticate.validate_cinder")
@scenario.configure(name="Authenticate.validate_cinder", platform="openstack")
class ValidateCinder(scenario.OpenStackScenario):
def run(self, repetitions):
@ -119,7 +120,7 @@ class ValidateCinder(scenario.OpenStackScenario):
@validation.add("number", param_name="repetitions", minval=1)
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="Authenticate.validate_neutron")
@scenario.configure(name="Authenticate.validate_neutron", platform="openstack")
class ValidateNeutron(scenario.OpenStackScenario):
def run(self, repetitions):
@ -140,7 +141,7 @@ class ValidateNeutron(scenario.OpenStackScenario):
@validation.add("number", param_name="repetitions", minval=1)
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="Authenticate.validate_heat")
@scenario.configure(name="Authenticate.validate_heat", platform="openstack")
class ValidateHeat(scenario.OpenStackScenario):
def run(self, repetitions):
@ -163,7 +164,7 @@ class ValidateHeat(scenario.OpenStackScenario):
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_services",
services=[consts.Service.MONASCA])
@scenario.configure(name="Authenticate.validate_monasca")
@scenario.configure(name="Authenticate.validate_monasca", platform="openstack")
class ValidateMonasca(scenario.OpenStackScenario):
def run(self, repetitions):

View File

@ -24,7 +24,8 @@ from rally.task import validation
services=[consts.Service.CEILOMETER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["ceilometer"]},
name="CeilometerAlarms.create_alarm")
name="CeilometerAlarms.create_alarm",
platform="openstack")
class CreateAlarm(ceiloutils.CeilometerScenario):
def run(self, meter_name, threshold, **kwargs):
@ -46,7 +47,7 @@ class CreateAlarm(ceiloutils.CeilometerScenario):
@validation.add("required_services",
services=[consts.Service.CEILOMETER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="CeilometerAlarms.list_alarms")
@scenario.configure(name="CeilometerAlarms.list_alarms", platform="openstack")
class ListAlarms(ceiloutils.CeilometerScenario):
def run(self):
@ -61,7 +62,8 @@ class ListAlarms(ceiloutils.CeilometerScenario):
services=[consts.Service.CEILOMETER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["ceilometer"]},
name="CeilometerAlarms.create_and_list_alarm")
name="CeilometerAlarms.create_and_list_alarm",
platform="openstack")
class CreateAndListAlarm(ceiloutils.CeilometerScenario):
def run(self, meter_name, threshold, **kwargs):
@ -86,7 +88,8 @@ class CreateAndListAlarm(ceiloutils.CeilometerScenario):
services=[consts.Service.CEILOMETER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["ceilometer"]},
name="CeilometerAlarms.create_and_get_alarm")
name="CeilometerAlarms.create_and_get_alarm",
platform="openstack")
class CreateAndGetAlarm(ceiloutils.CeilometerScenario):
def run(self, meter_name, threshold, **kwargs):
@ -111,7 +114,8 @@ class CreateAndGetAlarm(ceiloutils.CeilometerScenario):
services=[consts.Service.CEILOMETER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["ceilometer"]},
name="CeilometerAlarms.create_and_update_alarm")
name="CeilometerAlarms.create_and_update_alarm",
platform="openstack")
class CreateAndUpdateAlarm(ceiloutils.CeilometerScenario):
def run(self, meter_name, threshold, **kwargs):
@ -136,7 +140,8 @@ class CreateAndUpdateAlarm(ceiloutils.CeilometerScenario):
services=[consts.Service.CEILOMETER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["ceilometer"]},
name="CeilometerAlarms.create_and_delete_alarm")
name="CeilometerAlarms.create_and_delete_alarm",
platform="openstack")
class CreateAndDeleteAlarm(ceiloutils.CeilometerScenario):
def run(self, meter_name, threshold, **kwargs):
@ -160,7 +165,8 @@ class CreateAndDeleteAlarm(ceiloutils.CeilometerScenario):
services=[consts.Service.CEILOMETER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["ceilometer"]},
name="CeilometerAlarms.create_alarm_and_get_history")
name="CeilometerAlarms.create_alarm_and_get_history",
platform="openstack")
class CreateAlarmAndGetHistory(ceiloutils.CeilometerScenario):
def run(self, meter_name, threshold, state, timeout=60, **kwargs):

View File

@ -32,7 +32,8 @@ from rally.task import validation
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"],
"cleanup": ["ceilometer"]},
name="CeilometerEvents.create_user_and_list_events")
name="CeilometerEvents.create_user_and_list_events",
platform="openstack")
class CeilometerEventsCreateUserAndListEvents(cutils.CeilometerScenario,
kbasic.KeystoneBasic):
@ -54,7 +55,8 @@ class CeilometerEventsCreateUserAndListEvents(cutils.CeilometerScenario,
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"],
"cleanup": ["ceilometer"]},
name="CeilometerEvents.create_user_and_list_event_types")
name="CeilometerEvents.create_user_and_list_event_types",
platform="openstack")
class CeilometerEventsCreateUserAndListEventTypes(cutils.CeilometerScenario,
kbasic.KeystoneBasic):
@ -76,7 +78,8 @@ class CeilometerEventsCreateUserAndListEventTypes(cutils.CeilometerScenario,
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"],
"cleanup": ["ceilometer"]},
name="CeilometerEvents.create_user_and_get_event")
name="CeilometerEvents.create_user_and_get_event",
platform="openstack")
class CeilometerEventsCreateUserAndGetEvent(cutils.CeilometerScenario,
kbasic.KeystoneBasic):

View File

@ -25,7 +25,7 @@ from rally.task import validation
services=[consts.Service.CEILOMETER])
@validation.add("required_contexts", contexts=("ceilometer"))
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="CeilometerMeters.list_meters")
@scenario.configure(name="CeilometerMeters.list_meters", platform="openstack")
class ListMeters(ceiloutils.CeilometerScenario):
def run(self, metadata_query=None, limit=None):
@ -49,7 +49,8 @@ class ListMeters(ceiloutils.CeilometerScenario):
services=[consts.Service.CEILOMETER])
@validation.add("required_contexts", contexts=("ceilometer"))
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="CeilometerMeters.list_matched_meters")
@scenario.configure(name="CeilometerMeters.list_matched_meters",
platform="openstack")
class ListMatchedMeters(ceiloutils.CeilometerScenario):
def run(self, filter_by_user_id=False, filter_by_project_id=False,

View File

@ -27,7 +27,8 @@ from rally.task import validation
services=[consts.Service.CEILOMETER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["ceilometer"]},
name="CeilometerQueries.create_and_query_alarms")
name="CeilometerQueries.create_and_query_alarms",
platform="openstack")
class CeilometerQueriesCreateAndQueryAlarms(ceiloutils.CeilometerScenario):
def run(self, meter_name, threshold, filter=None, orderby=None,
@ -55,7 +56,8 @@ class CeilometerQueriesCreateAndQueryAlarms(ceiloutils.CeilometerScenario):
services=[consts.Service.CEILOMETER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["ceilometer"]},
name="CeilometerQueries.create_and_query_alarm_history")
name="CeilometerQueries.create_and_query_alarm_history",
platform="openstack")
class CeilometerQueriesCreateAndQueryAlarmHistory(ceiloutils
.CeilometerScenario):
@ -81,7 +83,8 @@ class CeilometerQueriesCreateAndQueryAlarmHistory(ceiloutils
services=[consts.Service.CEILOMETER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["ceilometer"]},
name="CeilometerQueries.create_and_query_samples")
name="CeilometerQueries.create_and_query_samples",
platform="openstack")
class CeilometerQueriesCreateAndQuerySamples(ceiloutils.CeilometerScenario):
def run(self, counter_name, counter_type, counter_unit, counter_volume,

View File

@ -25,7 +25,8 @@ from rally.task import validation
services=[consts.Service.CEILOMETER])
@validation.add("required_contexts", contexts=("ceilometer"))
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="CeilometerResource.list_resources")
@scenario.configure(name="CeilometerResource.list_resources",
platform="openstack")
class ListResources(ceiloutils.CeilometerScenario):
def run(self, metadata_query=None, start_time=None,
@ -58,7 +59,8 @@ class ListResources(ceiloutils.CeilometerScenario):
@validation.add("required_services",
services=[consts.Service.CEILOMETER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="CeilometerResource.get_tenant_resources")
@scenario.configure(name="CeilometerResource.get_tenant_resources",
platform="openstack")
class GetTenantResources(ceiloutils.CeilometerScenario):
def run(self):
@ -79,7 +81,8 @@ class GetTenantResources(ceiloutils.CeilometerScenario):
services=[consts.Service.CEILOMETER])
@validation.add("required_contexts", contexts=("ceilometer"))
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="CeilometerResource.list_matched_resources")
@scenario.configure(name="CeilometerResource.list_matched_resources",
platform="openstack")
class ListMatchedResources(ceiloutils.CeilometerScenario):
def run(self, filter_by_user_id=False, filter_by_project_id=False,

View File

@ -25,7 +25,8 @@ from rally.task import validation
services=[consts.Service.CEILOMETER])
@validation.add("required_contexts", contexts=("ceilometer"))
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="CeilometerSamples.list_matched_samples")
@scenario.configure(name="CeilometerSamples.list_matched_samples",
platform="openstack")
class ListMatchedSamples(ceiloutils.CeilometerScenario):
def run(self, filter_by_resource_id=False, filter_by_project_id=False,
@ -49,7 +50,8 @@ class ListMatchedSamples(ceiloutils.CeilometerScenario):
services=[consts.Service.CEILOMETER])
@validation.add("required_contexts", contexts=("ceilometer"))
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="CeilometerSamples.list_samples")
@scenario.configure(name="CeilometerSamples.list_samples",
platform="openstack")
class ListSamples(ceiloutils.CeilometerScenario):
def run(self, metadata_query=None, limit=None):

View File

@ -25,7 +25,8 @@ from rally.task import validation
@validation.add("required_services",
services=[consts.Service.CEILOMETER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="CeilometerStats.create_meter_and_get_stats")
@scenario.configure(name="CeilometerStats.create_meter_and_get_stats",
platform="openstack")
class CreateMeterAndGetStats(utils.CeilometerScenario):
@logging.log_deprecated("Use 'get_stats' method, now samples are created"
@ -46,7 +47,7 @@ class CreateMeterAndGetStats(utils.CeilometerScenario):
services=[consts.Service.CEILOMETER])
@validation.add("required_contexts", contexts=("ceilometer"))
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="CeilometerStats.get_stats")
@scenario.configure(name="CeilometerStats.get_stats", platform="openstack")
class GetStats(utils.CeilometerScenario):
def run(self, meter_name, filter_by_user_id=False,

View File

@ -31,7 +31,8 @@ from rally.task import validation
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"],
"cleanup": ["ceilometer"]},
name="CeilometerTraits.create_user_and_list_traits")
name="CeilometerTraits.create_user_and_list_traits",
platform="openstack")
class CreateUserAndListTraits(cutils.CeilometerScenario,
kbasic.KeystoneBasic):
@ -55,7 +56,8 @@ class CreateUserAndListTraits(cutils.CeilometerScenario,
@scenario.configure(context={"admin_cleanup": ["keystone"],
"cleanup": ["ceilometer"]},
name="CeilometerTraits.create_user_and"
"_list_trait_descriptions")
"_list_trait_descriptions",
platform="openstack")
class CreateUserAndListTraitDescriptions(
cutils.CeilometerScenario, kbasic.KeystoneBasic):

View File

@ -24,7 +24,7 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["cinder"]},
name="CinderQos.create_and_list_qos")
name="CinderQos.create_and_list_qos", platform="openstack")
class CreateAndListQos(cinder_utils.CinderBasic):
def run(self, consumer, write_iops_sec, read_iops_sec):
"""Create a qos, then list all qos.
@ -51,7 +51,7 @@ class CreateAndListQos(cinder_utils.CinderBasic):
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["cinder"]},
name="CinderQos.create_and_get_qos")
name="CinderQos.create_and_get_qos", platform="openstack")
class CreateAndGetQos(cinder_utils.CinderBasic):
def run(self, consumer, write_iops_sec, read_iops_sec):
"""Create a qos, then get details of the qos.
@ -73,7 +73,7 @@ class CreateAndGetQos(cinder_utils.CinderBasic):
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["cinder"]},
name="CinderQos.create_and_set_qos")
name="CinderQos.create_and_set_qos", platform="openstack")
class CreateAndSetQos(cinder_utils.CinderBasic):
def run(self, consumer, write_iops_sec, read_iops_sec,
set_consumer, set_write_iops_sec, set_read_iops_sec):

View File

@ -31,7 +31,7 @@ from rally.task import validation
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumeBackups."
"create_incremental_volume_backup")
"create_incremental_volume_backup", platform="openstack")
class CreateIncrementalVolumeBackup(cinder_utils.CinderBasic):
def run(self, size, do_delete=True, create_volume_kwargs=None,
create_backup_kwargs=None):

View File

@ -29,7 +29,8 @@ LOG = logging.getLogger(__name__)
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["cinder"]},
name="CinderVolumeTypes.create_and_delete_volume_type")
name="CinderVolumeTypes.create_and_delete_volume_type",
platform="openstack")
class CreateAndDeleteVolumeType(cinder_utils.CinderBasic):
def run(self, description=None, is_public=True):
@ -47,7 +48,8 @@ class CreateAndDeleteVolumeType(cinder_utils.CinderBasic):
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["cinder"]},
name="CinderVolumeTypes.create_and_get_volume_type")
name="CinderVolumeTypes.create_and_get_volume_type",
platform="openstack")
class CreateAndGetVolumeType(cinder_utils.CinderBasic):
def run(self, description=None, is_public=True):
@ -66,7 +68,8 @@ class CreateAndGetVolumeType(cinder_utils.CinderBasic):
@validation.add("required_api_versions", component="cinder", versions=["2"])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["cinder"]},
name="CinderVolumeTypes.create_and_update_volume_type")
name="CinderVolumeTypes.create_and_update_volume_type",
platform="openstack")
class CreateAndUpdateVolumeType(scenario.OpenStackScenario):
def run(self, description=None, is_public=True, update_name=False,
@ -98,7 +101,8 @@ class CreateAndUpdateVolumeType(scenario.OpenStackScenario):
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["cinder"]},
name="CinderVolumeTypes.create_and_list_volume_types")
name="CinderVolumeTypes.create_and_list_volume_types",
platform="openstack")
class CreateAndListVolumeTypes(cinder_utils.CinderBasic):
def run(self, description=None, is_public=True):
@ -125,7 +129,8 @@ class CreateAndListVolumeTypes(cinder_utils.CinderBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["cinder"]},
name="CinderVolumeTypes.create_volume_type"
"_and_encryption_type")
"_and_encryption_type",
platform="openstack")
class CreateVolumeTypeAndEncryptionType(cinder_utils.CinderBasic):
def run(self, create_specs=None, provider=None, cipher=None,
@ -172,7 +177,8 @@ class CreateVolumeTypeAndEncryptionType(cinder_utils.CinderBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["cinder"]},
name="CinderVolumeTypes.create_and_list_"
"encryption_type")
"encryption_type",
platform="openstack")
class CreateAndListEncryptionType(cinder_utils.CinderBasic):
def run(self, create_specs=None, provider=None, cipher=None,
@ -216,7 +222,8 @@ class CreateAndListEncryptionType(cinder_utils.CinderBasic):
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["cinder"]},
name="CinderVolumeTypes.create_and_set_volume_type_keys")
name="CinderVolumeTypes.create_and_set_volume_type_keys",
platform="openstack")
class CreateAndSetVolumeTypeKeys(cinder_utils.CinderBasic):
def run(self, volume_type_key, description=None, is_public=True):
@ -238,7 +245,8 @@ class CreateAndSetVolumeTypeKeys(cinder_utils.CinderBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["cinder"]},
name="CinderVolumeTypes.create_get_and_delete_"
"encryption_type")
"encryption_type",
platform="openstack")
class CreateGetAndDeleteEncryptionType(cinder_utils.CinderBasic):
def run(self, provider=None, cipher=None,
@ -278,7 +286,8 @@ class CreateGetAndDeleteEncryptionType(cinder_utils.CinderBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["cinder"]},
name="CinderVolumeTypes.create_and_delete_"
"encryption_type")
"encryption_type",
platform="openstack")
class CreateAndDeleteEncryptionType(cinder_utils.CinderBasic):
def run(self, create_specs=None, provider=None, cipher=None,
@ -320,7 +329,8 @@ class CreateAndDeleteEncryptionType(cinder_utils.CinderBasic):
@validation.add("required_contexts", contexts="volume_types")
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["cinder"]},
name="CinderVolumeTypes.create_and_update_encryption_type")
name="CinderVolumeTypes.create_and_update_encryption_type",
platform="openstack")
class CreateAndUpdateEncryptionType(cinder_utils.CinderBasic):
def run(self, create_provider=None, create_cipher=None,
@ -373,7 +383,8 @@ class CreateAndUpdateEncryptionType(cinder_utils.CinderBasic):
@validation.add("required_services", services=consts.Service.CINDER)
@scenario.configure(context={"admin_cleanup": ["cinder"]},
name="CinderVolumeTypes.create_volume_type_"
"add_and_list_type_access")
"add_and_list_type_access",
platform="openstack")
class CreateVolumeTypeAddAndListTypeAccess(scenario.OpenStackScenario):
def run(self, description=None, is_public=False):

View File

@ -37,7 +37,8 @@ LOG = logging.getLogger(__name__)
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_and_list_volume")
name="CinderVolumes.create_and_list_volume",
platform="openstack")
class CreateAndListVolume(cinder_utils.CinderBasic):
def run(self, size, detailed=True, image=None, **kwargs):
@ -73,7 +74,8 @@ class CreateAndListVolume(cinder_utils.CinderBasic):
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_and_get_volume")
name="CinderVolumes.create_and_get_volume",
platform="openstack")
class CreateAndGetVolume(cinder_utils.CinderBasic):
def run(self, size, image=None, **kwargs):
@ -98,7 +100,8 @@ class CreateAndGetVolume(cinder_utils.CinderBasic):
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.list_volumes")
name="CinderVolumes.list_volumes",
platform="openstack")
class ListVolumes(cinder_utils.CinderBasic):
def run(self, detailed=True):
@ -116,7 +119,7 @@ class ListVolumes(cinder_utils.CinderBasic):
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="CinderVolumes.list_types")
@scenario.configure(name="CinderVolumes.list_types", platform="openstack")
class ListTypes(cinder_utils.CinderBasic):
def run(self, search_opts=None, is_public=None):
@ -134,7 +137,7 @@ class ListTypes(cinder_utils.CinderBasic):
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="CinderVolumes.list_transfers")
@scenario.configure(name="CinderVolumes.list_transfers", platform="openstack")
class ListTransfers(cinder_utils.CinderBasic):
def run(self, detailed=True, search_opts=None):
@ -160,7 +163,8 @@ class ListTransfers(cinder_utils.CinderBasic):
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_and_update_volume")
name="CinderVolumes.create_and_update_volume",
platform="openstack")
class CreateAndUpdateVolume(cinder_utils.CinderBasic):
def run(self, size, image=None, create_volume_kwargs=None,
@ -194,7 +198,8 @@ class CreateAndUpdateVolume(cinder_utils.CinderBasic):
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_and_delete_volume")
name="CinderVolumes.create_and_delete_volume",
platform="openstack")
class CreateAndDeleteVolume(cinder_utils.CinderBasic):
def run(self, size, image=None, min_sleep=0, max_sleep=0, **kwargs):
@ -230,7 +235,8 @@ class CreateAndDeleteVolume(cinder_utils.CinderBasic):
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_volume")
name="CinderVolumes.create_volume",
platform="openstack")
class CreateVolume(cinder_utils.CinderBasic):
def run(self, size, image=None, **kwargs):
@ -256,7 +262,8 @@ class CreateVolume(cinder_utils.CinderBasic):
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_contexts", contexts=("volumes"))
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.modify_volume_metadata")
name="CinderVolumes.modify_volume_metadata",
platform="openstack")
class ModifyVolumeMetadata(cinder_utils.CinderBasic):
def run(self, sets=10, set_size=3, deletes=5, delete_size=3):
@ -292,7 +299,8 @@ class ModifyVolumeMetadata(cinder_utils.CinderBasic):
@validation.add("restricted_parameters", param_names=["name", "display_name"])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_and_extend_volume")
name="CinderVolumes.create_and_extend_volume",
platform="openstack")
class CreateAndExtendVolume(cinder_utils.CinderBasic):
def run(self, size, new_size, min_sleep=0, max_sleep=0, **kwargs):
@ -326,7 +334,8 @@ class CreateAndExtendVolume(cinder_utils.CinderBasic):
@validation.add("required_contexts", contexts=("volumes"))
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_from_volume_and_delete_volume")
name="CinderVolumes.create_from_volume_and_delete_volume",
platform="openstack")
class CreateFromVolumeAndDeleteVolume(cinder_utils.CinderBasic):
def run(self, size, min_sleep=0, max_sleep=0, **kwargs):
@ -360,7 +369,8 @@ class CreateFromVolumeAndDeleteVolume(cinder_utils.CinderBasic):
@validation.add("required_contexts", contexts=("volumes"))
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_and_delete_snapshot")
name="CinderVolumes.create_and_delete_snapshot",
platform="openstack")
class CreateAndDeleteSnapshot(cinder_utils.CinderBasic):
def run(self, force=False, min_sleep=0, max_sleep=0, **kwargs):
@ -395,7 +405,8 @@ class CreateAndDeleteSnapshot(cinder_utils.CinderBasic):
consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder", "nova"]},
name="CinderVolumes.create_and_attach_volume")
name="CinderVolumes.create_and_attach_volume",
platform="openstack")
class CreateAndAttachVolume(cinder_utils.CinderBasic,
nova_utils.NovaScenario):
@ -445,7 +456,8 @@ class CreateAndAttachVolume(cinder_utils.CinderBasic,
@validation.add("volume_type_exists", param_name="volume_type", nullable=True)
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder", "nova"]},
name="CinderVolumes.create_snapshot_and_attach_volume")
name="CinderVolumes.create_snapshot_and_attach_volume",
platform="openstack")
class CreateSnapshotAndAttachVolume(cinder_utils.CinderBasic,
nova_utils.NovaScenario):
@ -485,7 +497,8 @@ class CreateSnapshotAndAttachVolume(cinder_utils.CinderBasic,
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder", "nova"]},
name="CinderVolumes.create_nested_snapshots"
"_and_attach_volume")
"_and_attach_volume",
platform="openstack")
class CreateNestedSnapshotsAndAttachVolume(cinder_utils.CinderBasic,
nova_utils.NovaScenario):
@ -551,7 +564,8 @@ class CreateNestedSnapshotsAndAttachVolume(cinder_utils.CinderBasic,
@validation.add("required_contexts", contexts=("volumes"))
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_and_list_snapshots")
name="CinderVolumes.create_and_list_snapshots",
platform="openstack")
class CreateAndListSnapshots(cinder_utils.CinderBasic,
nova_utils.NovaScenario):
@ -575,7 +589,8 @@ class CreateAndListSnapshots(cinder_utils.CinderBasic,
@validation.add("restricted_parameters", param_names=["name", "display_name"])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder", "glance"]},
name="CinderVolumes.create_and_upload_volume_to_image")
name="CinderVolumes.create_and_upload_volume_to_image",
platform="openstack")
class CreateAndUploadVolumeToImage(cinder_utils.CinderBasic,
images.GlanceBasic):
@ -615,7 +630,8 @@ class CreateAndUploadVolumeToImage(cinder_utils.CinderBasic,
@validation.add("required_cinder_services", services="cinder-backup")
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_volume_backup")
name="CinderVolumes.create_volume_backup",
platform="openstack")
class CreateVolumeBackup(cinder_utils.CinderBasic):
def run(self, size, do_delete=True, create_volume_kwargs=None,
@ -647,7 +663,8 @@ class CreateVolumeBackup(cinder_utils.CinderBasic):
@validation.add("required_cinder_services", services="cinder-backup")
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_and_restore_volume_backup")
name="CinderVolumes.create_and_restore_volume_backup",
platform="openstack")
class CreateAndRestoreVolumeBackup(cinder_utils.CinderBasic):
def run(self, size, do_delete=True, create_volume_kwargs=None,
@ -680,7 +697,8 @@ class CreateAndRestoreVolumeBackup(cinder_utils.CinderBasic):
@validation.add("required_cinder_services", services="cinder-backup")
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_and_list_volume_backups")
name="CinderVolumes.create_and_list_volume_backups",
platform="openstack")
class CreateAndListVolumeBackups(cinder_utils.CinderBasic):
def run(self, size, detailed=True, do_delete=True,
@ -712,7 +730,8 @@ class CreateAndListVolumeBackups(cinder_utils.CinderBasic):
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_volume_and_clone")
name="CinderVolumes.create_volume_and_clone",
platform="openstack")
class CreateVolumeAndClone(cinder_utils.CinderBasic):
def run(self, size, image=None, nested_level=1, **kwargs):
@ -754,7 +773,8 @@ class CreateVolumeAndClone(cinder_utils.CinderBasic):
@validation.add("required_contexts", contexts=("volumes"))
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_volume_from_snapshot")
name="CinderVolumes.create_volume_from_snapshot",
platform="openstack")
class CreateVolumeFromSnapshot(cinder_utils.CinderBasic):
def run(self, do_delete=True, create_snapshot_kwargs=None, **kwargs):
@ -786,7 +806,8 @@ class CreateVolumeFromSnapshot(cinder_utils.CinderBasic):
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_volume_"
"and_update_readonly_flag")
"and_update_readonly_flag",
platform="openstack")
class CreateVolumeAndUpdateReadonlyFlag(cinder_utils.CinderBasic):
def run(self, size, image=None, read_only=True, **kwargs):
@ -810,7 +831,8 @@ class CreateVolumeAndUpdateReadonlyFlag(cinder_utils.CinderBasic):
@validation.add("required_services", services=[consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder"]},
name="CinderVolumes.create_and_accept_transfer")
name="CinderVolumes.create_and_accept_transfer",
platform="openstack")
class CreateAndAcceptTransfer(cinder_utils.CinderBasic):
def run(self, size, image=None, **kwargs):

View File

@ -28,7 +28,8 @@ from rally.task import validation
services=[consts.Service.DESIGNATE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["designate"]},
name="DesignateBasic.create_and_list_domains")
name="DesignateBasic.create_and_list_domains",
platform="openstack")
class CreateAndListDomains(utils.DesignateScenario):
def run(self):
@ -53,7 +54,8 @@ class CreateAndListDomains(utils.DesignateScenario):
services=[consts.Service.DESIGNATE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["designate"]},
name="DesignateBasic.list_domains")
name="DesignateBasic.list_domains",
platform="openstack")
class ListDomains(utils.DesignateScenario):
def run(self):
@ -73,7 +75,8 @@ class ListDomains(utils.DesignateScenario):
services=[consts.Service.DESIGNATE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["designate"]},
name="DesignateBasic.create_and_delete_domain")
name="DesignateBasic.create_and_delete_domain",
platform="openstack")
class CreateAndDeleteDomain(utils.DesignateScenario):
def run(self):
@ -90,7 +93,8 @@ class CreateAndDeleteDomain(utils.DesignateScenario):
services=[consts.Service.DESIGNATE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["designate"]},
name="DesignateBasic.create_and_update_domain")
name="DesignateBasic.create_and_update_domain",
platform="openstack")
class CreateAndUpdateDomain(utils.DesignateScenario):
def run(self):
@ -107,7 +111,8 @@ class CreateAndUpdateDomain(utils.DesignateScenario):
services=[consts.Service.DESIGNATE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["designate"]},
name="DesignateBasic.create_and_delete_records")
name="DesignateBasic.create_and_delete_records",
platform="openstack")
class CreateAndDeleteRecords(utils.DesignateScenario):
def run(self, records_per_domain=5):
@ -135,7 +140,8 @@ class CreateAndDeleteRecords(utils.DesignateScenario):
services=[consts.Service.DESIGNATE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["designate"]},
name="DesignateBasic.list_records")
name="DesignateBasic.list_records",
platform="openstack")
class ListRecords(utils.DesignateScenario):
def run(self, domain_id):
@ -158,7 +164,8 @@ class ListRecords(utils.DesignateScenario):
services=[consts.Service.DESIGNATE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["designate"]},
name="DesignateBasic.create_and_list_records")
name="DesignateBasic.create_and_list_records",
platform="openstack")
class CreateAndListRecords(utils.DesignateScenario):
def run(self, records_per_domain=5):
@ -187,7 +194,8 @@ class CreateAndListRecords(utils.DesignateScenario):
services=[consts.Service.DESIGNATE])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["designate"]},
name="DesignateBasic.create_and_list_servers")
name="DesignateBasic.create_and_list_servers",
platform="openstack")
class CreateAndListServers(utils.DesignateScenario):
def run(self):
@ -209,7 +217,8 @@ class CreateAndListServers(utils.DesignateScenario):
services=[consts.Service.DESIGNATE])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["designate"]},
name="DesignateBasic.create_and_delete_server")
name="DesignateBasic.create_and_delete_server",
platform="openstack")
class CreateAndDeleteServer(utils.DesignateScenario):
def run(self):
@ -225,7 +234,7 @@ class CreateAndDeleteServer(utils.DesignateScenario):
@validation.add("required_services",
services=[consts.Service.DESIGNATE])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(name="DesignateBasic.list_servers")
@scenario.configure(name="DesignateBasic.list_servers", platform="openstack")
class ListServers(utils.DesignateScenario):
def run(self):
@ -242,7 +251,8 @@ class ListServers(utils.DesignateScenario):
services=[consts.Service.DESIGNATE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["designate"]},
name="DesignateBasic.create_and_list_zones")
name="DesignateBasic.create_and_list_zones",
platform="openstack")
class CreateAndListZones(utils.DesignateScenario):
def run(self):
@ -266,7 +276,7 @@ class CreateAndListZones(utils.DesignateScenario):
services=[consts.Service.DESIGNATE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["designate"]},
name="DesignateBasic.list_zones")
name="DesignateBasic.list_zones", platform="openstack")
class ListZones(utils.DesignateScenario):
def run(self):
@ -283,7 +293,8 @@ class ListZones(utils.DesignateScenario):
services=[consts.Service.DESIGNATE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["designate"]},
name="DesignateBasic.create_and_delete_zone")
name="DesignateBasic.create_and_delete_zone",
platform="openstack")
class CreateAndDeleteZone(utils.DesignateScenario):
def run(self):
@ -300,7 +311,8 @@ class CreateAndDeleteZone(utils.DesignateScenario):
services=[consts.Service.DESIGNATE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["designate"]},
name="DesignateBasic.list_recordsets")
name="DesignateBasic.list_recordsets",
platform="openstack")
class ListRecordsets(utils.DesignateScenario):
def run(self, zone_id):
@ -320,7 +332,8 @@ class ListRecordsets(utils.DesignateScenario):
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_contexts", contexts=("zones"))
@scenario.configure(context={"cleanup": ["designate"]},
name="DesignateBasic.create_and_delete_recordsets")
name="DesignateBasic.create_and_delete_recordsets",
platform="openstack")
class CreateAndDeleteRecordsets(utils.DesignateScenario):
def run(self, recordsets_per_zone=5):
@ -349,7 +362,8 @@ class CreateAndDeleteRecordsets(utils.DesignateScenario):
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_contexts", contexts=("zones"))
@scenario.configure(context={"cleanup": ["designate"]},
name="DesignateBasic.create_and_list_recordsets")
name="DesignateBasic.create_and_list_recordsets",
platform="openstack")
class CreateAndListRecordsets(utils.DesignateScenario):
def run(self, recordsets_per_zone=5):

View File

@ -17,6 +17,6 @@ from rally.plugins.common.scenarios.dummy import dummy
from rally.task import scenario
@scenario.configure(name="Dummy.openstack", namespace="openstack")
@scenario.configure(name="Dummy.openstack", platform="openstack")
class DummyOpenStack(dummy.Dummy):
"""Clone of Dummy.dummy for OpenStack"""

View File

@ -25,7 +25,7 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.EC2])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["ec2"]},
name="EC2Servers.list_servers")
name="EC2Servers.list_servers", platform="openstack")
class ListServers(utils.EC2Scenario):
def run(self):
@ -44,7 +44,7 @@ class ListServers(utils.EC2Scenario):
@validation.add("required_services", services=[consts.Service.EC2])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["ec2"]},
name="EC2Servers.boot_server")
name="EC2Servers.boot_server", platform="openstack")
class BootServer(utils.EC2Scenario):
def run(self, image, flavor, **kwargs):

View File

@ -49,7 +49,8 @@ class GlanceBasic(scenario.OpenStackScenario):
@validation.add("required_services", services=[consts.Service.GLANCE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["glance"]},
name="GlanceImages.create_and_list_image")
name="GlanceImages.create_and_list_image",
platform="openstack")
class CreateAndListImage(GlanceBasic):
def run(self, container_format, image_location, disk_format,
@ -95,7 +96,8 @@ class CreateAndListImage(GlanceBasic):
@validation.add("required_services", services=[consts.Service.GLANCE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["glance"]},
name="GlanceImages.create_and_get_image")
name="GlanceImages.create_and_get_image",
platform="openstack")
class CreateAndGetImage(GlanceBasic):
def run(self, container_format, image_location, disk_format,
@ -126,7 +128,8 @@ class CreateAndGetImage(GlanceBasic):
@validation.add("required_services", services=[consts.Service.GLANCE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["glance"]},
name="GlanceImages.list_images")
name="GlanceImages.list_images",
platform="openstack")
class ListImages(GlanceBasic):
def run(self):
@ -152,7 +155,8 @@ class ListImages(GlanceBasic):
@validation.add("required_services", services=[consts.Service.GLANCE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["glance"]},
name="GlanceImages.create_and_delete_image")
name="GlanceImages.create_and_delete_image",
platform="openstack")
class CreateAndDeleteImage(GlanceBasic):
def run(self, container_format, image_location, disk_format,
@ -192,7 +196,8 @@ class CreateAndDeleteImage(GlanceBasic):
consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["glance", "nova"]},
name="GlanceImages.create_image_and_boot_instances")
name="GlanceImages.create_image_and_boot_instances",
platform="openstack")
class CreateImageAndBootInstances(GlanceBasic, nova_utils.NovaScenario):
def run(self, container_format, image_location, disk_format,
@ -243,7 +248,8 @@ class CreateImageAndBootInstances(GlanceBasic, nova_utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.GLANCE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["glance"]},
name="GlanceImages.create_and_update_image")
name="GlanceImages.create_and_update_image",
platform="openstack")
class CreateAndUpdateImage(GlanceBasic):
def run(self, container_format, image_location, disk_format,

View File

@ -29,7 +29,8 @@ from rally.task import validation
@validation.add("validate_heat_template", params="template_path")
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["heat"]},
name="HeatStacks.create_and_list_stack")
name="HeatStacks.create_and_list_stack",
platform="openstack")
class CreateAndListStack(utils.HeatScenario):
def run(self, template_path, parameters=None,
@ -53,7 +54,8 @@ class CreateAndListStack(utils.HeatScenario):
@validation.add("required_services", services=[consts.Service.HEAT])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="HeatStacks.list_stacks_and_resources")
@scenario.configure(name="HeatStacks.list_stacks_and_resources",
platform="openstack")
class ListStacksAndResources(utils.HeatScenario):
def run(self):
@ -70,7 +72,8 @@ class ListStacksAndResources(utils.HeatScenario):
@validation.add("validate_heat_template", params="template_path")
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["heat"]},
name="HeatStacks.create_and_delete_stack")
name="HeatStacks.create_and_delete_stack",
platform="openstack")
class CreateAndDeleteStack(utils.HeatScenario):
def run(self, template_path, parameters=None,
@ -96,7 +99,8 @@ class CreateAndDeleteStack(utils.HeatScenario):
@validation.add("validate_heat_template", params="template_path")
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["heat"]},
name="HeatStacks.create_check_delete_stack")
name="HeatStacks.create_check_delete_stack",
platform="openstack")
class CreateCheckDeleteStack(utils.HeatScenario):
def run(self, template_path, parameters=None,
@ -128,7 +132,8 @@ class CreateCheckDeleteStack(utils.HeatScenario):
@validation.add("validate_heat_template", params="template_path")
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["heat"]},
name="HeatStacks.create_update_delete_stack")
name="HeatStacks.create_update_delete_stack",
platform="openstack")
class CreateUpdateDeleteStack(utils.HeatScenario):
def run(self, template_path, updated_template_path,
@ -167,7 +172,8 @@ class CreateUpdateDeleteStack(utils.HeatScenario):
@validation.add("validate_heat_template", params="template_path")
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["heat"]},
name="HeatStacks.create_stack_and_scale")
name="HeatStacks.create_stack_and_scale",
platform="openstack")
class CreateStackAndScale(utils.HeatScenario):
def run(self, template_path, output_key, delta,
@ -209,7 +215,8 @@ class CreateStackAndScale(utils.HeatScenario):
@validation.add("validate_heat_template", params="template_path")
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["heat"]},
name="HeatStacks.create_suspend_resume_delete_stack")
name="HeatStacks.create_suspend_resume_delete_stack",
platform="openstack")
class CreateSuspendResumeDeleteStack(utils.HeatScenario):
def run(self, template_path, parameters=None,
@ -236,7 +243,8 @@ class CreateSuspendResumeDeleteStack(utils.HeatScenario):
@validation.add("required_services", services=[consts.Service.HEAT])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="HeatStacks.list_stacks_and_events")
@scenario.configure(name="HeatStacks.list_stacks_and_events",
platform="openstack")
class ListStacksAndEvents(utils.HeatScenario):
def run(self):
@ -253,7 +261,8 @@ class ListStacksAndEvents(utils.HeatScenario):
@validation.add("validate_heat_template", params="template_path")
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["heat"]},
name="HeatStacks.create_snapshot_restore_delete_stack")
name="HeatStacks.create_snapshot_restore_delete_stack",
platform="openstack")
class CreateSnapshotRestoreDeleteStack(utils.HeatScenario):
def run(self, template_path, parameters=None,
@ -283,7 +292,8 @@ class CreateSnapshotRestoreDeleteStack(utils.HeatScenario):
@validation.add("required_services", services=[consts.Service.HEAT])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["heat"]},
name="HeatStacks.create_stack_and_show_output_via_API")
name="HeatStacks.create_stack_and_show_output_via_API",
platform="openstack")
class CreateStackAndShowOutputViaAPI(utils.HeatScenario):
def run(self, template_path, output_key,
@ -310,7 +320,8 @@ class CreateStackAndShowOutputViaAPI(utils.HeatScenario):
@validation.add("required_services", services=[consts.Service.HEAT])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["heat"]},
name="HeatStacks.create_stack_and_show_output")
name="HeatStacks.create_stack_and_show_output",
platform="openstack")
class CreateStackAndShowOutput(utils.HeatScenario):
def run(self, template_path, output_key,
@ -337,7 +348,8 @@ class CreateStackAndShowOutput(utils.HeatScenario):
@validation.add("required_services", services=[consts.Service.HEAT])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["heat"]},
name="HeatStacks.create_stack_and_list_output_via_API")
name="HeatStacks.create_stack_and_list_output_via_API",
platform="openstack")
class CreateStackAndListOutputViaAPI(utils.HeatScenario):
def run(self, template_path, parameters=None,
@ -362,7 +374,8 @@ class CreateStackAndListOutputViaAPI(utils.HeatScenario):
@validation.add("required_services", services=[consts.Service.HEAT])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["heat"]},
name="HeatStacks.create_stack_and_list_output")
name="HeatStacks.create_stack_and_list_output",
platform="openstack")
class CreateStackAndListOutput(utils.HeatScenario):
def run(self, template_path, parameters=None,

View File

@ -29,7 +29,8 @@ from rally.task import validation
@validation.add("restricted_parameters", param_names="name")
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["ironic"]},
name="IronicNodes.create_and_list_node")
name="IronicNodes.create_and_list_node",
platform="openstack")
class CreateAndListNode(utils.IronicScenario):
def run(self, driver, properties=None, associated=None, maintenance=None,
@ -69,7 +70,8 @@ class CreateAndListNode(utils.IronicScenario):
@validation.add("restricted_parameters", param_names="name")
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["ironic"]},
name="IronicNodes.create_and_delete_node")
name="IronicNodes.create_and_delete_node",
platform="openstack")
class CreateAndDeleteNode(utils.IronicScenario):
def run(self, driver, properties=None, **kwargs):

View File

@ -40,7 +40,8 @@ class KeystoneBasic(scenario.OpenStackScenario):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_user")
name="KeystoneBasic.create_user",
platform="openstack")
class CreateUser(KeystoneBasic):
@logging.log_deprecated_args(
@ -57,7 +58,8 @@ class CreateUser(KeystoneBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_delete_user")
name="KeystoneBasic.create_delete_user",
platform="openstack")
class CreateDeleteUser(KeystoneBasic):
@logging.log_deprecated_args(
@ -75,7 +77,8 @@ class CreateDeleteUser(KeystoneBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_user_set_enabled_and_delete")
name="KeystoneBasic.create_user_set_enabled_and_delete",
platform="openstack")
class CreateUserSetEnabledAndDelete(KeystoneBasic):
def run(self, enabled=True, **kwargs):
@ -93,7 +96,8 @@ class CreateUserSetEnabledAndDelete(KeystoneBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_tenant")
name="KeystoneBasic.create_tenant",
platform="openstack")
class CreateTenant(KeystoneBasic):
@logging.log_deprecated_args(
@ -109,7 +113,8 @@ class CreateTenant(KeystoneBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.authenticate_user_and_validate_token")
name="KeystoneBasic.authenticate_user_and_validate_token",
platform="openstack")
class AuthenticateUserAndValidateToken(KeystoneBasic):
def run(self):
@ -121,7 +126,8 @@ class AuthenticateUserAndValidateToken(KeystoneBasic):
@validation.add("number", param_name="users_per_tenant", minval=1)
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_tenant_with_users")
name="KeystoneBasic.create_tenant_with_users",
platform="openstack")
class CreateTenantWithUsers(KeystoneBasic):
@logging.log_deprecated_args(
@ -141,7 +147,8 @@ class CreateTenantWithUsers(KeystoneBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_and_list_users")
name="KeystoneBasic.create_and_list_users",
platform="openstack")
class CreateAndListUsers(KeystoneBasic):
@logging.log_deprecated_args(
@ -161,7 +168,8 @@ class CreateAndListUsers(KeystoneBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_and_list_tenants")
name="KeystoneBasic.create_and_list_tenants",
platform="openstack")
class CreateAndListTenants(KeystoneBasic):
@logging.log_deprecated_args(
@ -179,7 +187,8 @@ class CreateAndListTenants(KeystoneBasic):
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.add_and_remove_user_role")
name="KeystoneBasic.add_and_remove_user_role",
platform="openstack")
class AddAndRemoveUserRole(KeystoneBasic):
def run(self):
@ -195,7 +204,8 @@ class AddAndRemoveUserRole(KeystoneBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_and_delete_role")
name="KeystoneBasic.create_and_delete_role",
platform="openstack")
class CreateAndDeleteRole(KeystoneBasic):
def run(self):
@ -207,7 +217,8 @@ class CreateAndDeleteRole(KeystoneBasic):
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_add_and_list_user_roles")
name="KeystoneBasic.create_add_and_list_user_roles",
platform="openstack")
class CreateAddAndListUserRoles(KeystoneBasic):
def run(self):
@ -222,7 +233,8 @@ class CreateAddAndListUserRoles(KeystoneBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.get_entities")
name="KeystoneBasic.get_entities",
platform="openstack")
class GetEntities(KeystoneBasic):
def run(self, service_name="keystone"):
@ -254,7 +266,8 @@ class GetEntities(KeystoneBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_and_delete_service")
name="KeystoneBasic.create_and_delete_service",
platform="openstack")
class CreateAndDeleteService(KeystoneBasic):
@logging.log_deprecated_args(
@ -273,7 +286,8 @@ class CreateAndDeleteService(KeystoneBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_update_and_delete_tenant")
name="KeystoneBasic.create_update_and_delete_tenant",
platform="openstack")
class CreateUpdateAndDeleteTenant(KeystoneBasic):
@logging.log_deprecated_args(
@ -294,7 +308,8 @@ class CreateUpdateAndDeleteTenant(KeystoneBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_user_update_password")
name="KeystoneBasic.create_user_update_password",
platform="openstack")
class CreateUserUpdatePassword(KeystoneBasic):
@logging.log_deprecated_args(
@ -310,7 +325,8 @@ class CreateUserUpdatePassword(KeystoneBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_and_list_services")
name="KeystoneBasic.create_and_list_services",
platform="openstack")
class CreateAndListServices(KeystoneBasic):
@logging.log_deprecated_args(
@ -329,7 +345,8 @@ class CreateAndListServices(KeystoneBasic):
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["keystone"]},
name="KeystoneBasic.create_and_list_ec2credentials")
name="KeystoneBasic.create_and_list_ec2credentials",
platform="openstack")
class CreateAndListEc2Credentials(KeystoneBasic):
def run(self):
@ -342,7 +359,8 @@ class CreateAndListEc2Credentials(KeystoneBasic):
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["keystone"]},
name="KeystoneBasic.create_and_delete_ec2credential")
name="KeystoneBasic.create_and_delete_ec2credential",
platform="openstack")
class CreateAndDeleteEc2Credential(KeystoneBasic):
def run(self):
@ -356,7 +374,8 @@ class CreateAndDeleteEc2Credential(KeystoneBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_and_get_role")
name="KeystoneBasic.create_and_get_role",
platform="openstack")
class CreateAndGetRole(KeystoneBasic):
def run(self, **kwargs):
@ -370,7 +389,8 @@ class CreateAndGetRole(KeystoneBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_and_list_roles")
name="KeystoneBasic.create_and_list_roles",
platform="openstack")
class CreateAddListRoles(KeystoneBasic):
def run(self, create_role_kwargs=None, list_role_kwargs=None):
@ -394,7 +414,8 @@ class CreateAddListRoles(KeystoneBasic):
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["keystone"]},
name="KeystoneBasic.create_and_update_user")
name="KeystoneBasic.create_and_update_user",
platform="openstack")
class CreateAndUpdateUser(KeystoneBasic):
def run(self, create_user_kwargs=None, update_user_kwargs=None):

View File

@ -24,7 +24,8 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.MAGNUM])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["magnum"]},
name="MagnumClusterTemplates.list_cluster_templates")
name="MagnumClusterTemplates.list_cluster_templates",
platform="openstack")
class ListClusterTemplates(utils.MagnumScenario):
def run(self, **kwargs):

View File

@ -24,7 +24,8 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.MAGNUM])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["magnum.clusters"]},
name="MagnumClusters.list_clusters")
name="MagnumClusters.list_clusters",
platform="openstack")
class ListClusters(utils.MagnumScenario):
def run(self, **kwargs):
@ -47,7 +48,8 @@ class ListClusters(utils.MagnumScenario):
@validation.add("required_services", services=[consts.Service.MAGNUM])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["magnum.clusters", "nova.keypairs"]},
name="MagnumClusters.create_and_list_clusters")
name="MagnumClusters.create_and_list_clusters",
platform="openstack")
class CreateAndListClusters(utils.MagnumScenario):
def run(self, node_count, **kwargs):

View File

@ -25,7 +25,7 @@ from rally.task import validation
@validation.add("required_services", services=consts.Service.MAGNUM)
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="K8sPods.list_pods")
@scenario.configure(name="K8sPods.list_pods", platform="openstack")
class ListPods(utils.MagnumScenario):
def run(self):
@ -37,7 +37,7 @@ class ListPods(utils.MagnumScenario):
@validation.add("required_services", services=consts.Service.MAGNUM)
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="K8sPods.create_pods")
@scenario.configure(name="K8sPods.create_pods", platform="openstack")
class CreatePods(utils.MagnumScenario):
def run(self, manifests):
@ -56,7 +56,7 @@ class CreatePods(utils.MagnumScenario):
@validation.add("required_services", services=consts.Service.MAGNUM)
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="K8sPods.create_rcs")
@scenario.configure(name="K8sPods.create_rcs", platform="openstack")
class CreateRcs(utils.MagnumScenario):
def run(self, manifests):

View File

@ -28,7 +28,8 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.MANILA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["manila"]},
name="ManilaShares.create_and_delete_share")
name="ManilaShares.create_and_delete_share",
platform="openstack")
class CreateAndDeleteShare(utils.ManilaScenario):
def run(self, share_proto, size=1, min_sleep=0, max_sleep=0, **kwargs):
@ -55,7 +56,7 @@ class CreateAndDeleteShare(utils.ManilaScenario):
@validation.add("required_services", services=[consts.Service.MANILA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="ManilaShares.list_shares")
@scenario.configure(name="ManilaShares.list_shares", platform="openstack")
class ListShares(utils.ManilaScenario):
def run(self, detailed=True, search_opts=None):
@ -75,7 +76,8 @@ class ListShares(utils.ManilaScenario):
@validation.add("required_services", services=[consts.Service.MANILA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["manila"]},
name="ManilaShares.create_and_extend_share")
name="ManilaShares.create_and_extend_share",
platform="openstack")
class CreateAndExtendShare(utils.ManilaScenario):
def run(self, share_proto, size=1, new_size=2, snapshot_id=None,
description=None, metadata=None, share_network=None,
@ -118,7 +120,8 @@ class CreateAndExtendShare(utils.ManilaScenario):
@validation.add("required_services", services=[consts.Service.MANILA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["manila"]},
name="ManilaShares.create_and_shrink_share")
name="ManilaShares.create_and_shrink_share",
platform="openstack")
class CreateAndShrinkShare(utils.ManilaScenario):
def run(self, share_proto, size=2, new_size=1, snapshot_id=None,
description=None, metadata=None, share_network=None,
@ -158,7 +161,8 @@ class CreateAndShrinkShare(utils.ManilaScenario):
@validation.add("required_services", services=[consts.Service.MANILA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["manila"]},
name="ManilaShares.create_share_network_and_delete")
name="ManilaShares.create_share_network_and_delete",
platform="openstack")
class CreateShareNetworkAndDelete(utils.ManilaScenario):
@logging.log_deprecated_args(
@ -185,7 +189,8 @@ class CreateShareNetworkAndDelete(utils.ManilaScenario):
@validation.add("required_services", services=[consts.Service.MANILA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["manila"]},
name="ManilaShares.create_share_network_and_list")
name="ManilaShares.create_share_network_and_list",
platform="openstack")
class CreateShareNetworkAndList(utils.ManilaScenario):
@logging.log_deprecated_args(
@ -219,7 +224,8 @@ class CreateShareNetworkAndList(utils.ManilaScenario):
@validation.add("required_services", services=[consts.Service.MANILA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(name="ManilaShares.list_share_servers")
@scenario.configure(name="ManilaShares.list_share_servers",
platform="openstack")
class ListShareServers(utils.ManilaScenario):
def run(self, search_opts=None):
@ -236,7 +242,8 @@ class ListShareServers(utils.ManilaScenario):
@validation.add("required_services", services=[consts.Service.MANILA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["manila"]},
name="ManilaShares.create_security_service_and_delete")
name="ManilaShares.create_security_service_and_delete",
platform="openstack")
class CreateSecurityServiceAndDelete(utils.ManilaScenario):
@logging.log_deprecated_args(
@ -271,8 +278,9 @@ class CreateSecurityServiceAndDelete(utils.ManilaScenario):
@validation.add("required_services", services=[consts.Service.MANILA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["manila"]},
name=("ManilaShares."
"attach_security_service_to_share_network"))
name="ManilaShares."
"attach_security_service_to_share_network",
platform="openstack")
class AttachSecurityServiceToShareNetwork(utils.ManilaScenario):
def run(self, security_service_type="ldap"):
@ -292,7 +300,8 @@ class AttachSecurityServiceToShareNetwork(utils.ManilaScenario):
@validation.add("required_services", services=[consts.Service.MANILA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["manila"]},
name=("ManilaShares.create_and_list_share"))
name="ManilaShares.create_and_list_share",
platform="openstack")
class CreateAndListShare(utils.ManilaScenario):
def run(self, share_proto, size=1, min_sleep=0, max_sleep=0, detailed=True,
@ -330,9 +339,9 @@ class CreateAndListShare(utils.ManilaScenario):
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_contexts",
contexts=manila_consts.SHARES_CONTEXT_NAME)
@scenario.configure(
context={"cleanup": ["manila"]},
name="ManilaShares.set_and_delete_metadata")
@scenario.configure(context={"cleanup": ["manila"]},
name="ManilaShares.set_and_delete_metadata",
platform="openstack")
class SetAndDeleteMetadata(utils.ManilaScenario):
def run(self, sets=10, set_size=3, delete_size=3,

View File

@ -31,7 +31,8 @@ from rally.task import validation
@validation.add("required_services",
services=[consts.Service.MISTRAL])
@scenario.configure(name="MistralExecutions.list_executions",
context={"cleanup": ["mistral"]})
context={"cleanup": ["mistral"]},
platform="openstack")
class ListExecutions(utils.MistralScenario):
def run(self, marker="", limit=None, sort_keys="", sort_dirs=""):
@ -59,9 +60,9 @@ class ListExecutions(utils.MistralScenario):
@validation.add("required_services",
services=[consts.Service.MISTRAL])
@validation.workbook_contains_workflow("definition", "workflow_name")
@scenario.configure(
name="MistralExecutions.create_execution_from_workbook",
context={"cleanup": ["mistral"]})
@scenario.configure(name="MistralExecutions.create_execution_from_workbook",
context={"cleanup": ["mistral"]},
platform="openstack")
class CreateExecutionFromWorkbook(utils.MistralScenario):
def run(self, definition, workflow_name=None, wf_input=None, params=None,

View File

@ -26,7 +26,8 @@ from rally.task import validation
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_services",
services=[consts.Service.MISTRAL])
@scenario.configure(name="MistralWorkbooks.list_workbooks")
@scenario.configure(name="MistralWorkbooks.list_workbooks",
platform="openstack")
class ListWorkbooks(utils.MistralScenario):
def run(self):
@ -44,7 +45,8 @@ class ListWorkbooks(utils.MistralScenario):
@validation.add("required_services",
services=[consts.Service.MISTRAL])
@scenario.configure(context={"cleanup": ["mistral"]},
name="MistralWorkbooks.create_workbook")
name="MistralWorkbooks.create_workbook",
platform="openstack")
class CreateWorkbook(utils.MistralScenario):
def run(self, definition, do_delete=False):

View File

@ -24,7 +24,7 @@ from rally.task import validation
@validation.add("required_services",
services=[consts.Service.MONASCA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="MonascaMetrics.list_metrics")
@scenario.configure(name="MonascaMetrics.list_metrics", platform="openstack")
class ListMetrics(monascautils.MonascaScenario):
def run(self, **kwargs):

View File

@ -24,7 +24,8 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.MURANO])
@scenario.configure(context={"cleanup": ["murano.environments"]},
name="MuranoEnvironments.list_environments")
name="MuranoEnvironments.list_environments",
platform="openstack")
class ListEnvironments(utils.MuranoScenario):
def run(self):
@ -37,7 +38,8 @@ class ListEnvironments(utils.MuranoScenario):
@validation.add("required_services", services=[consts.Service.MURANO])
@scenario.configure(context={"cleanup": ["murano.environments"]},
name="MuranoEnvironments.create_and_delete_environment")
name="MuranoEnvironments.create_and_delete_environment",
platform="openstack")
class CreateAndDeleteEnvironment(utils.MuranoScenario):
def run(self):
@ -51,7 +53,8 @@ class CreateAndDeleteEnvironment(utils.MuranoScenario):
@validation.add("required_services", services=[consts.Service.MURANO])
@validation.add("required_contexts", contexts=("murano_packages"))
@scenario.configure(context={"cleanup": ["murano"], "roles": ["admin"]},
name="MuranoEnvironments.create_and_deploy_environment")
name="MuranoEnvironments.create_and_deploy_environment",
platform="openstack")
class CreateAndDeployEnvironment(utils.MuranoScenario):
def run(self, packages_per_env=1):

View File

@ -31,7 +31,8 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.MURANO])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["murano.packages"]},
name="MuranoPackages.import_and_list_packages")
name="MuranoPackages.import_and_list_packages",
platform="openstack")
class ImportAndListPackages(utils.MuranoScenario):
def run(self, package, include_disabled=False):
@ -62,7 +63,8 @@ class ImportAndListPackages(utils.MuranoScenario):
@validation.add("required_services", services=[consts.Service.MURANO])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["murano.packages"]},
name="MuranoPackages.import_and_delete_package")
name="MuranoPackages.import_and_delete_package",
platform="openstack")
class ImportAndDeletePackage(utils.MuranoScenario):
def run(self, package):
@ -90,7 +92,8 @@ class ImportAndDeletePackage(utils.MuranoScenario):
@validation.add("required_services", services=[consts.Service.MURANO])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["murano.packages"]},
name="MuranoPackages.package_lifecycle")
name="MuranoPackages.package_lifecycle",
platform="openstack")
class PackageLifecycle(utils.MuranoScenario):
def run(self, package, body, operation="replace"):
@ -127,7 +130,8 @@ class PackageLifecycle(utils.MuranoScenario):
@validation.add("required_services", services=[consts.Service.MURANO])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["murano.packages"]},
name="MuranoPackages.import_and_filter_applications")
name="MuranoPackages.import_and_filter_applications",
platform="openstack")
class ImportAndFilterApplications(utils.MuranoScenario):
def run(self, package, filter_query):

View File

@ -25,7 +25,8 @@ from rally.task import validation
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@scenario.configure(context={"admin_cleanup": ["neutron"]},
name="NeutronBGPVPN.create_and_delete_bgpvpns")
name="NeutronBGPVPN.create_and_delete_bgpvpns",
platform="openstack")
class CreateAndDeleteBgpvpns(utils.NeutronScenario):
def run(self, route_targets=None, import_targets=None,
@ -58,7 +59,8 @@ class CreateAndDeleteBgpvpns(utils.NeutronScenario):
@validation.add("required_services", services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["neutron"]},
name="NeutronBGPVPN.create_and_list_bgpvpns")
name="NeutronBGPVPN.create_and_list_bgpvpns",
platform="openstack")
class CreateAndListBgpvpns(utils.NeutronScenario):
def run(self, route_targets=None, import_targets=None,
@ -91,7 +93,8 @@ class CreateAndListBgpvpns(utils.NeutronScenario):
@validation.add("required_services", services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["neutron"]},
name="NeutronBGPVPN.create_and_update_bgpvpns")
name="NeutronBGPVPN.create_and_update_bgpvpns",
platform="openstack")
class CreateAndUpdateBgpvpns(utils.NeutronScenario):
def run(self, update_name=False, route_targets=None,
@ -148,7 +151,8 @@ class CreateAndUpdateBgpvpns(utils.NeutronScenario):
@validation.add("required_contexts", contexts=("network"))
@scenario.configure(context={"admin_cleanup": ["neutron"],
"cleanup": ["neutron"]},
name="NeutronBGPVPN.create_bgpvpn_assoc_disassoc_networks")
name="NeutronBGPVPN.create_bgpvpn_assoc_disassoc_networks",
platform="openstack")
class CreateAndAssociateDissassociateNetworks(utils.NeutronScenario):
def run(self, route_targets=None, import_targets=None,
@ -189,7 +193,8 @@ class CreateAndAssociateDissassociateNetworks(utils.NeutronScenario):
@validation.add("required_contexts", contexts=("router"))
@scenario.configure(context={"admin_cleanup": ["neutron"],
"cleanup": ["neutron"]},
name="NeutronBGPVPN.create_bgpvpn_assoc_disassoc_routers")
name="NeutronBGPVPN.create_bgpvpn_assoc_disassoc_routers",
platform="openstack")
class CreateAndAssociateDissassociateRouters(utils.NeutronScenario):
def run(self, route_targets=None, import_targets=None,
@ -230,7 +235,8 @@ class CreateAndAssociateDissassociateRouters(utils.NeutronScenario):
admin=True, users=True)
@validation.add("required_contexts", contexts=("network"))
@scenario.configure(context={"admin_cleanup": ["neutron"]},
name="NeutronBGPVPN.create_and_list_networks_associations")
name="NeutronBGPVPN.create_and_list_networks_associations",
platform="openstack")
class CreateAndListNetworksAssocs(utils.NeutronScenario):
def run(self, route_targets=None, import_targets=None,
@ -279,7 +285,8 @@ class CreateAndListNetworksAssocs(utils.NeutronScenario):
admin=True, users=True)
@validation.add("required_contexts", contexts=("router"))
@scenario.configure(context={"admin_cleanup": ["neutron"]},
name="NeutronBGPVPN.create_and_list_routers_associations")
name="NeutronBGPVPN.create_and_list_routers_associations",
platform="openstack")
class CreateAndListRoutersAssocs(utils.NeutronScenario):
def run(self, route_targets=None, import_targets=None,

View File

@ -30,7 +30,8 @@ from rally.task import validation
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_contexts", contexts=("network"))
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronLoadbalancerV1.create_and_list_pools")
name="NeutronLoadbalancerV1.create_and_list_pools",
platform="openstack")
class CreateAndListPools(utils.NeutronScenario):
def run(self, pool_create_args=None):
@ -55,7 +56,8 @@ class CreateAndListPools(utils.NeutronScenario):
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_contexts", contexts=("network"))
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronLoadbalancerV1.create_and_delete_pools")
name="NeutronLoadbalancerV1.create_and_delete_pools",
platform="openstack")
class CreateAndDeletePools(utils.NeutronScenario):
def run(self, pool_create_args=None):
@ -82,7 +84,8 @@ class CreateAndDeletePools(utils.NeutronScenario):
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_contexts", contexts=("network"))
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronLoadbalancerV1.create_and_update_pools")
name="NeutronLoadbalancerV1.create_and_update_pools",
platform="openstack")
class CreateAndUpdatePools(utils.NeutronScenario):
def run(self, pool_update_args=None, pool_create_args=None):
@ -111,7 +114,8 @@ class CreateAndUpdatePools(utils.NeutronScenario):
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_contexts", contexts=("network"))
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronLoadbalancerV1.create_and_list_vips")
name="NeutronLoadbalancerV1.create_and_list_vips",
platform="openstack")
class CreateAndListVips(utils.NeutronScenario):
def run(self, pool_create_args=None, vip_create_args=None):
@ -142,7 +146,8 @@ class CreateAndListVips(utils.NeutronScenario):
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_contexts", contexts=("network"))
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronLoadbalancerV1.create_and_delete_vips")
name="NeutronLoadbalancerV1.create_and_delete_vips",
platform="openstack")
class CreateAndDeleteVips(utils.NeutronScenario):
def run(self, pool_create_args=None, vip_create_args=None):
@ -175,7 +180,8 @@ class CreateAndDeleteVips(utils.NeutronScenario):
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_contexts", contexts=("network"))
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronLoadbalancerV1.create_and_update_vips")
name="NeutronLoadbalancerV1.create_and_update_vips",
platform="openstack")
class CreateAndUpdateVips(utils.NeutronScenario):
def run(self, pool_create_args=None,
@ -207,9 +213,10 @@ class CreateAndUpdateVips(utils.NeutronScenario):
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name=("NeutronLoadbalancerV1"
".create_and_list_healthmonitors"))
@scenario.configure(
context={"cleanup": ["neutron"]},
name="NeutronLoadbalancerV1.create_and_list_healthmonitors",
platform="openstack")
class CreateAndListHealthmonitors(utils.NeutronScenario):
def run(self, healthmonitor_create_args=None):
@ -230,9 +237,10 @@ class CreateAndListHealthmonitors(utils.NeutronScenario):
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name=("NeutronLoadbalancerV1"
".create_and_delete_healthmonitors"))
@scenario.configure(
context={"cleanup": ["neutron"]},
name="NeutronLoadbalancerV1.create_and_delete_healthmonitors",
platform="openstack")
class CreateAndDeleteHealthmonitors(utils.NeutronScenario):
def run(self, healthmonitor_create_args=None):
@ -255,9 +263,10 @@ class CreateAndDeleteHealthmonitors(utils.NeutronScenario):
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name=("NeutronLoadbalancerV1"
".create_and_update_healthmonitors"))
@scenario.configure(
context={"cleanup": ["neutron"]},
name="NeutronLoadbalancerV1.create_and_update_healthmonitors",
platform="openstack")
class CreateAndUpdateHealthmonitors(utils.NeutronScenario):
def run(self, healthmonitor_create_args=None,

View File

@ -25,7 +25,8 @@ from rally.task import validation
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_contexts", contexts=("network"))
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronLoadbalancerV2.create_and_list_loadbalancers")
name="NeutronLoadbalancerV2.create_and_list_loadbalancers",
platform="openstack")
class CreateAndListLoadbalancers(utils.NeutronScenario):
def run(self, lb_create_args=None):

View File

@ -27,7 +27,8 @@ from rally.task import validation
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_list_networks")
name="NeutronNetworks.create_and_list_networks",
platform="openstack")
class CreateAndListNetworks(utils.NeutronScenario):
def run(self, network_create_args=None):
@ -51,7 +52,8 @@ class CreateAndListNetworks(utils.NeutronScenario):
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_show_network")
name="NeutronNetworks.create_and_show_network",
platform="openstack")
class CreateAndShowNetwork(utils.NeutronScenario):
def run(self, network_create_args=None):
@ -69,7 +71,8 @@ class CreateAndShowNetwork(utils.NeutronScenario):
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_update_networks")
name="NeutronNetworks.create_and_update_networks",
platform="openstack")
class CreateAndUpdateNetworks(utils.NeutronScenario):
def run(self, network_update_args, network_create_args=None):
@ -87,7 +90,8 @@ class CreateAndUpdateNetworks(utils.NeutronScenario):
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_delete_networks")
name="NeutronNetworks.create_and_delete_networks",
platform="openstack")
class CreateAndDeleteNetworks(utils.NeutronScenario):
def run(self, network_create_args=None):
@ -107,7 +111,8 @@ class CreateAndDeleteNetworks(utils.NeutronScenario):
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_list_subnets")
name="NeutronNetworks.create_and_list_subnets",
platform="openstack")
class CreateAndListSubnets(utils.NeutronScenario):
def run(self, network_create_args=None, subnet_create_args=None,
@ -135,7 +140,8 @@ class CreateAndListSubnets(utils.NeutronScenario):
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_update_subnets")
name="NeutronNetworks.create_and_update_subnets",
platform="openstack")
class CreateAndUpdateSubnets(utils.NeutronScenario):
def run(self, subnet_update_args, network_create_args=None,
@ -168,7 +174,8 @@ class CreateAndUpdateSubnets(utils.NeutronScenario):
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_show_subnets")
name="NeutronNetworks.create_and_show_subnets",
platform="openstack")
class CreateAndShowSubnets(utils.NeutronScenario):
def run(self, network_create_args=None,
@ -199,7 +206,8 @@ class CreateAndShowSubnets(utils.NeutronScenario):
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_delete_subnets")
name="NeutronNetworks.create_and_delete_subnets",
platform="openstack")
class CreateAndDeleteSubnets(utils.NeutronScenario):
def run(self, network_create_args=None, subnet_create_args=None,
@ -229,7 +237,8 @@ class CreateAndDeleteSubnets(utils.NeutronScenario):
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_list_routers")
name="NeutronNetworks.create_and_list_routers",
platform="openstack")
class CreateAndListRouters(utils.NeutronScenario):
def run(self, network_create_args=None, subnet_create_args=None,
@ -258,7 +267,8 @@ class CreateAndListRouters(utils.NeutronScenario):
@validation.add("required_services", services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_show_routers")
name="NeutronNetworks.create_and_show_routers",
platform="openstack")
class CreateAndShowRouters(utils.NeutronScenario):
def run(self, network_create_args=None, subnet_create_args=None,
@ -289,7 +299,8 @@ class CreateAndShowRouters(utils.NeutronScenario):
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_update_routers")
name="NeutronNetworks.create_and_update_routers",
platform="openstack")
class CreateAndUpdateRouters(utils.NeutronScenario):
def run(self, router_update_args, network_create_args=None,
@ -321,7 +332,8 @@ class CreateAndUpdateRouters(utils.NeutronScenario):
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_delete_routers")
name="NeutronNetworks.create_and_delete_routers",
platform="openstack")
class CreateAndDeleteRouters(utils.NeutronScenario):
def run(self, network_create_args=None, subnet_create_args=None,
@ -354,7 +366,8 @@ class CreateAndDeleteRouters(utils.NeutronScenario):
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.set_and_clear_router_gateway")
name="NeutronNetworks.set_and_clear_router_gateway",
platform="openstack")
class SetAndClearRouterGateway(utils.NeutronScenario):
def run(self, enable_snat=True, network_create_args=None,
@ -384,7 +397,8 @@ class SetAndClearRouterGateway(utils.NeutronScenario):
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_list_ports")
name="NeutronNetworks.create_and_list_ports",
platform="openstack")
class CreateAndListPorts(utils.NeutronScenario):
def run(self, network_create_args=None,
@ -409,7 +423,8 @@ class CreateAndListPorts(utils.NeutronScenario):
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_update_ports")
name="NeutronNetworks.create_and_update_ports",
platform="openstack")
class CreateAndUpdatePorts(utils.NeutronScenario):
def run(self, port_update_args, network_create_args=None,
@ -437,7 +452,8 @@ class CreateAndUpdatePorts(utils.NeutronScenario):
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_show_ports")
name="NeutronNetworks.create_and_show_ports",
platform="openstack")
class CreateAndShowPorts(utils.NeutronScenario):
def run(self, network_create_args=None,
@ -474,7 +490,8 @@ class CreateAndShowPorts(utils.NeutronScenario):
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_delete_ports")
name="NeutronNetworks.create_and_delete_ports",
platform="openstack")
class CreateAndDeletePorts(utils.NeutronScenario):
def run(self, network_create_args=None,
@ -500,7 +517,8 @@ class CreateAndDeletePorts(utils.NeutronScenario):
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("external_network_exists", param_name="floating_network")
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_list_floating_ips")
name="NeutronNetworks.create_and_list_floating_ips",
platform="openstack")
class CreateAndListFloatingIps(utils.NeutronScenario):
def run(self, floating_network=None, floating_ip_args=None):
@ -522,7 +540,8 @@ class CreateAndListFloatingIps(utils.NeutronScenario):
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("external_network_exists", param_name="floating_network")
@scenario.configure(context={"cleanup": ["neutron"]},
name="NeutronNetworks.create_and_delete_floating_ips")
name="NeutronNetworks.create_and_delete_floating_ips",
platform="openstack")
class CreateAndDeleteFloatingIps(utils.NeutronScenario):
def run(self, floating_network=None, floating_ip_args=None):
@ -543,7 +562,7 @@ class CreateAndDeleteFloatingIps(utils.NeutronScenario):
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="NeutronNetworks.list_agents")
@scenario.configure(name="NeutronNetworks.list_agents", platform="openstack")
class ListAgents(utils.NeutronScenario):
def run(self, agent_args=None):

View File

@ -22,9 +22,10 @@ from rally.task import validation
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name=("NeutronSecurityGroup"
".create_and_list_security_groups"))
@scenario.configure(
context={"cleanup": ["neutron"]},
name="NeutronSecurityGroup.create_and_list_security_groups",
platform="openstack")
class CreateAndListSecurityGroups(utils.NeutronScenario):
def run(self, security_group_create_args=None):
@ -44,9 +45,10 @@ class CreateAndListSecurityGroups(utils.NeutronScenario):
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name=("NeutronSecurityGroup"
".create_and_show_security_group"))
@scenario.configure(
context={"cleanup": ["neutron"]},
name="NeutronSecurityGroup.create_and_show_security_group",
platform="openstack")
class CreateAndShowSecurityGroup(utils.NeutronScenario):
def run(self, security_group_create_args=None):
@ -70,9 +72,10 @@ class CreateAndShowSecurityGroup(utils.NeutronScenario):
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name=("NeutronSecurityGroup"
".create_and_delete_security_groups"))
@scenario.configure(
context={"cleanup": ["neutron"]},
name="NeutronSecurityGroup.create_and_delete_security_groups",
platform="openstack")
class CreateAndDeleteSecurityGroups(utils.NeutronScenario):
def run(self, security_group_create_args=None):
@ -93,9 +96,10 @@ class CreateAndDeleteSecurityGroups(utils.NeutronScenario):
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name=("NeutronSecurityGroup"
".create_and_update_security_groups"))
@scenario.configure(
context={"cleanup": ["neutron"]},
name="NeutronSecurityGroup.create_and_update_security_groups",
platform="openstack")
class CreateAndUpdateSecurityGroups(utils.NeutronScenario):
def run(self, security_group_create_args=None,
@ -121,9 +125,10 @@ class CreateAndUpdateSecurityGroups(utils.NeutronScenario):
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name=("NeutronSecurityGroup"
".create_and_list_security_group_rules"))
@scenario.configure(
context={"cleanup": ["neutron"]},
name="NeutronSecurityGroup.create_and_list_security_group_rules",
platform="openstack")
class CreateAndListSecurityGroupRules(utils.NeutronScenario):
def run(self, security_group_args=None,
@ -159,9 +164,10 @@ class CreateAndListSecurityGroupRules(utils.NeutronScenario):
@validation.add("required_services",
services=[consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["neutron"]},
name=("NeutronSecurityGroup"
".create_and_show_security_group_rule"))
@scenario.configure(
context={"cleanup": ["neutron"]},
name="NeutronSecurityGroup.create_and_show_security_group_rule",
platform="openstack")
class CreateAndShowSecurityGroupRule(utils.NeutronScenario):
def run(self, security_group_args=None,

View File

@ -24,7 +24,7 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(name="NovaAgents.list_agents")
@scenario.configure(name="NovaAgents.list_agents", platform="openstack")
class ListAgents(utils.NovaScenario):
def run(self, hypervisor=None):
"""List all builds.

View File

@ -26,7 +26,8 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(name="NovaAggregates.list_aggregates")
@scenario.configure(name="NovaAggregates.list_aggregates",
platform="openstack")
class ListAggregates(utils.NovaScenario):
def run(self):
@ -40,7 +41,8 @@ class ListAggregates(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["nova"]},
name="NovaAggregates.create_and_list_aggregates")
name="NovaAggregates.create_and_list_aggregates",
platform="openstack")
class CreateAndListAggregates(utils.NovaScenario):
"""scenario for create and list aggregate."""
@ -62,7 +64,8 @@ class CreateAndListAggregates(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["nova"]},
name="NovaAggregates.create_and_delete_aggregate")
name="NovaAggregates.create_and_delete_aggregate",
platform="openstack")
class CreateAndDeleteAggregate(utils.NovaScenario):
"""Scenario for create and delete aggregate."""
@ -79,7 +82,8 @@ class CreateAndDeleteAggregate(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["nova"]},
name="NovaAggregates.create_and_update_aggregate")
name="NovaAggregates.create_and_update_aggregate",
platform="openstack")
class CreateAndUpdateAggregate(utils.NovaScenario):
"""Scenario for create and update aggregate."""
@ -97,7 +101,8 @@ class CreateAndUpdateAggregate(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["nova"]},
name="NovaAggregates.create_aggregate_add_and_remove_host")
name="NovaAggregates.create_aggregate_add_and_remove_host",
platform="openstack")
class CreateAggregateAddAndRemoveHost(utils.NovaScenario):
"""Scenario for add a host to and remove the host from an aggregate."""
@ -118,7 +123,8 @@ class CreateAggregateAddAndRemoveHost(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["nova"]},
name="NovaAggregates.create_and_get_aggregate_details")
name="NovaAggregates.create_and_get_aggregate_details",
platform="openstack")
class CreateAndGetAggregateDetails(utils.NovaScenario):
"""Scenario for create and get aggregate details."""
@ -136,9 +142,10 @@ class CreateAndGetAggregateDetails(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"admin_cleanup": ["nova"], "cleanup": ["nova"]},
name="NovaAggregates."
"create_aggregate_add_host_and_boot_server")
@scenario.configure(
context={"admin_cleanup": ["nova"], "cleanup": ["nova"]},
name="NovaAggregates.create_aggregate_add_host_and_boot_server",
platform="openstack")
class CreateAggregateAddHostAndBootServer(utils.NovaScenario):
"""Scenario to verify an aggregate."""

View File

@ -24,7 +24,8 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(name="NovaAvailabilityZones.list_availability_zones")
@scenario.configure(name="NovaAvailabilityZones.list_availability_zones",
platform="openstack")
class ListAvailabilityZones(utils.NovaScenario):
def run(self, detailed=True):

View File

@ -29,7 +29,7 @@ LOG = logging.getLogger(__name__)
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(name="NovaFlavors.list_flavors")
@scenario.configure(name="NovaFlavors.list_flavors", platform="openstack")
class ListFlavors(utils.NovaScenario):
def run(self, detailed=True, is_public=True, marker=None, min_disk=None,
@ -59,7 +59,8 @@ class ListFlavors(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["nova"]},
name="NovaFlavors.create_and_list_flavor_access")
name="NovaFlavors.create_and_list_flavor_access",
platform="openstack")
class CreateAndListFlavorAccess(utils.NovaScenario):
def run(self, ram, vcpus, disk, flavorid="auto",
@ -95,7 +96,8 @@ class CreateAndListFlavorAccess(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["nova"]},
name="NovaFlavors.create_flavor_and_add_tenant_access")
name="NovaFlavors.create_flavor_and_add_tenant_access",
platform="openstack")
class CreateFlavorAndAddTenantAccess(utils.NovaScenario):
def run(self, ram, vcpus, disk, flavorid="auto",
@ -124,7 +126,7 @@ class CreateFlavorAndAddTenantAccess(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["nova"]},
name="NovaFlavors.create_flavor")
name="NovaFlavors.create_flavor", platform="openstack")
class CreateFlavor(utils.NovaScenario):
def run(self, ram, vcpus, disk, flavorid="auto",
@ -151,7 +153,8 @@ class CreateFlavor(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["nova"]},
name="NovaFlavors.create_and_get_flavor")
name="NovaFlavors.create_and_get_flavor",
platform="openstack")
class CreateAndGetFlavor(utils.NovaScenario):
"""Scenario for create and get flavor."""
@ -180,7 +183,8 @@ class CreateAndGetFlavor(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["nova"]},
name="NovaFlavors.create_and_delete_flavor")
name="NovaFlavors.create_and_delete_flavor",
platform="openstack")
class CreateAndDeleteFlavor(utils.NovaScenario):
def run(self, ram, vcpus, disk, flavorid="auto",
ephemeral=0, swap=0, rxtx_factor=1.0, is_public=True):
@ -207,7 +211,8 @@ class CreateAndDeleteFlavor(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["nova"]},
name="NovaFlavors.create_flavor_and_set_keys")
name="NovaFlavors.create_flavor_and_set_keys",
platform="openstack")
class CreateFlavorAndSetKeys(utils.NovaScenario):
def run(self, ram, vcpus, disk, extra_specs, flavorid="auto",
ephemeral=0, swap=0, rxtx_factor=1.0, is_public=True):

View File

@ -24,7 +24,7 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(name="NovaHosts.list_hosts")
@scenario.configure(name="NovaHosts.list_hosts", platform="openstack")
class ListHosts(utils.NovaScenario):
def run(self, zone=None):
@ -41,7 +41,7 @@ class ListHosts(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(name="NovaHosts.list_and_get_hosts")
@scenario.configure(name="NovaHosts.list_and_get_hosts", platform="openstack")
class ListAndGetHosts(utils.NovaScenario):
def run(self, zone=None):

View File

@ -24,7 +24,8 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(name="NovaHypervisors.list_hypervisors")
@scenario.configure(name="NovaHypervisors.list_hypervisors",
platform="openstack")
class ListHypervisors(utils.NovaScenario):
def run(self, detailed=True):
@ -40,7 +41,8 @@ class ListHypervisors(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(name="NovaHypervisors.list_and_get_hypervisors")
@scenario.configure(name="NovaHypervisors.list_and_get_hypervisors",
platform="openstack")
class ListAndGetHypervisors(utils.NovaScenario):
"""Benchmark scenario for Nova hypervisors."""
def run(self, detailed=True):
@ -62,7 +64,8 @@ class ListAndGetHypervisors(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(name="NovaHypervisors.statistics_hypervisors")
@scenario.configure(name="NovaHypervisors.statistics_hypervisors",
platform="openstack")
class StatisticsHypervisors(utils.NovaScenario):
def run(self):
@ -75,7 +78,8 @@ class StatisticsHypervisors(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(name="NovaHypervisors.list_and_get_uptime_hypervisors")
@scenario.configure(name="NovaHypervisors.list_and_get_uptime_hypervisors",
platform="openstack")
class ListAndGetUptimeHypervisors(utils.NovaScenario):
def run(self, detailed=True):
"""List hypervisors,then display the uptime of it.
@ -96,7 +100,8 @@ class ListAndGetUptimeHypervisors(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(name="NovaHypervisors.list_and_search_hypervisors")
@scenario.configure(name="NovaHypervisors.list_and_search_hypervisors",
platform="openstack")
class ListAndSearchHypervisors(utils.NovaScenario):
def run(self, detailed=True):
"""List all servers belonging to specific hypervisor.

View File

@ -25,7 +25,8 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaImages.list_images")
name="NovaImages.list_images",
platform="openstack")
class ListImages(utils.NovaScenario):
def run(self, detailed=True, **kwargs):

View File

@ -27,7 +27,8 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaKeypair.create_and_list_keypairs")
name="NovaKeypair.create_and_list_keypairs",
platform="openstack")
class CreateAndListKeypairs(utils.NovaScenario):
def run(self, **kwargs):
@ -48,7 +49,8 @@ class CreateAndListKeypairs(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaKeypair.create_and_delete_keypair")
name="NovaKeypair.create_and_delete_keypair",
platform="openstack")
class CreateAndDeleteKeypair(utils.NovaScenario):
def run(self, **kwargs):
@ -70,7 +72,8 @@ class CreateAndDeleteKeypair(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaKeypair.boot_and_delete_server_with_keypair")
name="NovaKeypair.boot_and_delete_server_with_keypair",
platform="openstack")
class BootAndDeleteServerWithKeypair(utils.NovaScenario):
@logging.log_deprecated_args(
@ -107,7 +110,8 @@ class BootAndDeleteServerWithKeypair(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaKeypair.create_and_get_keypair")
name="NovaKeypair.create_and_get_keypair",
platform="openstack")
class CreateAndGetKeypair(utils.NovaScenario):
def run(self, **kwargs):

View File

@ -25,7 +25,8 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServerGroups.create_and_list_server_groups")
name="NovaServerGroups.create_and_list_server_groups",
platform="openstack")
class CreateAndListServerGroups(utils.NovaScenario):
def run(self, all_projects=False, kwargs=None):
@ -54,7 +55,8 @@ class CreateAndListServerGroups(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServerGroups.create_and_get_server_group")
name="NovaServerGroups.create_and_get_server_group",
platform="openstack")
class CreateAndGetServerGroup(utils.NovaScenario):
def run(self, kwargs=None):

View File

@ -40,7 +40,8 @@ LOG = logging.getLogger(__name__)
@validation.add("required_services", services=(consts.Service.NOVA))
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.boot_and_list_server")
name="NovaServers.boot_and_list_server",
platform="openstack")
class BootAndListServer(utils.NovaScenario):
def run(self, image, flavor, detailed=True, **kwargs):
@ -74,7 +75,7 @@ class BootAndListServer(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.list_servers")
name="NovaServers.list_servers", platform="openstack")
class ListServers(utils.NovaScenario):
def run(self, detailed=True):
@ -96,7 +97,8 @@ class ListServers(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.boot_and_delete_server")
name="NovaServers.boot_and_delete_server",
platform="openstack")
class BootAndDeleteServer(utils.NovaScenario):
def run(self, image, flavor, min_sleep=0, max_sleep=0,
@ -127,7 +129,8 @@ class BootAndDeleteServer(utils.NovaScenario):
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.boot_and_delete_multiple_servers")
name="NovaServers.boot_and_delete_multiple_servers",
platform="openstack")
class BootAndDeleteMultipleServers(utils.NovaScenario):
def run(self, image, flavor, count=2, min_sleep=0,
@ -159,7 +162,8 @@ class BootAndDeleteMultipleServers(utils.NovaScenario):
consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova", "cinder"]},
name="NovaServers.boot_server_from_volume_and_delete")
name="NovaServers.boot_server_from_volume_and_delete",
platform="openstack")
class BootServerFromVolumeAndDelete(utils.NovaScenario,
cinder_utils.CinderBasic):
@ -199,7 +203,8 @@ class BootServerFromVolumeAndDelete(utils.NovaScenario,
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.boot_and_bounce_server")
name="NovaServers.boot_and_bounce_server",
platform="openstack")
class BootAndBounceServer(utils.NovaScenario):
def run(self, image, flavor, force_delete=False, actions=None, **kwargs):
@ -240,7 +245,8 @@ class BootAndBounceServer(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.boot_lock_unlock_and_delete")
name="NovaServers.boot_lock_unlock_and_delete",
platform="openstack")
class BootLockUnlockAndDelete(utils.NovaScenario):
def run(self, image, flavor, min_sleep=0,
@ -275,7 +281,8 @@ class BootLockUnlockAndDelete(utils.NovaScenario):
consts.Service.GLANCE])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova", "glance"]},
name="NovaServers.snapshot_server")
name="NovaServers.snapshot_server",
platform="openstack")
class SnapshotServer(utils.NovaScenario):
def run(self, image, flavor, force_delete=False, **kwargs):
@ -303,7 +310,8 @@ class SnapshotServer(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.boot_server")
name="NovaServers.boot_server",
platform="openstack")
class BootServer(utils.NovaScenario):
def run(self, image, flavor, auto_assign_nic=False, **kwargs):
@ -328,7 +336,8 @@ class BootServer(utils.NovaScenario):
consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova", "cinder"]},
name="NovaServers.boot_server_from_volume")
name="NovaServers.boot_server_from_volume",
platform="openstack")
class BootServerFromVolume(utils.NovaScenario, cinder_utils.CinderBasic):
def run(self, image, flavor, volume_size,
@ -362,7 +371,7 @@ class BootServerFromVolume(utils.NovaScenario, cinder_utils.CinderBasic):
@validation.add("required_services", services=(consts.Service.NOVA))
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.resize_server")
name="NovaServers.resize_server", platform="openstack")
class ResizeServer(utils.NovaScenario):
def run(self, image, flavor, to_flavor, force_delete=False, **kwargs):
@ -396,7 +405,8 @@ class ResizeServer(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.resize_shutoff_server")
name="NovaServers.resize_shutoff_server",
platform="openstack")
class ResizeShutoffServer(utils.NovaScenario):
def run(self, image, flavor, to_flavor, confirm=True,
@ -432,9 +442,10 @@ class ResizeShutoffServer(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA,
consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder", "nova"]},
name=("NovaServers."
"boot_server_attach_created_volume_and_resize"))
@scenario.configure(
context={"cleanup": ["cinder", "nova"]},
name="NovaServers.boot_server_attach_created_volume_and_resize",
platform="openstack")
class BootServerAttachCreatedVolumeAndResize(utils.NovaScenario,
cinder_utils.CinderBasic):
@ -493,9 +504,10 @@ class BootServerAttachCreatedVolumeAndResize(utils.NovaScenario,
@validation.add("required_services", services=[consts.Service.NOVA,
consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["cinder", "nova"]},
name=("NovaServers.boot_server"
"_attach_volume_and_list_attachments"))
@scenario.configure(
context={"cleanup": ["cinder", "nova"]},
name="NovaServers.boot_server_attach_volume_and_list_attachments",
platform="openstack")
class BootServerAttachVolumeAndListAttachments(utils.NovaScenario,
cinder_utils.CinderBasic):
@ -540,7 +552,8 @@ class BootServerAttachVolumeAndListAttachments(utils.NovaScenario,
consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova", "cinder"]},
name="NovaServers.boot_server_from_volume_and_resize")
name="NovaServers.boot_server_from_volume_and_resize",
platform="openstack")
class BootServerFromVolumeAndResize(utils.NovaScenario,
cinder_utils.CinderBasic):
@ -601,7 +614,8 @@ class BootServerFromVolumeAndResize(utils.NovaScenario,
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.suspend_and_resume_server")
name="NovaServers.suspend_and_resume_server",
platform="openstack")
class SuspendAndResumeServer(utils.NovaScenario):
def run(self, image, flavor, force_delete=False, **kwargs):
@ -625,7 +639,8 @@ class SuspendAndResumeServer(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.pause_and_unpause_server")
name="NovaServers.pause_and_unpause_server",
platform="openstack")
class PauseAndUnpauseServer(utils.NovaScenario):
def run(self, image, flavor, force_delete=False, **kwargs):
@ -649,7 +664,8 @@ class PauseAndUnpauseServer(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.shelve_and_unshelve_server")
name="NovaServers.shelve_and_unshelve_server",
platform="openstack")
class ShelveAndUnshelveServer(utils.NovaScenario):
def run(self, image, flavor, force_delete=False, **kwargs):
@ -674,7 +690,8 @@ class ShelveAndUnshelveServer(utils.NovaScenario):
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.boot_and_live_migrate_server")
name="NovaServers.boot_and_live_migrate_server",
platform="openstack")
class BootAndLiveMigrateServer(utils.NovaScenario):
def run(self, image, flavor, block_migration=False, disk_over_commit=False,
@ -716,9 +733,10 @@ class BootAndLiveMigrateServer(utils.NovaScenario):
consts.Service.CINDER])
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"cleanup": ["nova", "cinder"]},
name=("NovaServers.boot_server_from_volume"
"_and_live_migrate"))
@scenario.configure(
context={"cleanup": ["nova", "cinder"]},
name="NovaServers.boot_server_from_volume_and_live_migrate",
platform="openstack")
class BootServerFromVolumeAndLiveMigrate(utils.NovaScenario,
cinder_utils.CinderBasic):
@ -772,9 +790,10 @@ class BootServerFromVolumeAndLiveMigrate(utils.NovaScenario,
consts.Service.CINDER])
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"cleanup": ["cinder", "nova"]},
name=("NovaServers.boot_server_attach_created_volume"
"_and_live_migrate"))
@scenario.configure(
context={"cleanup": ["cinder", "nova"]},
name="NovaServers.boot_server_attach_created_volume_and_live_migrate",
platform="openstack")
class BootServerAttachCreatedVolumeAndLiveMigrate(utils.NovaScenario,
cinder_utils.CinderBasic):
@ -832,7 +851,8 @@ class BootServerAttachCreatedVolumeAndLiveMigrate(utils.NovaScenario,
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.boot_and_migrate_server")
name="NovaServers.boot_and_migrate_server",
platform="openstack")
class BootAndMigrateServer(utils.NovaScenario):
def run(self, image, flavor, **kwargs):
@ -869,7 +889,8 @@ class BootAndMigrateServer(utils.NovaScenario):
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.boot_and_rebuild_server")
name="NovaServers.boot_and_rebuild_server",
platform="openstack")
class BootAndRebuildServer(utils.NovaScenario):
def run(self, from_image, to_image, flavor, **kwargs):
@ -896,7 +917,8 @@ class BootAndRebuildServer(utils.NovaScenario):
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_contexts", contexts=("network"))
@scenario.configure(context={"cleanup": ["nova", "neutron.floatingip"]},
name="NovaServers.boot_and_associate_floating_ip")
name="NovaServers.boot_and_associate_floating_ip",
platform="openstack")
class BootAndAssociateFloatingIp(utils.NovaScenario):
def run(self, image, flavor, **kwargs):
@ -920,7 +942,8 @@ class BootAndAssociateFloatingIp(utils.NovaScenario):
consts.Service.NEUTRON])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova", "neutron"]},
name="NovaServers.boot_server_and_attach_interface")
name="NovaServers.boot_server_and_attach_interface",
platform="openstack")
class BootServerAndAttachInterface(utils.NovaScenario,
neutron_utils.NeutronScenario):
def run(self, image, flavor, network_create_args=None,
@ -953,7 +976,8 @@ class BootServerAndAttachInterface(utils.NovaScenario,
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.boot_and_show_server")
name="NovaServers.boot_and_show_server",
platform="openstack")
class BootAndShowServer(utils.NovaScenario):
def run(self, image, flavor, **kwargs):
@ -978,7 +1002,8 @@ class BootAndShowServer(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.boot_and_get_console_output")
name="NovaServers.boot_and_get_console_output",
platform="openstack")
class BootAndGetConsoleOutput(utils.NovaScenario):
def run(self, image, flavor, length=None, **kwargs):
@ -1005,7 +1030,8 @@ class BootAndGetConsoleOutput(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.boot_and_update_server")
name="NovaServers.boot_and_update_server",
platform="openstack")
class BootAndUpdateServer(utils.NovaScenario):
def run(self, image, flavor, description=None, **kwargs):
@ -1031,7 +1057,8 @@ class BootAndUpdateServer(utils.NovaScenario):
consts.Service.CINDER])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova", "cinder"]},
name="NovaServers.boot_server_from_volume_snapshot")
name="NovaServers.boot_server_from_volume_snapshot",
platform="openstack")
class BootServerFromVolumeSnapshot(utils.NovaScenario,
cinder_utils.CinderBasic):
@ -1068,9 +1095,10 @@ class BootServerFromVolumeSnapshot(utils.NovaScenario,
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_contexts", contexts=("network"))
@scenario.configure(context={"cleanup": ["nova", "neutron.floatingip"]},
name="NovaServers.boot_server_associate_and"
"_dissociate_floating_ip")
@scenario.configure(
context={"cleanup": ["nova", "neutron.floatingip"]},
name="NovaServers.boot_server_associate_and_dissociate_floating_ip",
platform="openstack")
class BootServerAssociateAndDissociateFloatingIP(utils.NovaScenario):
""""Benchmark scenarios for Nova FloatingIp API."""
def run(self, image, flavor, **kwargs):
@ -1099,7 +1127,8 @@ class BootServerAssociateAndDissociateFloatingIP(utils.NovaScenario):
@validation.add("required_platform", platform="openstack", users=True)
@validation.add("required_contexts", contexts=("network"))
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.boot_server_and_list_interfaces")
name="NovaServers.boot_server_and_list_interfaces",
platform="openstack")
class BootServerAndListInterfaces(utils.NovaScenario):
def run(self, image, flavor, **kwargs):
"""Boot a server and list interfaces attached to it.
@ -1124,7 +1153,8 @@ class BootServerAndListInterfaces(utils.NovaScenario):
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova"]},
name="NovaServers.boot_and_get_console_url")
name="NovaServers.boot_and_get_console_url",
platform="openstack")
class BootAndGetConsoleUrl(utils.NovaScenario):
def run(self, image, flavor, console_type, **kwargs):

View File

@ -24,7 +24,7 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.NOVA])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(name="NovaServices.list_services")
@scenario.configure(name="NovaServices.list_services", platform="openstack")
class ListServices(utils.NovaScenario):
def run(self, host=None, binary=None):

View File

@ -25,7 +25,8 @@ from rally.task import validation
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"admin_cleanup": ["nova.quotas"]},
name="Quotas.nova_update")
name="Quotas.nova_update",
platform="openstack")
class NovaUpdate(utils.QuotasScenario):
def run(self, max_quota=1024):
@ -42,7 +43,7 @@ class NovaUpdate(utils.QuotasScenario):
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"admin_cleanup": ["nova.quotas"]},
name="Quotas.nova_update_and_delete")
name="Quotas.nova_update_and_delete", platform="openstack")
class NovaUpdateAndDelete(utils.QuotasScenario):
def run(self, max_quota=1024):
@ -60,7 +61,7 @@ class NovaUpdateAndDelete(utils.QuotasScenario):
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"admin_cleanup": ["cinder.quotas"]},
name="Quotas.cinder_update")
name="Quotas.cinder_update", platform="openstack")
class CinderUpdate(utils.QuotasScenario):
def run(self, max_quota=1024):
@ -77,7 +78,7 @@ class CinderUpdate(utils.QuotasScenario):
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"admin_cleanup": ["cinder.quotas"]},
name="Quotas.cinder_get")
name="Quotas.cinder_get", platform="openstack")
class CinderGet(utils.QuotasScenario):
def run(self):
@ -93,7 +94,8 @@ class CinderGet(utils.QuotasScenario):
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"admin_cleanup": ["cinder.quotas"]},
name="Quotas.cinder_update_and_delete")
name="Quotas.cinder_update_and_delete",
platform="openstack")
class CinderUpdateAndDelete(utils.QuotasScenario):
def run(self, max_quota=1024):
@ -112,7 +114,7 @@ class CinderUpdateAndDelete(utils.QuotasScenario):
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"admin_cleanup": ["neutron.quota"]},
name="Quotas.neutron_update")
name="Quotas.neutron_update", platform="openstack")
class NeutronUpdate(utils.QuotasScenario):
def run(self, max_quota=1024):
@ -130,7 +132,7 @@ class NeutronUpdate(utils.QuotasScenario):
@validation.add("required_platform", platform="openstack",
admin=True, users=True)
@scenario.configure(context={"admin_cleanup": ["nova.quotas"]},
name="Quotas.nova_get")
name="Quotas.nova_get", platform="openstack")
class NovaGet(utils.QuotasScenario):
def run(self):

View File

@ -38,7 +38,8 @@ LOG = logging.getLogger(__name__)
@validation.add("required_services", services=[consts.Service.SAHARA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["sahara"]},
name="SaharaClusters.create_and_delete_cluster")
name="SaharaClusters.create_and_delete_cluster",
platform="openstack")
class CreateAndDeleteCluster(utils.SaharaScenario):
def run(self, workers_count, plugin_name, hadoop_version,
@ -128,7 +129,8 @@ class CreateAndDeleteCluster(utils.SaharaScenario):
@validation.add("number", param_name="workers_count", minval=1,
integer_only=True)
@scenario.configure(context={"cleanup": ["sahara"]},
name="SaharaClusters.create_scale_delete_cluster")
name="SaharaClusters.create_scale_delete_cluster",
platform="openstack")
class CreateScaleDeleteCluster(utils.SaharaScenario):
def run(self, master_flavor, worker_flavor, workers_count,

View File

@ -30,7 +30,8 @@ LOG = logging.getLogger(__name__)
"sahara_job_binaries",
"sahara_cluster"])
@scenario.configure(context={"cleanup": ["sahara"]},
name="SaharaJob.create_launch_job")
name="SaharaJob.create_launch_job",
platform="openstack")
class CreateLaunchJob(utils.SaharaScenario):
def run(self, job_type, configs, job_idx=0):
@ -78,7 +79,8 @@ class CreateLaunchJob(utils.SaharaScenario):
"sahara_job_binaries",
"sahara_cluster"])
@scenario.configure(context={"cleanup": ["sahara"]},
name="SaharaJob.create_launch_job_sequence")
name="SaharaJob.create_launch_job_sequence",
platform="openstack")
class CreateLaunchJobSequence(utils.SaharaScenario):
def run(self, jobs):
@ -102,7 +104,8 @@ class CreateLaunchJobSequence(utils.SaharaScenario):
"sahara_job_binaries",
"sahara_cluster"])
@scenario.configure(context={"cleanup": ["sahara"]},
name="SaharaJob.create_launch_job_sequence_with_scaling")
name="SaharaJob.create_launch_job_sequence_with_scaling",
platform="openstack")
class CreateLaunchJobSequenceWithScaling(utils.SaharaScenario,):
def run(self, jobs, deltas):

View File

@ -26,9 +26,10 @@ from rally.task import validation
@validation.flavor_exists("flavor")
@validation.add("required_services", services=[consts.Service.SAHARA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["sahara"]},
name="SaharaNodeGroupTemplates"
".create_and_list_node_group_templates")
@scenario.configure(
context={"cleanup": ["sahara"]},
name="SaharaNodeGroupTemplates.create_and_list_node_group_templates",
platform="openstack")
class CreateAndListNodeGroupTemplates(utils.SaharaScenario):
def run(self, flavor, plugin_name="vanilla",
@ -71,9 +72,10 @@ class CreateAndListNodeGroupTemplates(utils.SaharaScenario):
@validation.flavor_exists("flavor")
@validation.add("required_services", services=[consts.Service.SAHARA])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["sahara"]},
name="SaharaNodeGroupTemplates"
".create_delete_node_group_templates")
@scenario.configure(
context={"cleanup": ["sahara"]},
name="SaharaNodeGroupTemplates.create_delete_node_group_templates",
platform="openstack")
class CreateDeleteNodeGroupTemplates(utils.SaharaScenario):
def run(self, flavor, plugin_name="vanilla",

View File

@ -23,7 +23,8 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.SENLIN])
@validation.add("required_contexts", contexts=("profiles"))
@scenario.configure(context={"admin_cleanup": ["senlin"]},
name="SenlinClusters.create_and_delete_cluster")
name="SenlinClusters.create_and_delete_cluster",
platform="openstack")
class CreateAndDeleteCluster(utils.SenlinScenario):
def run(self, desired_capacity=0, min_size=0,

View File

@ -27,9 +27,10 @@ from rally.task import validation
@validation.add("required_services", services=[consts.Service.SWIFT])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["swift"]},
name="SwiftObjects.create_container"
"_and_object_then_list_objects")
@scenario.configure(
context={"cleanup": ["swift"]},
name="SwiftObjects.create_container_and_object_then_list_objects",
platform="openstack")
class CreateContainerAndObjectThenListObjects(utils.SwiftScenario):
def run(self, objects_per_container=1, object_size=1024, **kwargs):
@ -52,9 +53,10 @@ class CreateContainerAndObjectThenListObjects(utils.SwiftScenario):
@validation.add("required_services", services=[consts.Service.SWIFT])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["swift"]},
name="SwiftObjects.create_container"
"_and_object_then_delete_all")
@scenario.configure(
context={"cleanup": ["swift"]},
name="SwiftObjects.create_container_and_object_then_delete_all",
platform="openstack")
class CreateContainerAndObjectThenDeleteAll(utils.SwiftScenario):
def run(self, objects_per_container=1, object_size=1024, **kwargs):
@ -83,9 +85,10 @@ class CreateContainerAndObjectThenDeleteAll(utils.SwiftScenario):
@validation.add("required_services", services=[consts.Service.SWIFT])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["swift"]},
name="SwiftObjects.create_container"
"_and_object_then_download_object")
@scenario.configure(
context={"cleanup": ["swift"]},
name="SwiftObjects.create_container_and_object_then_download_object",
platform="openstack")
class CreateContainerAndObjectThenDownloadObject(utils.SwiftScenario):
def run(self, objects_per_container=1, object_size=1024, **kwargs):
@ -113,8 +116,10 @@ class CreateContainerAndObjectThenDownloadObject(utils.SwiftScenario):
@validation.add("required_services", services=[consts.Service.SWIFT])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"swift_objects": {}},
name="SwiftObjects.list_objects_in_containers")
@scenario.configure(
context={"swift_objects": {}},
name="SwiftObjects.list_objects_in_containers",
platform="openstack")
class ListObjectsInContainers(utils.SwiftScenario):
def run(self):
@ -133,9 +138,10 @@ class ListObjectsInContainers(utils.SwiftScenario):
@validation.add("required_services", services=[consts.Service.SWIFT])
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"swift_objects": {}},
name="SwiftObjects.list_and_"
"download_objects_in_containers")
@scenario.configure(
context={"swift_objects": {}},
name="SwiftObjects.list_and_download_objects_in_containers",
platform="openstack")
class ListAndDownloadObjectsInContainers(utils.SwiftScenario):
def run(self):

View File

@ -50,7 +50,8 @@ LOG = logging.getLogger(__name__)
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova", "cinder"],
"keypair": {}, "allow_ssh": None},
name="VMTasks.boot_runcommand_delete")
name="VMTasks.boot_runcommand_delete",
platform="openstack")
class BootRuncommandDelete(vm_utils.VMScenario, cinder_utils.CinderBasic):
def run(self, flavor, username, password=None,
@ -406,7 +407,8 @@ EOF
@validation.add("required_platform", platform="openstack", users=True)
@scenario.configure(context={"cleanup": ["nova", "cinder"],
"keypair": {}, "allow_ssh": None},
name="VMTasks.dd_load_test")
name="VMTasks.dd_load_test",
platform="openstack")
class DDLoadTest(BootRuncommandDelete):
def run(self, command, **kwargs):

View File

@ -23,11 +23,11 @@ from rally.task import validation
@types.convert(strategy={"type": "watcher_strategy"},
goal={"type": "watcher_goal"})
@validation.add("required_services",
services=[consts.Service.WATCHER])
@validation.add("required_services", services=[consts.Service.WATCHER])
@validation.add("required_platform", platform="openstack", admin=True)
@scenario.configure(context={"admin_cleanup": ["watcher"]},
name="Watcher.create_audit_template_and_delete")
name="Watcher.create_audit_template_and_delete",
platform="openstack")
class CreateAuditTemplateAndDelete(utils.WatcherScenario):
@logging.log_deprecated_args("Extra field has been removed "
@ -45,9 +45,8 @@ class CreateAuditTemplateAndDelete(utils.WatcherScenario):
self._delete_audit_template(audit_template.uuid)
@validation.add("required_services",
services=[consts.Service.WATCHER])
@scenario.configure(name="Watcher.list_audit_templates")
@validation.add("required_services", services=[consts.Service.WATCHER])
@scenario.configure(name="Watcher.list_audit_templates", platform="openstack")
class ListAuditTemplates(utils.WatcherScenario):
def run(self, name=None, goal=None, strategy=None,
@ -80,11 +79,11 @@ class ListAuditTemplates(utils.WatcherScenario):
sort_dir=sort_dir, detail=detail)
@validation.add("required_services",
services=[consts.Service.WATCHER])
@validation.add("required_services", services=[consts.Service.WATCHER])
@validation.add("required_contexts", contexts="audit_templates")
@scenario.configure(context={"admin_cleanup": ["watcher"]},
name="Watcher.create_audit_and_delete")
name="Watcher.create_audit_and_delete",
platform="openstack")
class CreateAuditAndDelete(utils.WatcherScenario):
def run(self):

View File

@ -23,7 +23,7 @@ from rally.plugins.openstack.scenarios.zaqar import utils as zutils
@scenario.configure(context={"cleanup": ["zaqar"]},
name="ZaqarBasic.create_queue")
name="ZaqarBasic.create_queue", platform="openstack")
class CreateQueue(zutils.ZaqarScenario):
@logging.log_deprecated_args(
@ -39,7 +39,7 @@ class CreateQueue(zutils.ZaqarScenario):
@scenario.configure(context={"cleanup": ["zaqar"]},
name="ZaqarBasic.producer_consumer")
name="ZaqarBasic.producer_consumer", platform="openstack")
class ProducerConsumer(zutils.ZaqarScenario):
@logging.log_deprecated_args(

View File

@ -37,6 +37,7 @@ def configure(name, order, platform="default", namespace=None, hidden=False):
adds attributes to the class.
:param name: Name of the class, used in the input task
:param platform: str plugin's platform
:param order: As far as we can use multiple context classes that sometimes
depend on each other we have to specify order of execution.
Contexts with smaller order are run first

View File

@ -30,7 +30,9 @@ from rally.task.processing import charts
LOG = logging.getLogger(__name__)
def configure(name, namespace="default", context=None):
@logging.log_deprecated_args("Use 'platform' arg instead", "0.10.0",
["namespace"], log_function=LOG.warning)
def configure(name, platform="default", namespace=None, context=None):
"""Configure scenario by setting proper meta data.
This can also transform plain function into scenario plugin, however
@ -38,18 +40,21 @@ def configure(name, namespace="default", context=None):
based on rally.task.scenario.Scenario.
:param name: str scenario name
:param namespace: str plugin namespace
:param platform: str plugin's platform
:param context: default task context that is created for this scenario.
If there are custom user specified contexts this one
will be updated by provided contexts.
"""
if namespace:
platform = namespace
def wrapper(cls):
# TODO(boris-42): Drop this check as soon as we refactor rally report
if "." not in name.strip("."):
msg = (_("Scenario name must include a dot: '%s'") % name)
raise exceptions.RallyException(msg)
cls = plugin.configure(name=name, platform=namespace)(cls)
cls = plugin.configure(name=name, platform=platform)(cls)
cls._meta_set("default_context", context or {})
return cls