yapf

Author: asonnenschein

planet/cli/destinations.py

@@ -36,7 +36,12 @@ async def _patch_destination(ctx, destination_id, data, pretty):
             raise ClickException(f"Failed to patch destination: {e}")
 
 
-async def _list_destinations(ctx, archived, is_owner, can_write, is_default, pretty):
+async def _list_destinations(ctx,
+                             archived,
+                             is_owner,
+                             can_write,
+                             is_default,
+                             pretty):
     async with destinations_client(ctx) as cl:
         try:
             response = await cl.list_destinations(archived,
@@ -110,13 +115,17 @@ async def _get_default_destination(ctx, pretty):
     default=None,
     help="""Set to true to include only destinations the user can modify,
     false to exclude them.""")
-@click.option(
-    '--is-default',
-    type=bool,
-    default=None,
-    help="""Set to true to include only the default destination,
+@click.option('--is-default',
+              type=bool,
+              default=None,
+              help="""Set to true to include only the default destination,
     false to exclude it.""")
-async def list_destinations(ctx, archived, is_owner, can_write, is_default, pretty):
+async def list_destinations(ctx,
+                            archived,
+                            is_owner,
+                            can_write,
+                            is_default,
+                            pretty):
     """
     List destinations with optional filters
 
@@ -127,7 +136,12 @@ async def list_destinations(ctx, archived, is_owner, can_write, is_default, pret
 
         planet destinations list --archived false --is-owner true --can-write true
     """
-    await _list_destinations(ctx, archived, is_owner, can_write, is_default, pretty)
+    await _list_destinations(ctx,
+                             archived,
+                             is_owner,
+                             can_write,
+                             is_default,
+                             pretty)
 
 
 @command(destinations, name="get")
@@ -677,4 +691,4 @@ async def get_default_destination(ctx, pretty):
 
         planet destinations default get
     """
-    await _get_default_destination(ctx, pretty)
+    await _get_default_destination(ctx, pretty)

planet/clients/destinations.py

@@ -198,13 +198,11 @@ async def set_default_destination(self, destination_id: str) -> None:
             ClientError: If there is an issue with the client request.
         """
         url = f'{self._base_url}/default'
-        request = {
-            "destination_id": destination_id
-        }
+        request = {"destination_id": destination_id}
         try:
             response = await self._session.request(method='PUT',
-                                        url=url,
-                                        json=request)
+                                                   url=url,
+                                                   json=request)
         except APIError:
             raise
         except ClientError:  # pragma: no cover
@@ -253,4 +251,4 @@ async def get_default_destination(self) -> Dict:
             raise
         else:
             dest = response.json()
-            return dest
+            return dest

planet/order_request.py

@@ -392,7 +392,8 @@ def s3_compatible(endpoint: str,
     return {'s3_compatible': parameters}
 
 
-def destination(destination_ref: str, path_prefix: Optional[str] = None) -> dict:
+def destination(destination_ref: str,
+                path_prefix: Optional[str] = None) -> dict:
     """Destinations API configuration.
     Parameters:
         destination_ref: Reference to an existing Destinations API

planet/subscription_request.py

@@ -529,7 +529,8 @@ def s3_compatible(endpoint: str,
     return _delivery('s3_compatible', parameters)
 
 
-def destination(destination_ref: str, path_prefix: Optional[str] = None) -> dict:
+def destination(destination_ref: str,
+                path_prefix: Optional[str] = None) -> dict:
     """Specify a Destinations API destination by its ref.
 
     Parameters:

planet/sync/destinations.py

@@ -53,7 +53,10 @@ def list_destinations(self,
             ClientError: If there is an issue with the client request.
         """
         return self._client._call_sync(
-            self._client.list_destinations(archived, is_owner, can_write, is_default))
+            self._client.list_destinations(archived,
+                                           is_owner,
+                                           can_write,
+                                           is_default))
 
     def get_destination(self, destination_id: str) -> Dict:
         """
@@ -154,5 +157,4 @@ def get_default_destination(self) -> Dict:
             APIError: If the API returns an error response.
             ClientError: If there is an issue with the client request.
         """
-        return self._client._call_sync(
-            self._client.get_default_destination())
+        return self._client._call_sync(self._client.get_default_destination())

tests/integration/test_destinations_api.py

@@ -198,11 +198,12 @@ def assertf(resp):
 async def test_set_default_destination_bad_request():
     id = "invalid_dest_id"
     url = f"{TEST_URL}/default"
-    mock_response(url, {
-        "code": 400, "message": "Bad Request: Invalid destination ID"
-    },
-                  method="put",
-                  status_code=HTTPStatus.BAD_REQUEST)
+    mock_response(
+        url, {
+            "code": 400, "message": "Bad Request: Invalid destination ID"
+        },
+        method="put",
+        status_code=HTTPStatus.BAD_REQUEST)
 
     with pytest.raises(Exception):
         await cl_async.set_default_destination(id)
@@ -239,7 +240,10 @@ async def test_get_default_destination_not_found():
 @respx.mock
 async def test_unset_default_destination():
     url = f"{TEST_URL}/default"
-    mock_response(url, None, method="delete", status_code=HTTPStatus.NO_CONTENT)
+    mock_response(url,
+                  None,
+                  method="delete",
+                  status_code=HTTPStatus.NO_CONTENT)
 
     # unset_default_destination returns None
     assert await cl_async.unset_default_destination() is None
@@ -249,11 +253,12 @@ async def test_unset_default_destination():
 @respx.mock
 async def test_unset_default_destination_unauthorized():
     url = f"{TEST_URL}/default"
-    mock_response(url, {
-        "code": 401, "message": "Unauthorized: Insufficient permissions"
-    },
-                  method="delete",
-                  status_code=HTTPStatus.UNAUTHORIZED)
+    mock_response(
+        url, {
+            "code": 401, "message": "Unauthorized: Insufficient permissions"
+        },
+        method="delete",
+        status_code=HTTPStatus.UNAUTHORIZED)
 
     with pytest.raises(Exception):
         await cl_async.unset_default_destination()

tests/integration/test_destinations_cli.py

@@ -273,7 +273,9 @@ def test_destinations_cli_default_set_bad_request(invoke):
     url = f"{TEST_DESTINATIONS_URL}/default"
     respx.put(url).return_value = httpx.Response(
         HTTPStatus.BAD_REQUEST,
-        json={"code": 400, "message": "Bad Request: Invalid destination ID"})
+        json={
+            "code": 400, "message": "Bad Request: Invalid destination ID"
+        })
 
     result = invoke(['default', 'set', 'invalid-dest-id'])
     assert result.exit_code != 0
@@ -294,7 +296,9 @@ def test_destinations_cli_default_get_not_found(invoke):
     url = f"{TEST_DESTINATIONS_URL}/default"
     respx.get(url).return_value = httpx.Response(
         HTTPStatus.NOT_FOUND,
-        json={"code": 404, "message": "No default destination configured"})
+        json={
+            "code": 404, "message": "No default destination configured"
+        })
 
     result = invoke(['default', 'get'])
     assert result.exit_code != 0
