Ran yapf formatter

Author: Tim-Kerr

labelbox/client.py

@@ -55,7 +55,7 @@ def __init__(self,
                  api_key=None,
                  endpoint='https://api.labelbox.com/graphql',
                  enable_experimental=False,
-                 app_url="https://app.labelbox.com", 
+                 app_url="https://app.labelbox.com",
                  rest_endpoint="https://api.labelbox.com/api/v1"):
         """ Creates and initializes a Labelbox Client.
 
@@ -156,7 +156,8 @@ def convert_value(value):
         if query is not None:
             if params is not None:
                 params = {
-                    key: convert_value(value) for key, value in params.items()
+                    key: convert_value(value)
+                    for key, value in params.items()
                 }
             data = json.dumps({
                 'query': query,
@@ -357,18 +358,18 @@ def upload_data(self,
 
         request_data = {
             "operations":
-                json.dumps({
-                    "variables": {
-                        "file": None,
-                        "contentLength": len(content),
-                        "sign": sign
-                    },
-                    "query":
-                        """mutation UploadFile($file: Upload!, $contentLength: Int!,
+            json.dumps({
+                "variables": {
+                    "file": None,
+                    "contentLength": len(content),
+                    "sign": sign
+                },
+                "query":
+                """mutation UploadFile($file: Upload!, $contentLength: Int!,
                                             $sign: Boolean) {
                             uploadFile(file: $file, contentLength: $contentLength,
                                        sign: $sign) {url filename} } """,
-                }),
+            }),
             "map": (None, json.dumps({"1": ["variables.file"]})),
         }
         response = requests.post(
@@ -377,7 +378,7 @@ def upload_data(self,
             data=request_data,
             files={
                 "1": (filename, content, content_type) if
-                     (filename and content_type) else content
+                (filename and content_type) else content
             })
 
         if response.status_code == 502:
@@ -665,7 +666,8 @@ def create_project(self, **kwargs) -> Project:
         elif queue_mode == QueueMode.Dataset:
             logger.warning(
                 "QueueMode.Dataset will eventually be deprecated, and is no longer "
-                "recommended for new projects. Prefer QueueMode.Batch instead.")
+                "recommended for new projects. Prefer QueueMode.Batch instead."
+            )
 
         return self._create(Entity.Project, {
             **kwargs,
@@ -777,7 +779,7 @@ def get_data_row_ids_for_external_ids(
             for row in self.execute(
                     query_str,
                 {'externalId_in': external_ids[i:i + max_ids_per_request]
-                })['externalIdsToDataRowIds']:
+                 })['externalIdsToDataRowIds']:
                 result[row['externalId']].append(row['dataRowId'])
         return result
 
@@ -1069,9 +1071,10 @@ def _format_failed_rows(rows: Dict[str, str],
         }
         """
         params = {
-            'globalKeyDataRowLinks': [{
-                utils.camel_case(key): value for key, value in input.items()
-            } for input in global_key_to_data_row_inputs]
+            'globalKeyDataRowLinks':
+            [{utils.camel_case(key): value
+              for key, value in input.items()}
+             for input in global_key_to_data_row_inputs]
         }
         assign_global_keys_to_data_rows_job = self.execute(query_str, params)
 
@@ -1100,8 +1103,8 @@ def _format_failed_rows(rows: Dict[str, str],
         """
         result_params = {
             "jobId":
-                assign_global_keys_to_data_rows_job["assignGlobalKeysToDataRows"
-                                                   ]["jobId"]
+            assign_global_keys_to_data_rows_job["assignGlobalKeysToDataRows"]
+            ["jobId"]
         }
 
         # Poll job status until finished, then retrieve results
@@ -1217,7 +1220,7 @@ def _format_failed_rows(rows: List[str],
             """
         result_params = {
             "jobId":
-                data_rows_for_global_keys_job["dataRowsForGlobalKeys"]["jobId"]
+            data_rows_for_global_keys_job["dataRowsForGlobalKeys"]["jobId"]
         }
 
         # Poll job status until finished, then retrieve results
@@ -1339,7 +1342,8 @@ def _format_failed_rows(rows: List[str],
                 errors.extend(
                     _format_failed_rows(
                         data['notFoundGlobalKeys'],
-                        "Failed to find data row matching provided global key"))
+                        "Failed to find data row matching provided global key")
+                )
                 errors.extend(
                     _format_failed_rows(
                         data['accessDeniedGlobalKeys'],
@@ -1391,8 +1395,9 @@ def get_catalog_slice(self, slice_id) -> CatalogSlice:
         """
         res = self.execute(query_str, {'id': slice_id})
         return Entity.CatalogSlice(self, res['getSavedQuery'])
-    
-    def unarchive_root_feature_schema_node(self, ontology_id: str, root_feature_schema_id: str) -> bool:
+
+    def unarchive_root_feature_schema_node(
+            self, ontology_id: str, root_feature_schema_id: str) -> bool:
         """
         Returns true if the root feature schema node was successfully unarchived, false otherwise
         Args: