import zuul job settings from project-config

This is a mechanically generated patch to complete step 1 of moving
the zuul job settings out of project-config and into each project
repository.

Because there will be a separate patch on each branch, the branch
specifiers for branch-specific jobs have been removed.

Because this patch is generated by a script, there may be some
cosmetic changes to the layout of the YAML file(s) as the contents are
normalized.

See the python3-first goal document for details:
https://governance.openstack.org/tc/goals/stein/python3-first.html

Change-Id: I6e15638497fc016dca98189dc15397d61d268433
Story: #2002586
Task: #24344

.gitreview

@@ -1,5 +1,5 @@
 [gerrit]
-host=review.opendev.org
+host=review.openstack.org
 port=29418
 project=openstack/python-watcherclient.git
-defaultbranch=stable/queens
+defaultbranch=stable/pike

.zuul.yaml

@@ -5,13 +5,8 @@
       - publish-openstack-sphinx-docs
       - check-requirements
       - openstackclient-plugin-jobs
-    name: openstack/python-watcherclient
     check:
       jobs:
-        - watcherclient-tempest-functional
         - openstack-tox-cover:
             voting: false
 
-    gate:
-      jobs:
-        - watcherclient-tempest-functional

CONTRIBUTING.rst

@@ -1,13 +1,13 @@
 If you would like to contribute to the development of OpenStack,
 you must follow the steps in this page:
 
-   https://docs.openstack.org/infra/manual/developers.html
+   http://docs.openstack.org/infra/manual/developers.html
 
 Once those steps have been completed, changes to OpenStack
 should be submitted for review via the Gerrit tool, following
 the workflow documented at:
 
-   https://docs.openstack.org/infra/manual/developers.html#development-workflow
+   http://docs.openstack.org/infra/manual/developers.html#development-workflow
 
 Pull requests submitted through GitHub will be ignored.
 

HACKING.rst

@@ -1,4 +1,4 @@
 python-watcherclient Style Commandments
 =======================================
 
-Read the OpenStack Style Commandments https://docs.openstack.org/hacking/latest/
+Read the OpenStack Style Commandments http://docs.openstack.org/developer/hacking/

README.rst

@@ -23,9 +23,9 @@ operating costs, increased system performance via intelligent virtual machine
 migration, increased energy efficiency-and more!
 
 * Free software: Apache license
-* Wiki: https://wiki.openstack.org/wiki/Watcher
-* Source: https://git.openstack.org/cgit/openstack/python-watcher
-* Bugs: https://bugs.launchpad.net/watcher
+* Wiki: http://wiki.openstack.org/wiki/Watcher
+* Source: http://git.openstack.org/cgit/openstack/python-watcher
+* Bugs: http://bugs.launchpad.net/watcher
 
 Installation
 ============
@@ -61,7 +61,7 @@ You can install the Watcher CLI with the following command:
    sudo pip install python-watcherclient
 
 
-You can also use the `OpenStack client <https://docs.openstack.org/python-openstackclient/latest/>`_
+You can also use the `OpenStack client <http://docs.openstack.org/cli-reference/overview.html>`_
 with Watcher (our watcher plugin for OpenStack client is included in the
 python-watcherclient package). To install it, you have just to run this command:
 

doc/source/cli/index.rst

@@ -29,4 +29,3 @@ Once you've configured your authentication parameters, you can run
 
    watcher
    openstack_cli
-   details

doc/source/cli/watcher.rst

@@ -55,7 +55,7 @@ fill partially typed commands. To use this feature, source the below file
 https://git.openstack.org/cgit/openstack/python-watcherclient/tree/tools/watcher.bash_completion)
 to your terminal and then bash completion should work::
 
-    $ . watcher.bash_completion
+    $ source watcher.bash_completion
 
 To avoid doing this every time, add this to your ``.bashrc`` or copy the
 watcher.bash_completion file to the default bash completion scripts directory

doc/source/contributing.rst

@@ -19,8 +19,8 @@ signed OpenStack's contributor's agreement.
 
 .. seealso::
 
-   * https://docs.openstack.org/infra/manual/developers.html
-   * https://wiki.openstack.org/CLA
+   * http://docs.openstack.org/infra/manual/developers.html
+   * http://wiki.openstack.org/CLA
 
 LaunchPad Project
 -----------------
@@ -41,7 +41,7 @@ Project Hosting Details
 -------------------------
 
 Bug tracker
-    https://launchpad.net/python-watcherclient
+    http://launchpad.net/python-watcherclient
 
 Mailing list (prefix subjects with ``[watcher]`` for faster responses)
     http://lists.openstack.org/cgi-bin/mailman/listinfo/openstack-dev

doc/source/reference/api_v1.rst

@@ -68,7 +68,7 @@ Once you have an watcher `Client`_, you can perform various tasks::
 
    >>> watcher.action.list()  # list of actions
    >>> watcher.action_plan.list()  # list of action_plan
-   >>> watcher.audit.get(audit_uuid_or_name)  # information about a particular audit
+   >>> watcher.audit.get(audit_uuid)  # information about a particular audit
 
 When the `Client`_ needs to propagate an exception, it will usually
 raise an instance subclassed from

requirements.txt

@@ -3,12 +3,12 @@
 # process, which may cause wedges in the gate later.
 
 Babel!=2.4.0,>=2.3.4 # BSD
-cliff!=2.9.0,>=2.8.0 # Apache-2.0
-osc-lib>=1.8.0 # Apache-2.0
-oslo.i18n>=3.15.3 # Apache-2.0
-oslo.utils>=3.33.0 # Apache-2.0
+cliff>=2.8.0 # Apache-2.0
+osc-lib>=1.7.0 # Apache-2.0
+oslo.i18n!=3.15.2,>=2.1.0 # Apache-2.0
+oslo.utils>=3.20.0 # Apache-2.0
 pbr!=2.1.0,>=2.0.0 # Apache-2.0
 PrettyTable<0.8,>=0.7.1 # BSD
-keystoneauth1>=3.3.0 # Apache-2.0
-six>=1.10.0 # MIT
-PyYAML>=3.10 # MIT
+keystoneauth1>=3.1.0 # Apache-2.0
+six>=1.9.0 # MIT
+PyYAML>=3.10.0 # MIT

setup.cfg

@@ -5,7 +5,7 @@ description-file =
     README.rst
 author = OpenStack
 author-email = openstack-dev@lists.openstack.org
-home-page =  https://docs.openstack.org/python-watcherclient/latest/
+home-page =  http://docs.openstack.org/developer/python-watcherclient
 classifier =
     Environment :: OpenStack
     Intended Audience :: Information Technology
@@ -36,7 +36,6 @@ openstack.infra_optim.v1 =
 
     optimize_strategy_show = watcherclient.v1.strategy_shell:ShowStrategy
     optimize_strategy_list = watcherclient.v1.strategy_shell:ListStrategy
-    optimize_strategy_state = watcherclient.v1.strategy_shell:StateStrategy
 
     optimize_audittemplate_show = watcherclient.v1.audit_template_shell:ShowAuditTemplate
     optimize_audittemplate_list = watcherclient.v1.audit_template_shell:ListAuditTemplate
@@ -73,7 +72,6 @@ watcherclient.v1 =
 
     strategy_show = watcherclient.v1.strategy_shell:ShowStrategy
     strategy_list = watcherclient.v1.strategy_shell:ListStrategy
-    strategy_state = watcherclient.v1.strategy_shell:StateStrategy
 
     audittemplate_show = watcherclient.v1.audit_template_shell:ShowAuditTemplate
     audittemplate_list = watcherclient.v1.audit_template_shell:ListAuditTemplate

test-requirements.txt

@@ -5,15 +5,15 @@
 coverage!=4.4,>=4.0 # Apache-2.0
 fixtures>=3.0.0 # Apache-2.0/BSD
 hacking!=0.13.0,<0.14,>=0.12.0 # Apache-2.0
