flake

Author: tehasdf

cloudify_cli/async_commands/audit_log.py

@@ -1,7 +1,6 @@
 import asyncio
 import json
 
-from cloudify_cli.exceptions import CloudifyCliError
 from cloudify_cli.logger import get_global_json_output
 
 

cloudify_cli/commands/audit_log.py

@@ -91,26 +91,30 @@ def list_logs(
     else:
         import asyncio
         loop = asyncio.get_event_loop()
-        loop.run_until_complete(_list_logs(creator_name,
-                   execution_id,
-                   since,
-                   sort_by,
-                   descending,
-                   pagination_offset,
-                   pagination_size,
-                   logger,
-                   client))
+        loop.run_until_complete(_list_logs(
+            creator_name,
+            execution_id,
+            since,
+            sort_by,
+            descending,
+            pagination_offset,
+            pagination_size,
+            logger,
+            client,
+        ))
 
 
-async def _list_logs(creator_name,
-               execution_id,
-               since,
-               sort_by,
-               descending,
-               pagination_offset,
-               pagination_size,
-               logger,
-               client):
+async def _list_logs(
+    creator_name,
+    execution_id,
+    since,
+    sort_by,
+    descending,
+    pagination_offset,
+    pagination_size,
+    logger,
+    client,
+):
     """List audit_log entries"""
     logger.info('Listing audit log entries...')
     logs = await client.auditlog.list(

cloudify_cli/env.py

@@ -1,20 +1,15 @@
 import os
 import json
 import errno
-import types
 import shutil
 import getpass
 import tempfile
-import itertools
 from base64 import b64encode
 
 import yaml
-import requests
 
 from cloudify_rest_client.client import CloudifyClient, HTTPClient
 from cloudify.cluster_status import CloudifyNodeType
-from cloudify_rest_client.exceptions import CloudifyClientError
-from cloudify.utils import ipv6_url_compat
 
 from cloudify_cli import constants
 from cloudify_cli.exceptions import CloudifyCliError
@@ -559,7 +554,6 @@ def get_auth_header(username, password):
     return header
 
 
-
 # attributes that can differ for each node in a cluster. Those will be updated
 # in the profile when we switch to a new master.
 # Dicts with these keys live in profile.cluster, and are added there during

cloudify_cli/tests/commands/test_agents.py

@@ -123,7 +123,8 @@ def list_deployments(client_inst, **kwargs):
                 CLOUDIFY_TENANT_HEADER)
             if not tenant_name:
                 tenant_name = DEFAULT_TENANT_NAME
-            all_node_instances = _topology_filter(client_inst, lambda x: True, **kwargs)
+            all_node_instances = _topology_filter(
+                client_inst, lambda x: True, **kwargs)
             deployments = {(x['tenant_name'], x['deployment_id'])
                            for x in all_node_instances}
             deployments = [Deployment({'id': b, 'tenant_name': a}) for a, b in
@@ -137,7 +138,8 @@ def list_deployments(client_inst, **kwargs):
 
         def list_nodes(client_inst, **kwargs):
             node_ids = kwargs.get('id')
-            all_node_instances = _topology_filter(client_inst, lambda x: True, **kwargs)
+            all_node_instances = _topology_filter(
+                client_inst, lambda x: True, **kwargs)
             nodes = {(x['tenant_name'], x['deployment_id'], x['node_id'])
                      for x in all_node_instances}
             nodes = [Node({'id': c, 'deployment_id': b, 'tenant_name': a}) for
@@ -409,8 +411,9 @@ def _wait_side_effect(*args, **kwargs):
         with patch('cloudify_cli.commands.agents.wait_for_execution',
                    return_value=PropertyMock(error=False),
                    side_effect=_wait_side_effect), \
-            patch.object(ExecutionsClient, 'start', _mock_execution_start), \
-            patch('cloudify_cli.commands.agents.time.sleep'):
+                patch.object(
+                    ExecutionsClient, 'start', _mock_execution_start), \
+                patch('cloudify_cli.commands.agents.time.sleep'):
 
             get_deployments_and_run_workers(
                 self.client, self._agent_filters(), True, self.logger,

cloudify_cli/tests/commands/test_base.py

@@ -23,7 +23,6 @@
 from mock import patch, Mock, PropertyMock
 
 from cloudify.utils import setup_logger
-from cloudify_rest_client import CloudifyClient
 from cloudify_rest_client.client import CLOUDIFY_TENANT_HEADER
 import click.testing as clicktest
 

cloudify_cli/tests/commands/test_use.py

@@ -132,7 +132,6 @@ def mock_do_request(client_self, method, uri, **kwargs):
             self.verify = client_self.get_request_verify()
             return 'success'
 
-
         with patch('cloudify_rest_client.client.HTTPClient.do_request',
                    new=mock_do_request):
             if self.client._client.port == SSL_PORT: