format

Committed-by: xiaolei.zl from Dev container

coordinator/graphscope_runtime/__init__.py

@@ -16,5 +16,4 @@
 # limitations under the License.
 #
 
-"""Dummy package dir for gs-engine package
-"""
+"""Dummy package dir for gs-engine package"""

coordinator/gscoordinator/__init__.py

@@ -29,4 +29,6 @@
     except ModuleNotFoundError:
         # if graphscope is not installed, try to locate it by relative path,
         # which is strong related with the directory structure of GraphScope
-        sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", "..", "python"))
+        sys.path.insert(
+            0, os.path.join(os.path.dirname(__file__), "..", "..", "python")
+        )

coordinator/gscoordinator/coordinator.py

@@ -28,17 +28,16 @@
 from concurrent import futures
 
 import connexion
-
-from gscoordinator.flex.core.config import SOLUTION
 import grpc
 from graphscope.proto import coordinator_service_pb2_grpc
 
+from gscoordinator.flex.core.config import SOLUTION
+
 if SOLUTION != "INTERACTIVE":
     from graphscope.proto import coordinator_service_pb2_grpc
     from gscoordinator.monitor import Monitor
     from gscoordinator.servicer import init_graphscope_one_service_servicer
     from gscoordinator.utils import GS_GRPC_MAX_MESSAGE_LENGTH
-
 
 from flask_cors import CORS
 from graphscope.config import Config
@@ -99,8 +98,7 @@ def launch_graphscope():
 
     config_logging(config.log_level)
     logger.info("Start server with args \n%s", config.dumps_yaml())
-
-
+
     if config.coordinator.http_server_only:
         start_http_service(config)
     else:

coordinator/gscoordinator/flex/core/deployment.py

@@ -32,10 +32,12 @@
 from gscoordinator.flex.core.config import INSTANCE_NAME
 from gscoordinator.flex.core.config import MAXSIZE
 from gscoordinator.flex.core.config import NAMESPACE
-from gscoordinator.flex.core.config import STORAGE_TYPE
 from gscoordinator.flex.core.config import SOLUTION
+from gscoordinator.flex.core.config import STORAGE_TYPE
+
 if SOLUTION == "GRAPHSCOPE_INSIGHT":
     from gscoordinator.flex.core.scheduler import schedule
+
 from gscoordinator.flex.core.stoppable_thread import StoppableThread
 from gscoordinator.flex.core.utils import encode_datetime
 from gscoordinator.flex.core.utils import resolve_api_client

coordinator/gscoordinator/flex/core/utils.py

@@ -28,7 +28,9 @@
 from typing import Union
 
 import requests
+
 from gscoordinator.flex.core.config import CLUSTER_TYPE
+
 if CLUSTER_TYPE == "KUBERNETES":
     from kubernetes import client as kube_client
     from kubernetes import config as kube_config

coordinator/gscoordinator/hook/prestop/__main__.py

@@ -16,8 +16,7 @@
 # limitations under the License.
 #
 
-"""Prestop hook for delete all resource created by coordinator in kubernetes
-"""
+"""Prestop hook for delete all resource created by coordinator in kubernetes"""
 
 import json
 import os

python/graphscope/analytical/udf/compile.py

@@ -16,7 +16,7 @@
 # limitations under the License.
 #
 
-""" An almost-complete Python to Cython AST transformer, with injected
+"""An almost-complete Python to Cython AST transformer, with injected
     GRAPHSCOPE-specific translation.
 
 Python AST nodes are translated to corresponding Cython AST nodes as

python/graphscope/analytical/udf/patch.py

@@ -16,8 +16,7 @@
 # limitations under the License.
 #
 
-""" Patch for Cython writer
-"""
+"""Patch for Cython writer"""
 
 import functools
 

python/graphscope/client/connection.py

@@ -16,8 +16,7 @@
 # limitations under the License.
 #
 
-""" Manage connections of the GraphScope store service.
-"""
+"""Manage connections of the GraphScope store service."""
 
 import base64
 import json