-mock>=2.0.0 # BSD
-openstackdocstheme>=1.18.1 # Apache-2.0
-oslotest>=3.2.0 # Apache-2.0
-python-subunit>=1.0.0 # Apache-2.0/BSD
-sphinx!=1.6.6,>=1.6.2 # BSD
+mock>=2.0 # BSD
+openstackdocstheme>=1.16.0 # Apache-2.0
+oslotest>=1.10.0 # Apache-2.0
+python-subunit>=0.0.18 # Apache-2.0/BSD
+sphinx>=1.6.2 # BSD
 testrepository>=0.0.18 # Apache-2.0/BSD
 testscenarios>=0.4 # Apache-2.0/BSD
-testtools>=2.2.0 # MIT
-tempest>=17.1.0 # Apache-2.0
+testtools>=1.4.0 # MIT
+tempest>=16.1.0 # Apache-2.0
 
 # Needed for pypi packaging
-wheel>=0.24.0 # MIT
+wheel # MIT

tox.ini

@@ -6,7 +6,7 @@ skipsdist = True
 [testenv]
 usedevelop = True
 install_command =
-                  constraints: pip install -U --force-reinstall -c{env:UPPER_CONSTRAINTS_FILE:https://git.openstack.org/cgit/openstack/requirements/plain/upper-constraints.txt?h=stable/queens} {opts} {packages}
+                  constraints: pip install -U --force-reinstall -c{env:UPPER_CONSTRAINTS_FILE:https://git.openstack.org/cgit/openstack/requirements/plain/upper-constraints.txt?h=stable/pike} {opts} {packages}
                   pip install -U {opts} {packages}
 setenv =
    VIRTUAL_ENV={envdir}

watcherclient/common/httpclient.py

@@ -165,7 +165,8 @@ class VersionNegotiationMixin(object):
         raise NotImplementedError()
 
 
-_RETRY_EXCEPTIONS = (exceptions.ServiceUnavailable,
+_RETRY_EXCEPTIONS = (exceptions.Conflict,
+                     exceptions.ServiceUnavailable,
                      exceptions.ConnectionRefused,
                      kexceptions.RetriableConnectionFailure)
 

watcherclient/common/utils.py

@@ -161,21 +161,17 @@ def common_params_for_list(args, fields, field_labels):
                 args.sort_dir)
         params['sort_dir'] = args.sort_dir
 
-    marker = getattr(args, 'marker', None)
-    if marker is not None:
-        params['marker'] = marker
     params['detail'] = args.detail
 
     return params
 
 
-def common_filters(limit=None, sort_key=None, sort_dir=None, marker=None):
+def common_filters(limit=None, sort_key=None, sort_dir=None):
     """Generate common filters for any list request.
 
     :param limit: maximum number of entities to return.
     :param sort_key: field to use for sorting.
     :param sort_dir: direction of sorting: 'asc' or 'desc'.
-    :param marker: The last actionplan UUID of the previous page.
     :returns: list of string filters.
     """
     filters = []
@@ -185,8 +181,6 @@ def common_filters(limit=None, sort_key=None, sort_dir=None, marker=None):
         filters.append('sort_key=%s' % sort_key)
     if sort_dir is not None:
         filters.append('sort_dir=%s' % sort_dir)
-    if marker is not None:
-        filters.append('marker=%s' % marker)
     return filters
 
 

watcherclient/tests/README.rst

@@ -26,7 +26,7 @@ You need to install virtualenv, create a virtual environment and activate it::
 
     $ pip install virtualenv
     $ virtualenv watcher-env
-    $ . watcher-env/bin/activate
+    $ source watcher-env/bin/activate
 
 Then, to install Tempest you can issue the following commands::
 

watcherclient/tests/functional/hooks/post_test_hook.sh

@@ -24,14 +24,14 @@ function generate_testr_results {
         sudo /usr/os-testr-env/bin/subunit2html $BASE/logs/testrepository.subunit $BASE/logs/testr_results.html
         sudo gzip -9 $BASE/logs/testrepository.subunit
         sudo gzip -9 $BASE/logs/testr_results.html
-        sudo chown $USER:$USER $BASE/logs/testrepository.subunit.gz $BASE/logs/testr_results.html.gz
+        sudo chown jenkins:jenkins $BASE/logs/testrepository.subunit.gz $BASE/logs/testr_results.html.gz
         sudo chmod a+r $BASE/logs/testrepository.subunit.gz $BASE/logs/testr_results.html.gz
     fi
 }
 
 export WATCHERCLIENT_DIR="$BASE/new/python-watcherclient"
 
-sudo chown -R $USER:stack $WATCHERCLIENT_DIR
+sudo chown -R jenkins:stack $WATCHERCLIENT_DIR
 
 # Get admin credentials
 cd $STACK_DIR
@@ -44,7 +44,7 @@ cd $WATCHERCLIENT_DIR
 echo "Running watcherclient functional test suite"
 set +e
 # Preserve env for OS_ credentials
-sudo -E -H -u $USER tox -efunctional
+sudo -E -H -u jenkins tox -efunctional
 EXIT_CODE=$?
 set -e
 

watcherclient/tests/functional/v1/base.py

@@ -10,8 +10,6 @@
 #    License for the specific language governing permissions and limitations
 #    under the License.
 
-import os
-
 import re
 import shlex
 import subprocess
@@ -22,24 +20,9 @@ from tempest.lib.cli import output_parser
 from tempest.lib import exceptions
 
 
-def credentials():
-    creds = {
-        '--os-username': os.environ.get('OS_USERNAME', 'admin'),
-        '--os-password': os.environ.get('OS_PASSWORD', 'secretadmin'),
-        '--os-project-name': os.environ.get('OS_PROJECT_NAME', 'admin'),
-        '--os-auth-url': os.environ.get('OS_AUTH_URL',
-                                        'http://10.0.1.94/identity'),
-        '--os-project-domain-id': os.environ.get('OS_PROJECT_DOMAIN_ID',
-                                                 'default'),
-        '--os-user-domain-id': os.environ.get('OS_USER_DOMAIN_ID', 'default'),
-    }
-    return [x for sub in creds.items() for x in sub]
-
-
 def execute(cmd, fail_ok=False, merge_stderr=False):
     """Executes specified command for the given action."""
     cmdlist = shlex.split(cmd)
-    cmdlist.extend(credentials())
     stdout = subprocess.PIPE
     stderr = subprocess.STDOUT if merge_stderr else subprocess.PIPE
     proc = subprocess.Popen(cmdlist, stdout=stdout, stderr=stderr)

watcherclient/tests/functional/v1/test_action_plan.py

@@ -13,8 +13,6 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-import time
-
 from oslo_utils import uuidutils
 
 from watcherclient.tests.functional.v1 import base
@@ -46,15 +44,6 @@ class ActionPlanTests(base.TestCase):
         output = cls.parse_show(
             cls.watcher('actionplan list --audit %s' % cls.audit_uuid))
         action_plan_uuid = output[0].keys()[0]
-        retry = 10
-        while retry > 0:
-            output = cls.parse_show(
-                cls.watcher('actionplan show %s' % action_plan_uuid))
-            state = [x for x in output if x.keys()[0] == 'State'][0]['State']
-            if state == 'SUCCEEDED':
-                break
-            time.sleep(1)
-            retry -= 1
         raw_output = cls.watcher('actionplan delete %s' % action_plan_uuid)
         cls.assertOutput('', raw_output)
         # Delete audit

watcherclient/tests/functional/v1/test_audit.py

@@ -22,7 +22,7 @@ class AuditTests(base.TestCase):
     """Functional tests for audit."""
 
     dummy_name = 'dummy'
-    list_fields = ['UUID', 'Name', 'Audit Type', 'State', 'Goal', 'Strategy']
+    list_fields = ['UUID', 'Audit Type', 'State', 'Goal', 'Strategy']
     detailed_list_fields = list_fields + ['Created At', 'Updated At',
                                           'Deleted At', 'Parameters',
                                           'Interval', 'Audit Scope',
@@ -71,7 +71,7 @@ class AuditTests(base.TestCase):
 
 class AuditActiveTests(base.TestCase):
 
-    list_fields = ['UUID', 'Name', 'Audit Type', 'State', 'Goal', 'Strategy']
+    list_fields = ['UUID', 'Audit Type', 'State', 'Goal', 'Strategy']
     detailed_list_fields = list_fields + ['Created At', 'Updated At',
                                           'Deleted At', 'Parameters',
                                           'Interval', 'Audit Scope']

watcherclient/tests/functional/v1/test_strategy.py

@@ -20,9 +20,7 @@ class StrategyTests(base.TestCase):
     """Functional tests for strategy."""
 
     dummy_name = 'dummy'
-    basic_strategy = 'basic'
     list_fields = ['UUID', 'Name', 'Display name', 'Goal']
-    state_fields = ['Datasource', 'Metrics', 'CDM', 'Name']
 
     def test_strategy_list(self):
         raw_output = self.watcher('strategy list')
@@ -41,8 +39,3 @@ class StrategyTests(base.TestCase):
         self.assert_table_structure([raw_output],
                                     self.list_fields + ['Parameters spec'])
         self.assertNotIn('basic', raw_output)
-
-    def test_strategy_state(self):
-        raw_output = self.watcher('strategy state %s' % self.basic_strategy)
-        self.assertIn(self.basic_strategy, raw_output)
-        self.assert_table_structure([raw_output], self.state_fields)

watcherclient/tests/unit/test_utils.py

@@ -97,8 +97,7 @@ class UtilsTest(test_utils.BaseTestCase):
 class CommonParamsForListTest(test_utils.BaseTestCase):
     def setUp(self):
         super(CommonParamsForListTest, self).setUp()
-        self.args = mock.Mock(limit=None, marker=None,
-                              sort_key=None, sort_dir=None)
+        self.args = mock.Mock(limit=None, sort_key=None, sort_dir=None)
         self.args.detail = False
         self.expected_params = {'detail': False}
 
@@ -118,13 +117,6 @@ class CommonParamsForListTest(test_utils.BaseTestCase):
                           utils.common_params_for_list,
                           self.args, [], [])
 
-    def test_marker(self):
-        self.args.marker = 'e420a881-d7df-4de2-bbf3-378cc13d9b3a'
-        self.expected_params.update(
-            {'marker': 'e420a881-d7df-4de2-bbf3-378cc13d9b3a'})
-        self.assertEqual(self.expected_params,
-                         utils.common_params_for_list(self.args, [], []))
-
     def test_sort_key_and_sort_dir(self):
         self.args.sort_key = 'field'
         self.args.sort_dir = 'desc'

watcherclient/tests/unit/v1/test_action.py

@@ -144,16 +144,6 @@ fake_responses_sorting = {
     },
 }
 
-fake_responses_marker = {
-    '/v1/actions/?marker=770ef053-ecb3-48b0-85b5-d55a2dbc6588':
-    {
-        'GET': (
-            {},
-            {"actions": [ACTION2, ACTION3]}
-        ),
-    },
-}
-
 
 class ActionManagerTest(testtools.TestCase):
 
@@ -241,20 +231,6 @@ class ActionManagerTest(testtools.TestCase):
         self.assertEqual(expect, self.api.calls)
         self.assertEqual(3, len(actions))
 
-    def test_actions_list_marker(self):
-        self.api = utils.FakeAPI(fake_responses_marker)
-        self.mgr = watcherclient.v1.action.ActionManager(self.api)
-        actions = self.mgr.list(
-            marker='770ef053-ecb3-48b0-85b5-d55a2dbc6588')
-        expect = [
-            ('GET',
-             '/v1/actions/?marker=770ef053-ecb3-48b0-85b5-d55a2dbc6588',
-             {},
-             None)
-        ]
-        self.assertEqual(expect, self.api.calls)
-        self.assertEqual(2, len(actions))
-
     def test_actions_show(self):
         action = self.mgr.get(ACTION1['uuid'])
         expect = [

watcherclient/tests/unit/v1/test_action_plan.py

@@ -94,13 +94,6 @@ fake_responses_pagination = {
             {"action_plans": [ACTION_PLAN2]}
         ),
     },
-    '/v1/action_plans/?marker=f8e47706-efcf-49a4-a5c4-af604eb492f2':
-    {
-        'GET': (
-            {},
-            {"action_plans": [ACTION_PLAN2]}
-        ),
-    },
 }
 
 fake_responses_sorting = {
@@ -165,19 +158,6 @@ class ActionPlanManagerTest(testtools.TestCase):
         self.assertEqual(expect, self.api.calls)
         self.assertThat(action_plans, matchers.HasLength(2))
 
-    def test_action_plans_list_marker(self):
-        self.api = utils.FakeAPI(fake_responses_pagination)
-        self.mgr = watcherclient.v1.action_plan.ActionPlanManager(self.api)
-        action_plans = self.mgr.list(
-            marker='f8e47706-efcf-49a4-a5c4-af604eb492f2')
-        expect = [
-            ('GET', '/v1/action_plans/?'
-             'marker=f8e47706-efcf-49a4-a5c4-af604eb492f2',
-             {}, None),
-        ]
-        self.assertEqual(expect, self.api.calls)
-        self.assertThat(action_plans, matchers.HasLength(1))
-
     def test_action_plans_list_sort_key(self):
         self.api = utils.FakeAPI(fake_responses_sorting)
         self.mgr = watcherclient.v1.action_plan.ActionPlanManager(self.api)

watcherclient/tests/unit/v1/test_action_plan_shell.py

@@ -33,16 +33,12 @@ ACTION_PLAN_1 = {
                              'unit': '%'}],
     'created_at': datetime.datetime.now().isoformat(),
     'updated_at': None,