@@ -315,7 +319,9 @@ def test_destinations_cli_default_unset_unauthorized(invoke):
     url = f"{TEST_DESTINATIONS_URL}/default"
     respx.delete(url).return_value = httpx.Response(
         HTTPStatus.UNAUTHORIZED,
-        json={"code": 401, "message": "Unauthorized: Insufficient permissions"})
+        json={
+            "code": 401, "message": "Unauthorized: Insufficient permissions"
+        })
 
     result = invoke(['default', 'unset'])
     assert result.exit_code != 0

tests/unit/test_order_request.py

@@ -474,11 +474,7 @@ def test_fallback_bundle_invalid(bundle, fallback_bundle):
 def test_destination():
     dest_config = order_request.destination('my-dest-ref')
 
-    expected = {
-        'destination': {
-            'ref': 'my-dest-ref'
-        }
-    }
+    expected = {'destination': {'ref': 'my-dest-ref'}}
     assert dest_config == expected
 
 
@@ -488,8 +484,7 @@ def test_destination_path_prefix():
 
     expected = {
         'destination': {
-            'ref': 'my-dest-ref',
-            'path_prefix': 'my/prefix'
+            'ref': 'my-dest-ref', 'path_prefix': 'my/prefix'
         }
     }
     assert dest_config == expected
@@ -498,11 +493,7 @@ def test_destination_path_prefix():
 def test_default_destination():
     dest_config = order_request.default_destination()
 
-    expected = {
-        'destination': {
-            'ref': 'pl:destinations/default'
-        }
-    }
+    expected = {'destination': {'ref': 'pl:destinations/default'}}
     assert dest_config == expected
 
 
@@ -511,8 +502,7 @@ def test_default_destination_path_prefix():
 
     expected = {
         'destination': {
-            'ref': 'pl:destinations/default',
-            'path_prefix': 'my/prefix'
+            'ref': 'pl:destinations/default', 'path_prefix': 'my/prefix'
         }
     }
     assert dest_config == expected

tests/unit/test_subscription_request.py

@@ -639,23 +639,17 @@ def test_cloud_filter_tool_success():
 def test_destination_success():
     res = subscription_request.destination(destination_ref='my-dest-ref')
 
-    assert res == {
-        "type": "destination",
-        "parameters": {
-            "ref": "my-dest-ref"
-        }
-    }
+    assert res == {"type": "destination", "parameters": {"ref": "my-dest-ref"}}
 
 
 def test_destination_path_prefix_success():
     res = subscription_request.destination(destination_ref='my-dest-ref',
-                                          path_prefix='my/prefix')
+                                           path_prefix='my/prefix')
 
     assert res == {
         "type": "destination",
         "parameters": {
-            "ref": "my-dest-ref",
-            "path_prefix": "my/prefix"
+            "ref": "my-dest-ref", "path_prefix": "my/prefix"
         }
     }
 
@@ -677,7 +671,6 @@ def test_default_destination_path_prefix_success():
     assert res == {
         "type": "destination",
         "parameters": {
-            "ref": "pl:destinations/default",
-            "path_prefix": "my/prefix"
+            "ref": "pl:destinations/default", "path_prefix": "my/prefix"
         }
     }