Fix style using new black version

Author: micafer

libcloud/common/abiquo.py

@@ -17,6 +17,7 @@
 
 Common utilities needed by the :class:`AbiquoNodeDriver`.
 """
+
 import base64
 
 from libcloud.utils.py3 import b, httplib, urlparse

libcloud/common/base.py

@@ -327,7 +327,7 @@ class Connection:
     port = 443
     timeout = None  # type: Optional[Union[int, float]]
     secure = 1
-    driver = None  # type:  Type[BaseDriver]
+    driver = None  # type: Type[BaseDriver]
     action = None
     cache_busting = False
     backoff = None
@@ -410,7 +410,7 @@ def reset_context(self):
     def _tuple_from_url(self, url):
         secure = 1
         port = None
-        (scheme, netloc, request_path, param, query, fragment) = urlparse.urlparse(url)
+        scheme, netloc, request_path, param, query, fragment = urlparse.urlparse(url)
 
         if scheme not in ["http", "https"]:
             raise LibcloudError("Invalid scheme: {} in url {}".format(scheme, url))
@@ -450,9 +450,9 @@ def connect(self, host=None, port=None, base_url=None, **kwargs):
         secure = self.secure
 
         if getattr(self, "base_url", None) and base_url is None:
-            (host, port, secure, request_path) = self._tuple_from_url(getattr(self, "base_url"))
+            host, port, secure, request_path = self._tuple_from_url(getattr(self, "base_url"))
         elif base_url is not None:
-            (host, port, secure, request_path) = self._tuple_from_url(base_url)
+            host, port, secure, request_path = self._tuple_from_url(base_url)
         else:
             host = host or self.host
             port = port or self.port

libcloud/common/dimensiondata.py

@@ -15,6 +15,7 @@
 """
 Dimension Data Common Components
 """
+
 from time import sleep
 from base64 import b64encode
 

libcloud/common/google.py

@@ -65,7 +65,6 @@
 Please remember to secure your keys and access tokens.
 """
 
-
 import os
 import sys
 import time
@@ -262,7 +261,7 @@ def parse_body(self):
             if json_error:
                 raise JsonParseError(body, self.status, None)
             elif "error" in body:
-                (code, message) = self._get_error(body)
+                code, message = self._get_error(body)
                 if code == "QUOTA_EXCEEDED":
                     raise QuotaExceededError(message, self.status, code)
                 elif code == "RESOURCE_ALREADY_EXISTS":
@@ -278,23 +277,23 @@ def parse_body(self):
 
         elif self.status == httplib.NOT_FOUND:
             if (not json_error) and ("error" in body):
-                (code, message) = self._get_error(body)
+                code, message = self._get_error(body)
             else:
                 message = body
                 code = None
             raise ResourceNotFoundError(message, self.status, code)
 
         elif self.status == httplib.BAD_REQUEST:
             if (not json_error) and ("error" in body):
-                (code, message) = self._get_error(body)
+                code, message = self._get_error(body)
             else:
                 message = body
                 code = None
             raise InvalidRequestError(message, self.status, code)
 
         else:
             if (not json_error) and ("error" in body):
-                (code, message) = self._get_error(body)
+                code, message = self._get_error(body)
             else:
                 message = body
                 code = None

libcloud/common/openstack.py

@@ -358,7 +358,7 @@ def morph_action_hook(self, action):
     def _set_up_connection_info(self, url):
         prev_conn = (self.host, self.port, self.secure)
         result = self._tuple_from_url(url)
-        (self.host, self.port, self.secure, self.request_path) = result
+        self.host, self.port, self.secure, self.request_path = result
         new_conn = (self.host, self.port, self.secure)
         if new_conn != prev_conn:
             # We only call connect in case connection details have changed - this way we correctly

libcloud/common/openstack_identity.py

@@ -758,7 +758,7 @@ def authenticated_request(
         return response
 
     def morph_action_hook(self, action):
-        (_, _, _, request_path) = self._tuple_from_url(self.auth_url)
+        _, _, _, request_path = self._tuple_from_url(self.auth_url)
 
         if request_path == "":
             # No path is provided in the auth_url, use action passed to this

libcloud/compute/base.py

@@ -17,7 +17,6 @@
 Provides base classes for working with drivers
 """
 
-
 import os
 import re
 import time

libcloud/compute/deployment.py

@@ -17,7 +17,6 @@
 Provides generic deployment steps for machines post boot.
 """
 
-
 import os
 import re
 import binascii

libcloud/compute/drivers/azure_arm.py

@@ -439,10 +439,10 @@ def get_image(self, image_id, location=None):
         """
 
         if image_id.startswith("http"):
-            (storageAccount, blobContainer, blob) = _split_blob_uri(image_id)
+            storageAccount, blobContainer, blob = _split_blob_uri(image_id)
             return AzureVhdImage(storageAccount, blobContainer, blob, self)
         else:
-            (ex_publisher, ex_offer, ex_sku, ex_version) = image_id.split(":")
+            ex_publisher, ex_offer, ex_sku, ex_version = image_id.split(":")
             i = self.list_images(location, ex_publisher, ex_offer, ex_sku, ex_version)
             return i[0] if i else None
 
@@ -2315,7 +2315,7 @@ def ex_run_command(
 
     def _ex_delete_old_vhd(self, resource_group, uri):
         try:
-            (storageAccount, blobContainer, blob) = _split_blob_uri(uri)
+            storageAccount, blobContainer, blob = _split_blob_uri(uri)
             keys = self.ex_get_storage_account_keys(resource_group, storageAccount)
             blobdriver = AzureBlobsStorageDriver(
                 storageAccount,

libcloud/compute/drivers/digitalocean.py

@@ -15,6 +15,7 @@
 """
 DigitalOcean Driver
 """
+
 import json
 import warnings