-    'global_efficacy': [
-        {"value": 99,
-         "unit": "%",
-         "name": "dummy_global_efficacy",
-         "description": "Dummy Global Efficacy"},
-        {"value": 75,
-         "unit": "%",
-         "name": "dummy_global_efficacy2",
-         "description": "Dummy Global Efficacy2"}
-        ],
+    'global_efficacy': {
+        "value": 99,
+        "unit": "%",
+        "name": "dummy_global_efficacy",
+        "description": "Dummy Global Efficacy",
+    },
     'deleted_at': None,
 }
 
@@ -56,12 +52,12 @@ ACTION_PLAN_2 = {
                              'name': 'indicator2',
                              'unit': '%'}],
     'updated_at': None,
-    'global_efficacy': [{
+    'global_efficacy': {
         "value": 87,
         "unit": "%",
         "name": "dummy_global_efficacy",
         "description": "Dummy Global Efficacy",
-    }],
+    },
     'deleted_at': None,
 }
 
@@ -73,7 +69,6 @@ class ActionPlanShellTest(base.CommandTestCase):
         resource_fields.ACTION_PLAN_SHORT_LIST_FIELD_LABELS)
     FIELDS = resource_fields.ACTION_PLAN_FIELDS
     FIELD_LABELS = resource_fields.ACTION_PLAN_FIELD_LABELS
-    GLOBAL_EFFICACY_FIELDS = resource_fields.GLOBAL_EFFICACY_FIELDS
 
     def setUp(self):
         super(self.__class__, self).setUp()
@@ -119,11 +114,6 @@ class ActionPlanShellTest(base.CommandTestCase):
                                    self.SHORT_LIST_FIELD_LABELS)],
             results)
 
-        self.assertEqual(action_plan1.global_efficacy,
-                         results[0]['Global efficacy'])
-        self.assertEqual(action_plan2.global_efficacy,
-                         results[1]['Global efficacy'])
-
         self.m_action_plan_mgr.list.assert_called_once_with(detail=False)
 
     def test_do_action_plan_list_detail(self):
@@ -141,10 +131,6 @@ class ActionPlanShellTest(base.CommandTestCase):
              self.resource_as_dict(action_plan2, self.FIELDS,
                                    self.FIELD_LABELS)],
             results)
-        self.assertEqual(action_plan1.global_efficacy,
-                         results[0]['Global efficacy'])
-        self.assertEqual(action_plan2.global_efficacy,
-                         results[1]['Global efficacy'])
 
         self.m_action_plan_mgr.list.assert_called_once_with(detail=True)
 
@@ -179,8 +165,6 @@ class ActionPlanShellTest(base.CommandTestCase):
             self.resource_as_dict(
                 action_plan, self.FIELDS, self.FIELD_LABELS),
             result)
-        self.assertEqual(action_plan.global_efficacy,
-                         result['Global efficacy'])
         self.m_action_plan_mgr.get.assert_called_once_with(
             'd9d9978e-6db5-4a05-8eab-1531795d7004')
 