python/graphscope/client/session.py

@@ -16,8 +16,7 @@
 # limitations under the License.
 #
 
-""" Manage sessions to the GraphScope coordinator.
-"""
+"""Manage sessions to the GraphScope coordinator."""
 
 import atexit
 import base64

python/graphscope/config.py

@@ -16,8 +16,7 @@
 # limitations under the License.
 #
 
-""" GraphScope default configuration.
-"""
+"""GraphScope default configuration."""
 
 import base64
 import json

python/graphscope/framework/dag.py

@@ -16,8 +16,7 @@
 # limitations under the License.
 #
 
-""" Classes and functions used to manage dags.
-"""
+"""Classes and functions used to manage dags."""
 
 
 import queue

python/graphscope/framework/operation.py

@@ -16,8 +16,7 @@
 # limitations under the License.
 #
 
-""" Classes and functions used to construct dags.
-"""
+"""Classes and functions used to construct dags."""
 
 import hashlib
 import uuid

python/graphscope/nx/algorithms/tests/builtin/test_attribute_assortativity.py

@@ -15,7 +15,7 @@
 # information.
 #
 """
-    Unit tests for attribute assortativity coefficient.
+Unit tests for attribute assortativity coefficient.
 """
 import pytest
 

python/graphscope/nx/algorithms/tests/builtin/test_degree_assortativity.py

@@ -15,7 +15,7 @@
 # information.
 #
 """
-    Unit tests for degree assortativity coefficient.
+Unit tests for degree assortativity coefficient.
 """
 import pytest
 

python/graphscope/nx/algorithms/tests/builtin/test_degree_centrality.py

@@ -15,7 +15,7 @@
 # information.
 #
 """
-    Unit tests for degree centrality.
+Unit tests for degree centrality.
 """
 import pytest
 

python/graphscope/nx/algorithms/tests/builtin/test_degree_connectivity.py

@@ -15,7 +15,7 @@
 # information.
 #
 """
-    Unit tests for average degree connectivity.
+Unit tests for average degree connectivity.
 """
 from itertools import permutations
 

python/graphscope/nx/readwrite/tests/test_edgelist.py

@@ -62,6 +62,6 @@ def test_write_edgelist_4(self):
         G = nx.Graph()
         G.add_edge(1, 2, weight=2.0)
         G.add_edge(2, 3, weight=3.0)
-        nx.write_edgelist(G, fh, data=[("weight")])
+        nx.write_edgelist(G, fh, data=["weight"])
         fh.seek(0)
         assert fh.read() in (b"1 2 2.0\n2 3 3.0\n", b"2 3 3.0\n2 1 2.0\n")

python/setup_flex.py

@@ -17,15 +17,15 @@
 #
 
 """
-    GraphScope FLEX HTTP SERVICE API
+GraphScope FLEX HTTP SERVICE API
 
-    This is a specification for GraphScope FLEX HTTP service based on the OpenAPI 3.0 specification. You can find out more details about specification at [doc](https://swagger.io/specification/v3/).  Some useful links: - [GraphScope Repository](https://github.com/alibaba/GraphScope) - [The Source API definition for GraphScope Interactive](https://github.com/GraphScope/portal/tree/main/httpservice)
+This is a specification for GraphScope FLEX HTTP service based on the OpenAPI 3.0 specification. You can find out more details about specification at [doc](https://swagger.io/specification/v3/).  Some useful links: - [GraphScope Repository](https://github.com/alibaba/GraphScope) - [The Source API definition for GraphScope Interactive](https://github.com/GraphScope/portal/tree/main/httpservice)
 
-    The version of the OpenAPI document: 0.9.1
-    Contact: [email protected]
-    Generated by OpenAPI Generator (https://openapi-generator.tech)
+The version of the OpenAPI document: 0.9.1
+Contact: [email protected]
+Generated by OpenAPI Generator (https://openapi-generator.tech)
 
-    Do not edit the class manually.
+Do not edit the class manually.
 """  # noqa: E501
 
 import os