watcherclient/tests/unit/v1/test_action_shell.py

@@ -132,27 +132,6 @@ class ActionShellTest(base.CommandTestCase):
 
         self.m_action_mgr.list.assert_called_once_with(detail=True)
 
-    def test_do_action_list_marker(self):
-        action2 = resource.Action(mock.Mock(), ACTION_2)
-        action3 = resource.Action(mock.Mock(), ACTION_3)
-        self.m_action_mgr.list.return_value = [
-            action2, action3]
-
-        exit_code, results = self.run_cmd(
-            'action list --marker 770ef053-ecb3-48b0-85b5-d55a2dbc6588')
-
-        self.assertEqual(0, exit_code)
-        self.assertEqual(
-            [self.resource_as_dict(action2, self.SHORT_LIST_FIELDS,
-                                   self.SHORT_LIST_FIELD_LABELS),
-             self.resource_as_dict(action3, self.SHORT_LIST_FIELDS,
-                                   self.SHORT_LIST_FIELD_LABELS)],
-            results)
-
-        self.m_action_mgr.list.assert_called_once_with(
-            detail=False,
-            marker='770ef053-ecb3-48b0-85b5-d55a2dbc6588')
-
     def test_do_action_show_by_uuid(self):
         action = resource.Action(mock.Mock(), ACTION_1)
         self.m_action_mgr.get.return_value = action

watcherclient/tests/unit/v1/test_audit.py

@@ -145,16 +145,6 @@ fake_responses_strategy = {
     },
 }
 
-fake_responses_marker = {
-    '/v1/audits/?marker=5869da81-4876-4687-a1ed-12cd64cf53d9':
-    {
-        'GET': (
-            {},
-            {"audits": [AUDIT2]}
-        ),
-    },
-}
-
 
 class AuditManagerTest(testtools.TestCase):
     def setUp(self):
@@ -239,17 +229,6 @@ class AuditManagerTest(testtools.TestCase):
         self.assertEqual(expect, self.api.calls)
         self.assertEqual(1, len(audits))
 
-    def test_audits_list_marker(self):
-        self.api = utils.FakeAPI(fake_responses_marker)
-        self.mgr = watcherclient.v1.audit.AuditManager(self.api)
-        audits = self.mgr.list(marker=AUDIT1['uuid'])
-        expect = [
-            ('GET', '/v1/audits/?marker=5869da81-4876-4687-a1ed-12cd64cf53d9',
-             {}, None),
-        ]
-        self.assertEqual(expect, self.api.calls)
-        self.assertEqual(1, len(audits))
-
     def test_audits_show(self):
         audit = self.mgr.get(AUDIT1['uuid'])
         expect = [

watcherclient/tests/unit/v1/test_audit_shell.py

@@ -17,6 +17,7 @@ import datetime
 import mock
 import six
 
+from watcherclient import exceptions
 from watcherclient import shell
 from watcherclient.tests.unit.v1 import base
 from watcherclient import v1 as resource
@@ -68,7 +69,6 @@ AUDIT_1 = {
     'scope': '',
     'auto_trigger': False,
     'next_run_time': None,
-    'name': 'my_audit1',
 }
 
 AUDIT_2 = {
@@ -87,7 +87,6 @@ AUDIT_2 = {
     'scope': '',
     'auto_trigger': False,
     'next_run_time': None,
-    'name': 'my_audit2',
 }
 
 AUDIT_3 = {
@@ -106,7 +105,6 @@ AUDIT_3 = {
     'scope': '',
     'auto_trigger': True,
     'next_run_time': None,
-    'name': 'my_audit3',
 }
 
 
@@ -172,23 +170,6 @@ class AuditShellTest(base.CommandTestCase):
 
         self.m_audit_mgr.list.assert_called_once_with(detail=False)
 
-    def test_do_audit_list_marker(self):
-        audit2 = resource.Audit(mock.Mock(), AUDIT_2)
-        self.m_audit_mgr.list.return_value = [audit2]
-
-        exit_code, results = self.run_cmd(
-            'audit list --marker 5869da81-4876-4687-a1ed-12cd64cf53d9')
-
-        self.assertEqual(0, exit_code)
-        self.assertEqual(
-            [self.resource_as_dict(audit2, self.SHORT_LIST_FIELDS,
-                                   self.SHORT_LIST_FIELD_LABELS)],
-            results)
-
-        self.m_audit_mgr.list.assert_called_once_with(
-            detail=False,
-            marker='5869da81-4876-4687-a1ed-12cd64cf53d9')
-
     def test_do_audit_list_detail(self):
         audit1 = resource.Audit(mock.Mock(), AUDIT_1)
         audit2 = resource.Audit(mock.Mock(), AUDIT_2)
@@ -221,19 +202,14 @@ class AuditShellTest(base.CommandTestCase):
         self.m_audit_mgr.get.assert_called_once_with(
             '5869da81-4876-4687-a1ed-12cd64cf53d9')
 
-    def test_do_audit_show_by_name(self):
-        audit = resource.Audit(mock.Mock(), AUDIT_1)
-        self.m_audit_mgr.get.return_value = audit
+    def test_do_audit_show_by_not_uuid(self):
+        self.m_audit_mgr.get.side_effect = exceptions.HTTPNotFound
 
         exit_code, result = self.run_cmd(
-            'audit show my_audit')
+            'audit show not_uuid', formatting=None)
 
-        self.assertEqual(0, exit_code)
-        self.assertEqual(
-            self.resource_as_dict(audit, self.FIELDS, self.FIELD_LABELS),
-            result)
-        self.m_audit_mgr.get.assert_called_once_with(
-            'my_audit')
+        self.assertEqual(1, exit_code)
+        self.assertEqual('', result)
 
     def test_do_audit_delete(self):
         self.m_audit_mgr.delete.return_value = ''
@@ -247,18 +223,6 @@ class AuditShellTest(base.CommandTestCase):
         self.m_audit_mgr.delete.assert_called_once_with(
             '5869da81-4876-4687-a1ed-12cd64cf53d9')
 
-    def test_do_audit_delete_by_name(self):
-        self.m_audit_mgr.delete.return_value = ''
-
-        exit_code, result = self.run_cmd(
-            'audit delete my_audit',
-            formatting=None)
-
-        self.assertEqual(0, exit_code)
-        self.assertEqual('', result)
-        self.m_audit_mgr.delete.assert_called_once_with(
-            'my_audit')
-
     def test_do_audit_delete_multiple(self):
         self.m_audit_mgr.delete.return_value = ''
 
@@ -274,6 +238,16 @@ class AuditShellTest(base.CommandTestCase):
         self.m_audit_mgr.delete.assert_any_call(
             '5b157edd-5a7e-4aaa-b511-f7b33ec86e9f')
 
+    def test_do_audit_delete_with_not_uuid(self):
+        self.m_audit_mgr.delete.return_value = ''
+
+        exit_code, result = self.run_cmd(
+            'audit delete not_uuid',
+            formatting=None)
+
+        self.assertEqual(1, exit_code)
+        self.assertEqual('', result)
+
     def test_do_audit_update(self):
         audit = resource.Audit(mock.Mock(), AUDIT_1)
         self.m_audit_mgr.update.return_value = audit
@@ -290,20 +264,14 @@ class AuditShellTest(base.CommandTestCase):
             '5869da81-4876-4687-a1ed-12cd64cf53d9',
             [{'op': 'replace', 'path': '/state', 'value': 'PENDING'}])
 
-    def test_do_audit_update_by_name(self):
-        audit = resource.Audit(mock.Mock(), AUDIT_1)
-        self.m_audit_mgr.update.return_value = audit
+    def test_do_audit_update_with_not_uuid(self):
+        self.m_audit_mgr.update.return_value = ''
 
         exit_code, result = self.run_cmd(
-            'audit update my_audit replace state=PENDING')
+            'audit update not_uuid replace state=PENDING', formatting=None)
 
-        self.assertEqual(0, exit_code)
-        self.assertEqual(
-            self.resource_as_dict(audit, self.FIELDS, self.FIELD_LABELS),
-            result)
-        self.m_audit_mgr.update.assert_called_once_with(
-            'my_audit',
-            [{'op': 'replace', 'path': '/state', 'value': 'PENDING'}])
+        self.assertEqual(1, exit_code)
+        self.assertEqual('', result)
 
     def test_do_audit_create_with_audit_template_uuid(self):
         audit = resource.Audit(mock.Mock(), AUDIT_3)
@@ -320,9 +288,7 @@ class AuditShellTest(base.CommandTestCase):
             result)
         self.m_audit_mgr.create.assert_called_once_with(
             audit_template_uuid='f8e47706-efcf-49a4-a5c4-af604eb492f2',
-            audit_type='ONESHOT',
-            auto_trigger=False
-        )
+            audit_type='ONESHOT', auto_trigger=False)
 
     def test_do_audit_create_with_audit_template_name(self):
         audit = resource.Audit(mock.Mock(), AUDIT_3)
@@ -339,8 +305,7 @@ class AuditShellTest(base.CommandTestCase):
         self.m_audit_mgr.create.assert_called_once_with(
             audit_template_uuid='f8e47706-efcf-49a4-a5c4-af604eb492f2',
             auto_trigger=False,
-            audit_type='ONESHOT'
-        )
+            audit_type='ONESHOT')
 
     def test_do_audit_create_with_goal(self):
         audit = resource.Audit(mock.Mock(), AUDIT_1)
@@ -391,9 +356,7 @@ class AuditShellTest(base.CommandTestCase):
             result)
         self.m_audit_mgr.create.assert_called_once_with(
             goal='fc087747-61be-4aad-8126-b701731ae836',
-            auto_trigger=False,
-            audit_type='ONESHOT'
-        )
+            auto_trigger=False, audit_type='ONESHOT')
 
     def test_do_audit_create_with_parameter(self):
         audit = resource.Audit(mock.Mock(), AUDIT_1)
@@ -411,8 +374,7 @@ class AuditShellTest(base.CommandTestCase):
             goal='fc087747-61be-4aad-8126-b701731ae836',
             audit_type='ONESHOT',
             auto_trigger=False,
-            parameters={'para1': 10, 'para2': 20}
-        )
+            parameters={'para1': 10, 'para2': 20})
 
     def test_do_audit_create_with_type_continuous(self):
         audit = resource.Audit(mock.Mock(), AUDIT_1)
@@ -430,25 +392,4 @@ class AuditShellTest(base.CommandTestCase):
             goal='fc087747-61be-4aad-8126-b701731ae836',
             audit_type='CONTINUOUS',
             auto_trigger=False,
-            interval='3600'
-        )
-
-    def test_do_audit_create_with_name(self):
-        audit = resource.Audit(mock.Mock(), AUDIT_1)
-        self.m_audit_mgr.create.return_value = audit
-
-        exit_code, result = self.run_cmd(
-            'audit create -g fc087747-61be-4aad-8126-b701731ae836 '
-            '-t CONTINUOUS -i 3600 --name my_audit')
-
-        self.assertEqual(0, exit_code)
-        self.assertEqual(
-            self.resource_as_dict(audit, self.FIELDS, self.FIELD_LABELS),
-            result)
-        self.m_audit_mgr.create.assert_called_once_with(
-            goal='fc087747-61be-4aad-8126-b701731ae836',
-            audit_type='CONTINUOUS',
-            auto_trigger=False,
-            interval='3600',
-            name='my_audit'
-        )
+            interval='3600')

watcherclient/tests/unit/v1/test_audit_template.py

@@ -178,16 +178,6 @@ fake_responses_sorting = {
     },
 }
 
-fake_responses_marker = {
-    '/v1/audit_templates/?marker=f8e47706-efcf-49a4-a5c4-af604eb492f2':
-    {
-        'GET': (
-            {},
-            {"audit_templates": [AUDIT_TMPL2, AUDIT_TMPL3]}
-        ),
-    },
-}
-
 fake_responses_filter_by_goal_uuid = {
     '/v1/audit_templates/?goal=e75ee410-b32b-465f-88b5-4397705f9473':
     {
@@ -399,18 +389,6 @@ class AuditTemplateManagerTest(utils.BaseTestCase):
         self.assertEqual(expect, self.api.calls)
         self.assertEqual(3, len(audit_templates))
 
-    def test_audit_templates_list_marker(self):
-        self.api = utils.FakeAPI(fake_responses_marker)
-        self.mgr = watcherclient.v1.audit_template.AuditTemplateManager(
-            self.api)
-        audit_templates = self.mgr.list(marker=AUDIT_TMPL1['uuid'])
-        expect_url = '/v1/audit_templates/?marker=%s' % AUDIT_TMPL1['uuid']
-        expect = [
-            ('GET', expect_url, {}, None)
-        ]
-        self.assertEqual(expect, self.api.calls)
-        self.assertEqual(2, len(audit_templates))
-
     def test_audit_templates_show(self):
         audit_template = self.mgr.get(AUDIT_TMPL1['uuid'])
         expect = [

watcherclient/tests/unit/v1/test_audit_template_shell.py

@@ -128,24 +128,6 @@ class AuditTemplateShellTest(base.CommandTestCase):
 
         self.m_audit_template_mgr.list.assert_called_once_with(detail=False)
 
-    def test_do_audit_template_list_marker(self):
-        audit_template2 = resource.AuditTemplate(mock.Mock(), AUDIT_TEMPLATE_2)
-        self.m_audit_template_mgr.list.return_value = [audit_template2]
-
-        exit_code, results = self.run_cmd(
-            'audittemplate list --marker '
-            'f8e47706-efcf-49a4-a5c4-af604eb492f2')
-
-        self.assertEqual(0, exit_code)
-        self.assertEqual(
-            [self.resource_as_dict(audit_template2, self.SHORT_LIST_FIELDS,
-                                   self.SHORT_LIST_FIELD_LABELS)],
-            results)
-
-        self.m_audit_template_mgr.list.assert_called_once_with(
-            detail=False,
-            marker='f8e47706-efcf-49a4-a5c4-af604eb492f2')
-
     def test_do_audit_template_list_detail(self):
         audit_template1 = resource.AuditTemplate(mock.Mock(), AUDIT_TEMPLATE_1)
         audit_template2 = resource.AuditTemplate(mock.Mock(), AUDIT_TEMPLATE_2)

watcherclient/tests/unit/v1/test_strategy.py

@@ -63,13 +63,6 @@ fake_responses = {
             STRATEGY1,
         ),
     },
-    '/v1/strategies/%s/state' % STRATEGY1['name']:
-    {
-        'GET': (
-            {},
-            STRATEGY1,
-        ),
-    },
 }
 
 fake_responses_pagination = {
@@ -187,10 +180,3 @@ class StrategyManagerTest(testtools.TestCase):
         ]
         self.assertEqual(expect, self.api.calls)
         self.assertEqual(STRATEGY1['name'], strategy.name)
-
-    def test_strategies_state(self):
-        self.mgr.state(STRATEGY1['name'])
-        expect = [
-            ('GET', '/v1/strategies/%s/state' % STRATEGY1['name'], {}, None),
-        ]
-        self.assertEqual(expect, self.api.calls)

watcherclient/tests/unit/v1/test_strategy_shell.py

@@ -17,8 +17,6 @@ import datetime
 import mock
 import six
 
-from oslo_serialization import jsonutils
-
 from watcherclient import shell
 from watcherclient.tests.unit.v1 import base
 from watcherclient import v1 as resource
@@ -56,8 +54,6 @@ class StrategyShellTest(base.CommandTestCase):
         resource_fields.STRATEGY_SHORT_LIST_FIELD_LABELS)
     FIELDS = resource_fields.STRATEGY_FIELDS
     FIELD_LABELS = resource_fields.STRATEGY_FIELD_LABELS
-    STATE_FIELDS = resource_fields.STRATEGY_STATE_FIELDS
-    STATE_FIELD_LABELS = resource_fields.STRATEGY_STATE_FIELD_LABELS
 
     def setUp(self):
         super(self.__class__, self).setUp()
@@ -159,33 +155,3 @@ class StrategyShellTest(base.CommandTestCase):
             result)
         self.m_strategy_mgr.get.assert_called_once_with(
             'f8e47706-efcf-49a4-a5c4-af604eb492f2')
-
-    def test_do_strategy_state(self):
-        strategy1 = resource.Strategy(mock.Mock(), STRATEGY_1)
-        strategy_req = [
-            {'type': 'Datasource', 'mandatory': True,
-             'comment': '', 'state': 'gnocchi: True'},
-            {'type': 'Metrics', 'mandatory': False,
-             'comment': '', 'state': jsonutils.dumps([
-                 {'compute.node.cpu.percent': 'available'},
-                 {'cpu_util': 'available'},
-                 {'memory.resident': 'available'},
-                 {'hardware.memory.used': 'not available'}])},
-            {'type': 'CDM', 'mandatory': True,
-             'comment': '',
-             'state': jsonutils.dumps([{'compute_model': 'available'},
-                                      {'storage_model': 'not available'}])},
-            {'type': 'Name', 'mandatory': '', 'comment': '',
-             'state': strategy1.name}]
-        requirements = [resource.Strategy(mock.Mock(), req)
-                        for req in strategy_req]
-        self.m_strategy_mgr.state.return_value = requirements
-
-        exit_code, results = self.run_cmd('strategy state basic')
-
-        self.assertEqual(0, exit_code)
-        self.assertEqual(
-            [self.resource_as_dict(req, self.STATE_FIELDS,
-                                   self.STATE_FIELD_LABELS)
-             for req in requirements],
-            results)

watcherclient/v1/action.py

@@ -30,7 +30,7 @@ class ActionManager(base.Manager):
         return '/v1/actions/%s' % id if id else '/v1/actions'
 
     def list(self, action_plan=None, audit=None, limit=None, sort_key=None,
-             sort_dir=None, detail=False, marker=None):
+             sort_dir=None, detail=False):
         """Retrieve a list of action.
 
         :param action_plan: UUID of the action plan
@@ -52,15 +52,13 @@ class ActionManager(base.Manager):
         :param detail: Optional, boolean whether to return detailed information
                        about actions.
 
-        :param marker: Optional, UUID of the last action in the previous page.
-
         :returns: A list of actions.
 
         """
         if limit is not None:
             limit = int(limit)
 
-        filters = utils.common_filters(limit, sort_key, sort_dir, marker)
+        filters = utils.common_filters(limit, sort_key, sort_dir)
         if action_plan is not None:
             filters.append('action_plan_uuid=%s' % action_plan)
         if audit is not None:

watcherclient/v1/action_plan.py

@@ -31,7 +31,7 @@ class ActionPlanManager(base.Manager):
         return '/v1/action_plans/%s' % id if id else '/v1/action_plans'
 
     def list(self, audit=None, limit=None, sort_key=None,
-             sort_dir=None, detail=False, marker=None):
+             sort_dir=None, detail=False):
         """Retrieve a list of action plan.
 
         :param audit: Name of the audit
@@ -52,16 +52,13 @@ class ActionPlanManager(base.Manager):
         :param detail: Optional, boolean whether to return detailed information
                        about action plans.
 
-        :param marker: The last actionplan UUID of the previous page;
-                       displays list of actionplans after "marker".
-
         :returns: A list of action plans.
 
         """
         if limit is not None:
             limit = int(limit)
 
-        filters = utils.common_filters(limit, sort_key, sort_dir, marker)
+        filters = utils.common_filters(limit, sort_key, sort_dir)
         if audit is not None:
             filters.append('audit_uuid=%s' % audit)
 

watcherclient/v1/action_plan_shell.py

@@ -26,16 +26,16 @@ from watcherclient.v1 import resource_fields as res_fields
 
 
 def format_global_efficacy(global_efficacy):
-    formatted_global_eff = {}
-    for eff in global_efficacy:
-        if (eff.get('value') is not None and eff.get('unit')):
-            eff_name = eff.get('name')
-            formatted_global_eff[eff_name] = "%(value).2f %(unit)s" % dict(
-                unit=eff.get('unit'),
-                value=eff.get('value'))
-        elif eff.get('value') is not None:
-            formatted_global_eff[eff_name] = eff.get('value')
-    return formatted_global_eff
+    formatted_global_efficacy = None
+    if (global_efficacy.get('value') is not None and
+            global_efficacy.get('unit')):
+        formatted_global_efficacy = "%(value).2f %(unit)s" % dict(
+            unit=global_efficacy.get('unit'),
+            value=global_efficacy.get('value'))
+    elif global_efficacy.get('value') is not None:
+        formatted_global_efficacy = global_efficacy.get('value')
+
+    return formatted_global_efficacy
 
 
 class ShowActionPlan(command.ShowOne):
@@ -64,18 +64,6 @@ class ShowActionPlan(command.ShowOne):
             )
         return out.getvalue() or ''
 
-    def _format_global_efficacy(self, global_efficacy, parsed_args):
-        formatted_global_efficacy = format_global_efficacy(global_efficacy)
-        out = six.StringIO()
-        yaml_format.YAMLFormatter().emit_one(
-            column_names=list(resource.capitalize()
-                              for resource in formatted_global_efficacy),
-            data=[value for value in formatted_global_efficacy.itervalues()],
-            stdout=out,
-            parsed_args=parsed_args,
-            )
-        return out.getvalue() or ''
-
     def take_action(self, parsed_args):
         client = getattr(self.app.client_manager, "infra-optim")
 
@@ -95,8 +83,8 @@ class ShowActionPlan(command.ShowOne):
                 self._format_indicators(action_plan, parsed_args))
 
             # Update the raw global efficacy with the formatted one
-            action_plan.global_efficacy = self._format_global_efficacy(
-                action_plan.global_efficacy, parsed_args)
+            action_plan.global_efficacy = format_global_efficacy(
+                action_plan.global_efficacy)
 
         columns = res_fields.ACTION_PLAN_FIELDS
         column_headers = res_fields.ACTION_PLAN_FIELD_LABELS
@@ -125,11 +113,6 @@ class ListActionPlan(command.Lister):
             help=_('Maximum number of action plans to return per request, '
                    '0 for no limit. Default is the maximum number used '
                    'by the Watcher API Service.'))
-        parser.add_argument(
-            '--marker',
-            metavar='<actionplan>',
-            help=_('The last actionplan UUID of the previous page; '
-                   'displays list of actionplans after "marker".'))
         parser.add_argument(
             '--sort-key',
             metavar='<field>',
@@ -156,18 +139,6 @@ class ListActionPlan(command.Lister):
             )
         return out.getvalue() or ''
 
-    def _format_global_efficacy(self, global_efficacy, parsed_args):
-        formatted_global_efficacy = format_global_efficacy(global_efficacy)
-        out = six.StringIO()
-        yaml_format.YAMLFormatter().emit_one(
-            column_names=list(resource.capitalize()
-                              for resource in formatted_global_efficacy),
-            data=[value for value in formatted_global_efficacy.values()],
-            stdout=out,
-            parsed_args=parsed_args,
-            )
-        return out.getvalue() or ''
-
     def take_action(self, parsed_args):
         client = getattr(self.app.client_manager, "infra-optim")
 
@@ -193,8 +164,8 @@ class ListActionPlan(command.Lister):
                     self._format_indicators(action_plan, parsed_args))
 
                 # Update the raw global efficacy with the formatted one
-                action_plan.global_efficacy = self._format_global_efficacy(
-                    action_plan.global_efficacy, parsed_args)
+                action_plan.global_efficacy = format_global_efficacy(
+                    action_plan.global_efficacy)
 
         return (field_labels,
                 (utils.get_item_properties(item, fields) for item in data))

watcherclient/v1/action_shell.py

@@ -83,13 +83,6 @@ class ListAction(command.Lister):
             metavar='<direction>',
             choices=['asc', 'desc'],
             help=_('Sort direction: "asc" (the default) or "desc".'))
-        parser.add_argument(
-            '--marker',
-            dest='marker',
-            metavar='<marker>',
-            default=None,
-            help=_('UUID of the last action in the previous page; '
-                   'displays list of actions after "marker".'))
 
         return parser
 

watcherclient/v1/audit.py

@@ -19,8 +19,7 @@ from watcherclient import exceptions as exc
 
 
 CREATION_ATTRIBUTES = ['audit_template_uuid', 'audit_type', 'interval',
-                       'parameters', 'goal', 'strategy', 'auto_trigger',
-                       'name']
+                       'parameters', 'goal', 'strategy', 'auto_trigger']
 
 
 class Audit(base.Resource):
@@ -36,11 +35,11 @@ class AuditManager(base.Manager):
         return '/v1/audits/%s' % id if id else '/v1/audits'
 
     def list(self, audit_template=None, limit=None, sort_key=None,
-             sort_dir=None, detail=False, goal=None, strategy=None,
-             marker=None):
+             sort_dir=None, detail=False, goal=None, strategy=None):
         """Retrieve a list of audit.
 
-        :param audit_template: Name of the audit template
+        :param audit_template: Name of the audit
+        :param name: Name of the audit
         :param limit: The maximum number of results to return per
                       request, if:
 
@@ -58,15 +57,13 @@ class AuditManager(base.Manager):
         :param detail: Optional, boolean whether to return detailed information
                        about audits.
 
-        :param marker: Optional, UUID of the last audit in the previous page.
-
         :returns: A list of audits.
 
         """
         if limit is not None:
             limit = int(limit)
 
-        filters = utils.common_filters(limit, sort_key, sort_dir, marker)
+        filters = utils.common_filters(limit, sort_key, sort_dir)
         if audit_template is not None:
             filters.append('audit_template=%s' % audit_template)
         if goal is not None:
@@ -95,14 +92,14 @@ class AuditManager(base.Manager):
                 raise exc.InvalidAttribute()
         return self._create(self._path(), new)
 
-    def get(self, audit):
+    def get(self, audit_id):
         try:
-            return self._list(self._path(audit))[0]
+            return self._list(self._path(audit_id))[0]
         except IndexError:
             return None
 
-    def delete(self, audit):
-        return self._delete(self._path(audit))
+    def delete(self, audit_id):
+        return self._delete(self._path(audit_id))
 
-    def update(self, audit, patch):
-        return self._update(self._path(audit), patch)
+    def update(self, audit_id, patch):
+        return self._update(self._path(audit_id), patch)

watcherclient/v1/audit_shell.py

@@ -31,7 +31,7 @@ class ShowAudit(command.ShowOne):
         parser.add_argument(
             'audit',
             metavar='<audit>',
-            help=_('UUID or name of the audit'),
+            help=_('UUID of the audit'),
         )
         return parser
 
@@ -88,13 +88,6 @@ class ListAudit(command.Lister):
             metavar='<direction>',
             choices=['asc', 'desc'],
             help=_('Sort direction: "asc" (the default) or "desc".'))
-        parser.add_argument(
-            '--marker',
-            dest='marker',
-            metavar='<marker>',
-            default=None,
-            help=_('UUID of the last audit in the previous page; '
-                   'displays list of audits after "marker".'))
 
         return parser
 
@@ -182,19 +175,13 @@ class CreateAudit(command.ShowOne):
             default=False,
             help=_('Trigger automatically action plan '
                    'once audit is succeeded.'))
-        parser.add_argument(
-            '--name',
-            dest='name',
-            metavar='<name>',
-            help=_('Name for this audit.'))
-
         return parser
 
     def take_action(self, parsed_args):
         client = getattr(self.app.client_manager, "infra-optim")
 
         field_list = ['audit_template_uuid', 'audit_type', 'parameters',
-                      'interval', 'goal', 'strategy', 'auto_trigger', 'name']
+                      'interval', 'goal', 'strategy', 'auto_trigger']
 
         fields = dict((k, v) for (k, v) in vars(parsed_args).items()
                       if k in field_list and v is not None)
@@ -232,7 +219,7 @@ class UpdateAudit(command.ShowOne):
         parser.add_argument(
             'audit',
             metavar='<audit>',
-            help=_("UUID or name of the audit."))
+            help=_("UUID of the audit."))
         parser.add_argument(
             'op',
             metavar='<op>',
@@ -252,6 +239,9 @@ class UpdateAudit(command.ShowOne):
     def take_action(self, parsed_args):
         client = getattr(self.app.client_manager, "infra-optim")
 
+        if not uuidutils.is_uuid_like(parsed_args.audit):
+            raise exceptions.ValidationError()
+
         patch = common_utils.args_array_to_patch(
             parsed_args.op, parsed_args.attributes[0],
             exclude_fields=['/interval'])
@@ -273,7 +263,7 @@ class DeleteAudit(command.Command):
             'audits',
             metavar='<audit>',
             nargs='+',
-            help=_('UUID or name of the audit'),
+            help=_('UUID of the audit'),
         )
         return parser
 
@@ -281,4 +271,7 @@ class DeleteAudit(command.Command):
         client = getattr(self.app.client_manager, "infra-optim")
 
         for audit in parsed_args.audits:
+            if not uuidutils.is_uuid_like(audit):
+                raise exceptions.ValidationError()
+
             client.audit.delete(audit)

watcherclient/v1/audit_template.py

@@ -33,7 +33,7 @@ class AuditTemplateManager(base.Manager):
         return '/v1/audit_templates/%s' % id_ if id_ else '/v1/audit_templates'
 
     def list(self, name=None, goal=None, strategy=None, limit=None,
-             sort_key=None, sort_dir=None, detail=False, marker=None):
+             sort_key=None, sort_dir=None, detail=False):
         """Retrieve a list of audit template.
 
         :param name: Name of the audit template
@@ -54,16 +54,13 @@ class AuditTemplateManager(base.Manager):
         :param detail: Optional, boolean whether to return detailed information
                        about audit_templates.
 
-        :param marker: Optional, UUID of the last audit template of
-                       the previous page.
-
         :returns: A list of audit templates.
 
         """
         if limit is not None:
             limit = int(limit)
 
-        filters = utils.common_filters(limit, sort_key, sort_dir, marker)
+        filters = utils.common_filters(limit, sort_key, sort_dir)
         if name is not None:
             filters.append('name=%s' % name)
         if goal is not None:

watcherclient/v1/audit_template_shell.py

@@ -91,13 +91,6 @@ class ListAuditTemplate(command.Lister):
             metavar='<direction>',
             choices=['asc', 'desc'],
             help=_('Sort direction: "asc" (the default) or "desc".'))
-        parser.add_argument(
-            '--marker',
-            dest='marker',
-            metavar='<marker>',
-            default=None,
-            help=_('UUID of the last audit template of the previous page; '
-                   'displays list of audit templates after "marker".'))
 
         return parser
 
@@ -169,81 +162,37 @@ class CreateAuditTemplate(command.ShowOne):
                    "Can be provided either in yaml or json file.\n"
                    "YAML example:\n"
                    "---\n"
-                   " - compute:\n"
-                   "   - host_aggregates:\n"
-                   "     - id: 1\n"
-                   "     - id: 2\n"
-                   "     - id: 3\n"
-                   "   - availability_zones:\n"
-                   "     - name: AZ1\n"
-                   "     - name: AZ2\n"
-                   "   - exclude:\n"
-                   "     - instances:\n"
-                   "       - uuid: UUID1\n"
-                   "       - uuid: UUID2\n"
-                   "     - compute_nodes:\n"
-                   "       - name: compute1\n"
-                   " - storage: \n"
-                   "   - availability_zones:\n"
-                   "     - name: AZ1\n"
-                   "     - name: AZ2\n"
-                   "   - volume_types:\n"
-                   "     - name: lvm1\n"
-                   "     - name: lvm2\n"
-                   "   - exclude:\n"
-                   "     - storage_pools:\n"
-                   "       - name: host0@backend0#pool0\n"
-                   "       - name: host1@backend1#pool1\n"
-                   "     - volumes:\n"
-                   "       - uuid: UUID1\n"
-                   "       - uuid: UUID2\n"
-                   "     - projects:\n"
-                   "       - uuid: UUID1\n"
-                   "       - uuid: UUID2\n"
+                   " - host_aggregates:\n"
+                   "   - id: 1\n"
+                   "   - id: 2\n"
+                   "   - id: 3\n"
+                   " - availability_zones:\n"
+                   "   - name: AZ1\n"
+                   "   - name: AZ2\n"
+                   " - exclude:\n"
+                   "   - instances:\n"
+                   "     - uuid: UUID1\n"
+                   "    - uuid: UUID2\n"
+                   "   - compute_nodes:\n"
+                   "     - name: compute1\n"
                    "\n"
                    "JSON example:\n"
-                   "[\n"
-                   " {\"compute\":\n"
-                   "      [{\"host_aggregates\": [\n"
-                   "            {\"id\": 1},\n"
-                   "            {\"id\": 2},\n"
-                   "            {\"id\": 3}]},\n"
-                   "       {\"availability_zones\": [\n"
-                   "            {\"name\": \"AZ1\"},\n"
-                   "            {\"name\": \"AZ2\"}]},\n"
-                   "       {\"exclude\": [\n"
-                   "            {\"instances\": [\n"
-                   "                 {\"uuid\": \"UUID1\"},\n"
-                   "                 {\"uuid\": \"UUID2\"}\n"
-                   "            ]},\n"
-                   "            {\"compute_nodes\": [\n"
-                   "                 {\"name\": \"compute1\"}\n"
-                   "            ]}\n"
-                   "       ]}]\n"
-                   "  },\n"
-                   " {\"storage\":\n"
-                   "      [{\"availability_zones\": [\n"
-                   "            {\"name\": \"AZ1\"},\n"
-                   "            {\"name\": \"AZ2\"}]},\n"
-                   "       {\"volume_types\": [\n"
-                   "            {\"name\": \"lvm1\"},\n"
-                   "            {\"name\": \"lvm2\"}]},\n"
-                   "       {\"exclude\": [\n"
-                   "            {\"storage_pools\": [\n"
-                   "                 {\"name\": \"host0@backend0#pool0\"},\n"
-                   "                 {\"name\": \"host1@backend1#pool1\"}\n"
-                   "            ]},\n"
-                   "            {\"volumes\": [\n"
-                   "                 {\"uuid\": \"UUID1\"},\n"
-                   "                 {\"uuid\": \"UUID2\"}\n"
-                   "            ]},\n"
-                   "            {\"projects\": [\n"
-                   "                 {\"uuid\": \"UUID1\"},\n"
-                   "                 {\"uuid\": \"UUID2\"}\n"
-                   "            ]},\n"
-                   "       ]}]\n"
-                   "  }\n"
-                   " ]\n"
+                   "[{'host_aggregates': [\n"
+                   "     {'id': 1},\n"
+                   "     {'id': 2},\n"
+                   "     {'id': 3}]},\n"
+                   " {'availability_zones': [\n"
+                   "     {'name': 'AZ1'},\n"
+                   "     {'name': 'AZ2'}]},\n"
+                   " {'exclude': [\n"
+                   "     {'instances': [\n"
+                   "         {'uuid': 'UUID1'},\n"
+                   "         {'uuid': 'UUID2'}\n"
+                   "     ]},\n"
+                   "     {'compute_nodes': [\n"
+                   "         {'name': 'compute1'}\n"
+                   "     ]}\n"
+                   "]}]\n"
                    )
         )
 

watcherclient/v1/resource_fields.py

@@ -30,20 +30,20 @@ AUDIT_TEMPLATE_SHORT_LIST_FIELDS = [
 AUDIT_TEMPLATE_SHORT_LIST_FIELD_LABELS = ['UUID', 'Name', 'Goal', 'Strategy']
 
 # Audit
-AUDIT_FIELDS = ['uuid', 'name', 'created_at', 'updated_at', 'deleted_at',
+AUDIT_FIELDS = ['uuid', 'created_at', 'updated_at', 'deleted_at',
                 'state', 'audit_type', 'parameters', 'interval', 'goal_name',
                 'strategy_name', 'scope', 'auto_trigger', 'next_run_time']
 
-AUDIT_FIELD_LABELS = ['UUID', 'Name', 'Created At', 'Updated At', 'Deleted At',
+AUDIT_FIELD_LABELS = ['UUID', 'Created At', 'Updated At', 'Deleted At',
                       'State', 'Audit Type', 'Parameters', 'Interval', 'Goal',
                       'Strategy', 'Audit Scope', 'Auto Trigger',
                       'Next Run Time']
 
-AUDIT_SHORT_LIST_FIELDS = ['uuid', 'name', 'audit_type',
+AUDIT_SHORT_LIST_FIELDS = ['uuid', 'audit_type',
                            'state', 'goal_name', 'strategy_name',
                            'auto_trigger']
 
-AUDIT_SHORT_LIST_FIELD_LABELS = ['UUID', 'Name', 'Audit Type', 'State', 'Goal',
+AUDIT_SHORT_LIST_FIELD_LABELS = ['UUID', 'Audit Type', 'State', 'Goal',
                                  'Strategy', 'Auto Trigger']
 
 # Action Plan
@@ -61,8 +61,6 @@ ACTION_PLAN_SHORT_LIST_FIELDS = ['uuid', 'audit_uuid', 'state',
 ACTION_PLAN_SHORT_LIST_FIELD_LABELS = ['UUID', 'Audit', 'State',
                                        'Updated At', 'Global efficacy']
 
-GLOBAL_EFFICACY_FIELDS = ['value', 'unit', 'name', 'description']
-
 # Action
 ACTION_FIELDS = ['uuid', 'created_at', 'updated_at', 'deleted_at', 'parents',
                  'state', 'action_plan_uuid', 'action_type',
@@ -99,10 +97,6 @@ STRATEGY_SHORT_LIST_FIELDS = ['uuid', 'name', 'display_name', 'goal_name']
 
 STRATEGY_SHORT_LIST_FIELD_LABELS = ['UUID', 'Name', 'Display name', 'Goal']
 
-STRATEGY_STATE_FIELDS = ['type', 'state', 'mandatory', 'comment']
-
-STRATEGY_STATE_FIELD_LABELS = ['Type', 'State', 'Mandatory', 'Comment']
-
 # Metric Collector
 METRIC_COLLECTOR_FIELDS = ['uuid', 'created_at', 'updated_at', 'deleted_at',
                            'endpoint', 'category']

watcherclient/v1/strategy.py

@@ -28,14 +28,9 @@ class StrategyManager(base.Manager):
     resource_class = Strategy
 
     @staticmethod
-    def _path(strategy=None, state=False):
-        if strategy:
-            path = '/v1/strategies/%s' % strategy
-            if state:
-                path = '/v1/strategies/%s/state' % strategy
-        else:
-            path = '/v1/strategies'
-        return path
+    def _path(strategy=None):
+        return ('/v1/strategies/%s' % strategy
+                if strategy else '/v1/strategies')
 
     def list(self, goal=None, limit=None, sort_key=None,
              sort_dir=None, detail=False):
@@ -87,6 +82,3 @@ class StrategyManager(base.Manager):
             return self._list(self._path(strategy))[0]
         except IndexError:
             return None
-
-    def state(self, strategy):
-        return self._list(self._path(strategy, state=True))

watcherclient/v1/strategy_shell.py

@@ -57,40 +57,6 @@ class ShowStrategy(command.ShowOne):
         return column_headers, utils.get_item_properties(strategy, columns)
 
 
-class StateStrategy(command.Lister):
-    """Retrieve information about strategy requirements."""
-
-    def get_parser(self, prog_name):
-        parser = super(StateStrategy, self).get_parser(prog_name)
-        parser.add_argument(
-            'strategy',
-            metavar='<strategy>',
-            help=_('Name of the strategy'),
-        )
-        return parser
-
-    def _format_spec(self, requirements):
-        for req in requirements:
-            if type(req.state) == list:
-                req.state = jsonutils.dumps(req.state, indent=2)
-        return requirements
-
-    def take_action(self, parsed_args):
-        client = getattr(self.app.client_manager, "infra-optim")
-
-        try:
-            requirements = client.strategy.state(parsed_args.strategy)
-        except exceptions.HTTPNotFound as exc:
-            raise exceptions.CommandError(str(exc))
-        requirements = self._format_spec(requirements)
-        columns = res_fields.STRATEGY_STATE_FIELDS
-        column_headers = res_fields.STRATEGY_STATE_FIELD_LABELS
-
-        return (column_headers,
-                (utils.get_item_properties(item, columns)
-                    for item in requirements))
-
-
 class ListStrategy(command.Lister):
     """List information on retrieved strategies."""