Coordinator pod start successful but can't connecting to service ...

[yuenyu1]

when I create session, I miss the error

sess = gs.session()

2022-06-11 11:16:02,303 [INFO][cluster:303]: Launching coordinator...
2022-06-11 11:16:05,349 [INFO][utils:182]: coordinator-qrgbuf-849984d654-rndlr: Successfully assigned gs-eonbnu/coordinator -qrgbuf-849984d654-rndlr to ubuntu8
2022-06-11 11:16:05,350 [INFO][utils:182]: coordinator-qrgbuf-849984d654-rndlr: Container image "registry.cn-hongkong.aliyu ncs.com/graphscope/graphscope:0.13.0" already present on machine
2022-06-11 11:16:05,350 [INFO][utils:182]: coordinator-qrgbuf-849984d654-rndlr: Created container coordinator
2022-06-11 11:16:05,350 [INFO][utils:182]: coordinator-qrgbuf-849984d654-rndlr: Started container coordinator
2022-06-11 11:17:04,267 [INFO][cluster:695]: Launching etcd ...
2022-06-11 11:17:05,308 [INFO][cluster:906]: Etcd created, endpoint is 10.104.223.35:58576
2022-06-11 11:17:05,309 [INFO][cluster:927]: Creating interactive engine service...
2022-06-11 11:17:05,309 [INFO][cluster:855]: Launching zetcd proxy service ...
2022-06-11 11:17:05,309 [INFO][cluster:867]: zetcd cmd /home/graphscope/.local/lib/python3.8/site-packages/graphscope.runti me/bin/zetcd --zkaddr 0.0.0.0:2181 --endpoints http://gs-etcd-service-qrgbuf:58576,http://gs-etcd-qrgbuf-0:58576
Running zetcd proxy
Version: Version not provided (use make instead of go build)
SHA: SHA not provided (use make instead of go build)
2022-06-11 11:17:06,318 [INFO][cluster:896]: ZEtcd is ready, endpoint is 10.244.3.34:2181
2022-06-11 11:17:06,318 [INFO][cluster:934]: Creating engine replicaset...
2022-06-11 11:17:06,318 [INFO][cluster:534]: Launching GraphScope engines pod ...
2022-06-11 11:17:06,611 [INFO][cluster:987]: [gs-engine-qrgbuf-6jzgc]: Successfully assigned gs-eonbnu/gs-engine-qrgbuf-6jz gc to ubuntu21
2022-06-11 11:17:07,550 [INFO][cluster:987]: [gs-engine-qrgbuf-6jzgc]: Container image "registry.cn-hongkong.aliyuncs.com/g raphscope/graphscope:0.13.0" already present on machine
2022-06-11 11:17:07,616 [INFO][cluster:987]: [gs-engine-qrgbuf-qqfgs]: Successfully assigned gs-eonbnu/gs-engine-qrgbuf-qqf gs to ubuntu21
2022-06-11 11:17:07,888 [INFO][cluster:987]: [gs-engine-qrgbuf-qqfgs]: Container image "registry.cn-hongkong.aliyuncs.com/g raphscope/graphscope:0.13.0" already present on machine
2022-06-11 11:17:08,014 [INFO][cluster:987]: [gs-engine-qrgbuf-qqfgs]: Created container engine
2022-06-11 11:17:08,253 [INFO][cluster:987]: [gs-engine-qrgbuf-qqfgs]: Started container engine
2022-06-11 11:17:08,349 [INFO][cluster:987]: [gs-engine-qrgbuf-qqfgs]: Created container vineyard
2022-06-11 11:17:08,560 [INFO][cluster:987]: [gs-engine-qrgbuf-qqfgs]: Started container vineyard
2022-06-11 11:17:10,780 [INFO][cluster:987]: [gs-engine-qrgbuf-6jzgc]: Created container engine
2022-06-11 11:17:10,781 [INFO][cluster:987]: [gs-engine-qrgbuf-6jzgc]: Started container engine
2022-06-11 11:17:10,783 [INFO][cluster:987]: [gs-engine-qrgbuf-6jzgc]: Created container vineyard
2022-06-11 11:17:10,784 [INFO][cluster:987]: [gs-engine-qrgbuf-6jzgc]: Started container vineyard
2022-06-11 11:17:19,167 [INFO][cluster:987]: [gs-engine-qrgbuf-6jzgc]: Readiness probe failed:
2022-06-11 11:17:20,172 [INFO][cluster:987]: [gs-engine-qrgbuf-qqfgs]: Readiness probe failed:
2022-06-11 11:16:23,522 [INFO][utils:182]: coordinator-qrgbuf-849984d654-rndlr: Readiness probe failed: dial tcp 10.244.3.3 4:59262: connect: connection refused
2022-06-11 11:17:36,063 [DEBUG][cluster:1019]: vineyard rpc runs on 10.175.123.21:30332
2022-06-11 11:17:36,064 [INFO][cluster:1025]: GraphScope engines pod is ready.
2022-06-11 11:17:36,066 [INFO][cluster:1172]: Engines pod name list: ['gs-engine-qrgbuf-6jzgc', 'gs-engine-qrgbuf-qqfgs']
2022-06-11 11:17:36,066 [INFO][cluster:1173]: Engines pod ip list: ['10.244.4.32', '10.244.4.33']
2022-06-11 11:17:36,066 [INFO][cluster:1174]: Engines pod host ip list: ['10.175.123.21', '10.175.123.21']
2022-06-11 11:17:36,066 [INFO][cluster:1175]: Vineyard service endpoint: 10.175.123.21:30332
2022-06-11 11:17:36,066 [INFO][cluster:1049]: Starting GAE rpc service on 10.244.4.32:56053 ...
2022-06-11 11:17:36,670 [DEBUG][utils:1777]: Resolve mpi cmd prefix: /home/graphscope/.local/lib/python3.8/site-packages/gr aphscope.runtime/openmpi/bin/mpirun --allow-run-as-root -n 2 -host gs-engine-qrgbuf-6jzgc:1.0,gs-engine-qrgbuf-qqfgs:1.0
2022-06-11 11:17:36,670 [DEBUG][utils:1778]: Resolve mpi env: {"OMPI_MCA_btl_vader_single_copy_mechanism": "none", "OMPI_MC A_orte_allowed_exit_without_sync": "1", "OMPI_MCA_odls_base_sigkill_timeout": "0", "OMPI_MCA_plm_rsh_agent": "/home/graphsc ope/.local/lib/python3.8/site-packages/graphscope.runtime/bin/kube_ssh"}
2022-06-11 11:17:36,681 [INFO][cluster:1095]: Analytical engine launching command: /home/graphscope/.local/lib/python3.8/si te-packages/graphscope.runtime/openmpi/bin/mpirun --allow-run-as-root -n 2 -host gs-engine-qrgbuf-6jzgc:1.0,gs-engine-qrgbu f-qqfgs:1.0 /home/graphscope/.local/lib/python3.8/site-packages/graphscope.runtime/bin/grape_engine --host 0.0.0.0 --port 5 6053 --vineyard_shared_mem 4Gi -v 10 --vineyard_socket /tmp/vineyard_workspace/vineyard.sock
2022-06-11 11:17:36,694 [INFO][coordinator:197]: Java initial class path set to: /home/graphscope/.local/lib/python3.8/site -packages/graphscope.runtime/lib/grape-runtime-0.1-shaded.jar
2022-06-11 11:17:36,697 [INFO][coordinator:1587]: Coordinator server listen at 0.0.0.0:59262
10.244.4.32 gs-engine-qrgbuf-6jzgc
10.244.4.33 gs-engine-qrgbuf-qqfgs
I0611 12:09:52.000000 108 /work/analytical_engine/core/grape_instance.cc:59] Workers of grape-engine initialized.
I0611 12:09:52.000000 111 /work/analytical_engine/core/server/analytical_server.cc:36] Analytical server is listening on 0.0.0.0:56053
2022-06-11 11:16:43,728 [INFO][cluster:571]: Coordinator pod start successful with address 10.175.123.8:31337, connecting t o service ...
Traceback (most recent call last):
File "/home/yuenyu/python/venv/lib/python3.9/site-packages/graphscope/client/rpc.py", line 68, in waiting_service_ready
self._stub.HeartBeat(request)
File "/home/yuenyu/python/venv/lib/python3.9/site-packages/grpc/_channel.py", line 946, in call
return _end_unary_response_blocking(state, call, False, None)
File "/home/yuenyu/python/venv/lib/python3.9/site-packages/grpc/_channel.py", line 849, in _end_unary_response_blocking
raise _InactiveRpcError(state)
grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
status = StatusCode.UNAVAILABLE
details = "failed to connect to all addresses"
debug_error_string = "{"created":"@1654918004.522083028","description":"Failed to pick subchannel","file":"src/core /ext/filters/client_channel/client_channel.cc","file_line":3217,"referenced_errors":[{"created":"@1654918004.522081306","de scription":"failed to connect to all addresses","file":"src/core/lib/transport/error_utils.cc","file_line":165,"grpc_status ":14}]}"

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
File "/home/yuenyu/PycharmProjects/graph/graphscope/pagerank.py", line 10, in
sess = gs.session()
File "/home/yuenyu/python/venv/lib/python3.9/site-packages/graphscope/client/utils.py", line 357, in wrapper
return_value = func(*args, **kwargs)
File "/home/yuenyu/python/venv/lib/python3.9/site-packages/graphscope/client/session.py", line 715, in init
self._connect()
File "/home/yuenyu/python/venv/lib/python3.9/site-packages/graphscope/client/session.py", line 1047, in _connect
self._grpc_client.waiting_service_ready(
File "/home/yuenyu/python/venv/lib/python3.9/site-packages/graphscope/client/rpc.py", line 78, in waiting_service_ready
raise ConnectionError(f"Connect coordinator timeout, {msg}")
ConnectionError: Connect coordinator timeout, code: UNAVAILABLE, details: failed to connect to all addresses

[JackyYangPassion]

i have the same issue, Is this problem solved?

[yuenyu1]

NO，I give up.

…

---Original--- From: ***@***.***&gt; Date: Mon, Nov 14, 2022 23:43 PM To: ***@***.***&gt;; Cc: ***@***.******@***.***&gt;; Subject: Re: [alibaba/GraphScope] Coordinator pod start successful but can'tconnecting to service ... (Discussion #1707) i have the same issue, Is this problem solved? — Reply to this email directly, view it on GitHub, or unsubscribe. You are receiving this because you authored the thread.Message ID: ***@***.***&gt;

[sighingnow]

/cc @lidongze0629

[Qingnan1]

++ same error

[rahulvramesh]

any luck ?

[lidongze0629]

@rahulvramesh It works fine with 0.23.0 GraphScope on the Aliyun ACK cluster. If you have any problems, could you please give more error messages here? We will take a look asap. Thanks!

Here is my test code:

In [28]: import graphscope

In [29]: graphscope.__version__
Out[29]: '0.23.0'

In [30]: graphscope.set_option(show_log=True)

In [31]: sess = graphscope.session(cluster_type="k8s")
2023-07-20 17:57:52,969 [INFO][cluster:545]: Coordinator pod start successful with address 192.168.0.174:31243, connecting to service ...
2023-07-20 17:57:52,974 [INFO][rpc:69]: GraphScope coordinator service connected.

[rahulvramesh]

hi @lidongze0629

2023-07-20 10:04:23,501 [WARNING][op_executor:349]: Connecting to analytical engine... tried 1 time, will retry in 2 seconds
2023-07-20 10:04:23,501 [WARNING][op_executor:354]: Error code: StatusCode.UNAVAILABLE, details failed to connect to all addresses; last error: UNKNOWN: ipv4:192.168.45.162:56770: Failed to connect to remote host: Connection refused
2023-07-20 10:04:25,580 [WARNING][op_executor:349]: Connecting to analytical engine... tried 2 time, will retry in 4 seconds
2023-07-20 10:04:25,581 [WARNING][op_executor:354]: Error code: StatusCode.UNAVAILABLE, details failed to connect to all addresses; last error: UNKNOWN: ipv4:192.168.45.162:56770: Failed to connect to remote host: Connection refused

╭───────────────────── Traceback (most recent call last) ──────────────────────╮
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/aiohttp/client.py:423 in _request                                          │
│                                                                              │
│    420 │   │   proxy_headers = self._prepare_headers(proxy_headers)          │
│    421 │   │                                                                 │
│    422 │   │   try:                                                          │
│ ❱  423 │   │   │   url = self._build_url(str_or_url)                         │
│    424 │   │   except ValueError as e:                                       │
│    425 │   │   │   raise InvalidURL(str_or_url) from e                       │
│    426                                                                       │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/aiohttp/client.py:357 in _build_url                                        │
│                                                                              │
│    354 │   │   return _RequestContextManager(self._request(method, url, **kw │
│    355 │                                                                     │
│    356 │   def _build_url(self, str_or_url: StrOrURL) -> URL:                │
│ ❱  357 │   │   url = URL(str_or_url)                                         │
│    358 │   │   if self._base_url is None:                                    │
│    359 │   │   │   return url                                                │
│    360 │   │   else:                                                         │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/yarl/_url.py:188 in __new__                                                │
│                                                                              │
│    185 │   │   │   else:                                                     │
│    186 │   │   │   │   host = val.hostname                                   │
│    187 │   │   │   │   if host is None:                                      │
│ ❱  188 │   │   │   │   │   raise ValueError("Invalid URL: host is required f │
│    189 │   │   │   │                                                         │
│    190 │   │   │   │   try:                                                  │
│    191 │   │   │   │   │   port = val.port                                   │
╰──────────────────────────────────────────────────────────────────────────────╯
ValueError: Invalid URL: host is required for absolute urls

The above exception was the direct cause of the following exception:

╭───────────────────── Traceback (most recent call last) ──────────────────────╮
│ /Users/rahulvramesh/workspace/try/graphscope-k8/try.py:10 in <module>        │
│                                                                              │
│    7                                                                         │
│    8 g = gs.gremlin(graph)                                                   │
│    9                                                                         │
│ ❱ 10 q1 = g.execute('g.V().count()')                                         │
│   11                                                                         │
│   12 print(q1.all())                                                         │
│   13                                                                         │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/graphscope/interactive/query.py:88 in execute                              │
│                                                                              │
│    85 │                                                                      │
│    86 │   def execute(self, query, request_options=None):                    │
│    87 │   │   """A simple wrapper around `submit`, for compatibility"""      │
│ ❱  88 │   │   return self.submit(query, request_options=request_options)     │
│    89 │                                                                      │
│    90 │   def submit(self, query, request_options=None):                     │
│    91 │   │   """Execute gremlin querying scripts.                           │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/graphscope/interactive/query.py:103 in submit                              │
│                                                                              │
│   100 │   │   Returns:                                                       │
│   101 │   │   │   :class:`gremlin_python.driver.client.ResultSet`:           │
│   102 │   │   """                                                            │
│ ❱ 103 │   │   return self.gremlin_client.submit(query, request_options=reque │
│   104 │                                                                      │
│   105 │   @property                                                          │
│   106 │   def gremlin_client(self):                                          │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/gremlin_python/driver/client.py:150 in submit                              │
│                                                                              │
│   147 │   │   │   headers=self._headers, enable_user_agent_on_connect=self._ │
│   148 │                                                                      │
│   149 │   def submit(self, message, bindings=None, request_options=None):    │
│ ❱ 150 │   │   return self.submit_async(message, bindings=bindings, request_o │
│   151 │                                                                      │
│   152 │   def submitAsync(self, message, bindings=None, request_options=None │
│   153 │   │   warnings.warn(                                                 │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/gremlin_python/driver/client.py:182 in submit_async                        │
│                                                                              │
│   179 │   │   conn = self._pool.get(True)                                    │
│   180 │   │   if request_options:                                            │
│   181 │   │   │   message.args.update(request_options)                       │
│ ❱ 182 │   │   return conn.write(message)                                     │
│   183                                                                        │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/gremlin_python/driver/connection.py:60 in write                            │
│                                                                              │
│   57 │                                                                       │
│   58 │   def write(self, request_message):                                   │
│   59 │   │   if not self._inited:                                            │
│ ❱ 60 │   │   │   self.connect()                                              │
│   61 │   │   request_id = str(uuid.uuid4())                                  │
│   62 │   │   if request_message.args.get("requestId"):                       │
│   63 │   │   │   request_id = request_message.args.get("requestId")          │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/gremlin_python/driver/connection.py:50 in connect                          │
│                                                                              │
│   47 │   │   if self._transport:                                             │
│   48 │   │   │   self._transport.close()                                     │
│   49 │   │   self._transport = self._transport_factory()                     │
│ ❱ 50 │   │   self._transport.connect(self._url, self._headers)               │
│   51 │   │   self._protocol.connection_made(self._transport)                 │
│   52 │   │   self._inited = True                                             │
│   53                                                                         │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/gremlin_python/driver/aiohttp/transport.py:79 in connect                   │
│                                                                              │
│    76 │   │   │   │   │   raise                                              │
│    77 │   │                                                                  │
│    78 │   │   # Execute the async connect synchronously.                     │
│ ❱  79 │   │   self._loop.run_until_complete(async_connect())                 │
│    80 │                                                                      │
│    81 │   def write(self, message):                                          │
│    82 │   │   # Inner function to perform async write.                       │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/nest_asyncio.py:90 in run_until_complete                                   │
│                                                                              │
│    87 │   │   │   if not f.done():                                           │
│    88 │   │   │   │   raise RuntimeError(                                    │
│    89 │   │   │   │   │   'Event loop stopped before Future completed.')     │
│ ❱  90 │   │   │   return f.result()                                          │
│    91 │                                                                      │
│    92 │   def _run_once(self):                                               │
│    93 │   │   """                                                            │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/asyncio/futu │
│ res.py:201 in result                                                         │
│                                                                              │
│   198 │   │   │   raise exceptions.InvalidStateError('Result is not ready.') │
│   199 │   │   self.__log_traceback = False                                   │
│   200 │   │   if self._exception is not None:                                │
│ ❱ 201 │   │   │   raise self._exception                                      │
│   202 │   │   return self._result                                            │
│   203 │                                                                      │
│   204 │   def exception(self):                                               │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/asyncio/task │
│ s.py:256 in __step                                                           │
│                                                                              │
│   253 │   │   │   if exc is None:                                            │
│   254 │   │   │   │   # We use the `send` method directly, because coroutine │
│   255 │   │   │   │   # don't have `__iter__` and `__next__` methods.        │
│ ❱ 256 │   │   │   │   result = coro.send(None)                               │
│   257 │   │   │   else:                                                      │
│   258 │   │   │   │   result = coro.throw(exc)                               │
│   259 │   │   except StopIteration as exc:                                   │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/gremlin_python/driver/aiohttp/transport.py:69 in async_connect             │
│                                                                              │
│    66 │   │   │   # Start client session and use it to create a websocket wi │
│    67 │   │   │   self._client_session = aiohttp.ClientSession(loop=self._lo │
│    68 │   │   │   try:                                                       │
│ ❱  69 │   │   │   │   self._websocket = await self._client_session.ws_connec │
│    70 │   │   │   except ClientResponseError as err:                         │
│    71 │   │   │   │   # If 403, just send forbidden because in some cases th │
│    72 │   │   │   │   # that includes credentials.                           │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/aiohttp/client.py:779 in _ws_connect                                       │
│                                                                              │
│    776 │   │   ssl = _merge_ssl_params(ssl, verify_ssl, ssl_context, fingerp │
│    777 │   │                                                                 │
│    778 │   │   # send request                                                │
│ ❱  779 │   │   resp = await self.request(                                    │
│    780 │   │   │   method,                                                   │
│    781 │   │   │   url,                                                      │
│    782 │   │   │   params=params,                                            │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/aiohttp/client.py:425 in _request                                          │
│                                                                              │
│    422 │   │   try:                                                          │
│    423 │   │   │   url = self._build_url(str_or_url)                         │
│    424 │   │   except ValueError as e:                                       │
│ ❱  425 │   │   │   raise InvalidURL(str_or_url) from e                       │
│    426 │   │                                                                 │
│    427 │   │   skip_headers = set(self._skip_auto_headers)                   │
│    428 │   │   if skip_auto_headers is not None:                             │
╰──────────────────────────────────────────────────────────────────────────────╯
InvalidURL: ws://:50768/gremlin
WARNING:urllib3.connectionpool:Retrying (Retry(total=2, connect=None, read=None, redirect=None, status=None)) after connection broken by 'SSLError(FileNotFoundError(2, 'No such file or directory'))': /api/v1/namespaces/gs-bzndsd/services/coordinator-qqrtmq
WARNING:urllib3.connectionpool:Retrying (Retry(total=1, connect=None, read=None, redirect=None, status=None)) after connection broken by 'SSLError(FileNotFoundError(2, 'No such file or directory'))': /api/v1/namespaces/gs-bzndsd/services/coordinator-qqrtmq
WARNING:urllib3.connectionpool:Retrying (Retry(total=0, connect=None, read=None, redirect=None, status=None)) after connection broken by 'SSLError(FileNotFoundError(2, 'No such file or directory'))': /api/v1/namespaces/gs-bzndsd/services/coordinator-qqrtmq
Exception ignored in: <function KubernetesClusterLauncher.__del__ at 0x1379e2dc0>
Traceback (most recent call last):
  File "/Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-packages/graphscope/deploy/kubernetes/cluster.py", line 149, in __del__
  File "/Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-packages/graphscope/deploy/kubernetes/cluster.py", line 566, in stop
  File "/Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-packages/graphscope/deploy/kubernetes/utils.py", line 394, in delete_kubernetes_object
  File "/Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/re.py", line 210, in sub
ImportError: sys.meta_path is None, Python is likely shutting down

hi @lidongze0629 

using

sess = gs.session(cluster_type='k8s', show_log=True, k8s_service_type='LoadBalancer', with_dataset=True)

[lidongze0629]

@rahulvramesh

It looks like the error comes from the gremlin query

Can you please check whether the session and data uploading are executed successfully by just executing the following code:

import graphscope
graphscope.set_option(show_log=True)
sess = graphscope.session(cluster_type="k8s", with_dataset=True, k8s_service_type='LoadBalancer')
from graphscope.dataset import load_ogbn_mag
g = load_ogbn_mag(sess, '/dataset/ogbn_mag_small')
print(g)

# run pagerank
# project property graph 'g' to a simple graph to run pagerank
simple_g = g.project(vertices={"paper": []}, edges={"cites": []})
pr = graphscope.pagerank(simple_g, delta=0.85, max_round=10)
# print the result
pr.to_dataframe(selector={'node': 'r'})

session already launched and data loading completed successfully of the above code. And th

[rahulvramesh]

that works , when i use the gremlin it fails

InvalidURL: ws://:50456/gremlin

╭───────────────────── Traceback (most recent call last) ──────────────────────╮
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/aiohttp/client.py:423 in _request                                          │
│                                                                              │
│    420 │   │   proxy_headers = self._prepare_headers(proxy_headers)          │
│    421 │   │                                                                 │
│    422 │   │   try:                                                          │
│ ❱  423 │   │   │   url = self._build_url(str_or_url)                         │
│    424 │   │   except ValueError as e:                                       │
│    425 │   │   │   raise InvalidURL(str_or_url) from e                       │
│    426                                                                       │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/aiohttp/client.py:357 in _build_url                                        │
│                                                                              │
│    354 │   │   return _RequestContextManager(self._request(method, url, **kw │
│    355 │                                                                     │
│    356 │   def _build_url(self, str_or_url: StrOrURL) -> URL:                │
│ ❱  357 │   │   url = URL(str_or_url)                                         │
│    358 │   │   if self._base_url is None:                                    │
│    359 │   │   │   return url                                                │
│    360 │   │   else:                                                         │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/yarl/_url.py:188 in __new__                                                │
│                                                                              │
│    185 │   │   │   else:                                                     │
│    186 │   │   │   │   host = val.hostname                                   │
│    187 │   │   │   │   if host is None:                                      │
│ ❱  188 │   │   │   │   │   raise ValueError("Invalid URL: host is required f │
│    189 │   │   │   │                                                         │
│    190 │   │   │   │   try:                                                  │
│    191 │   │   │   │   │   port = val.port                                   │
╰──────────────────────────────────────────────────────────────────────────────╯
ValueError: Invalid URL: host is required for absolute urls

The above exception was the direct cause of the following exception:

╭───────────────────── Traceback (most recent call last) ──────────────────────╮
│ /Users/rahulvramesh/workspace/try/graphscope-k8/try.py:13 in <module>        │
│                                                                              │
│   10                                                                         │
│   11 g = graphscope.gremlin(graph)                                           │
│   12                                                                         │
│ ❱ 13 q1 = g.execute('g.V().count()')                                         │
│   14                                                                         │
│   15 print(q1.all())                                                         │
│   16                                                                         │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/graphscope/interactive/query.py:88 in execute                              │
│                                                                              │
│    85 │                                                                      │
│    86 │   def execute(self, query, request_options=None):                    │
│    87 │   │   """A simple wrapper around `submit`, for compatibility"""      │
│ ❱  88 │   │   return self.submit(query, request_options=request_options)     │
│    89 │                                                                      │
│    90 │   def submit(self, query, request_options=None):                     │
│    91 │   │   """Execute gremlin querying scripts.                           │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/graphscope/interactive/query.py:103 in submit                              │
│                                                                              │
│   100 │   │   Returns:                                                       │
│   101 │   │   │   :class:`gremlin_python.driver.client.ResultSet`:           │
│   102 │   │   """                                                            │
│ ❱ 103 │   │   return self.gremlin_client.submit(query, request_options=reque │
│   104 │                                                                      │
│   105 │   @property                                                          │
│   106 │   def gremlin_client(self):                                          │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/gremlin_python/driver/client.py:150 in submit                              │
│                                                                              │
│   147 │   │   │   headers=self._headers, enable_user_agent_on_connect=self._ │
│   148 │                                                                      │
│   149 │   def submit(self, message, bindings=None, request_options=None):    │
│ ❱ 150 │   │   return self.submit_async(message, bindings=bindings, request_o │
│   151 │                                                                      │
│   152 │   def submitAsync(self, message, bindings=None, request_options=None │
│   153 │   │   warnings.warn(                                                 │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/gremlin_python/driver/client.py:182 in submit_async                        │
│                                                                              │
│   179 │   │   conn = self._pool.get(True)                                    │
│   180 │   │   if request_options:                                            │
│   181 │   │   │   message.args.update(request_options)                       │
│ ❱ 182 │   │   return conn.write(message)                                     │
│   183                                                                        │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/gremlin_python/driver/connection.py:60 in write                            │
│                                                                              │
│   57 │                                                                       │
│   58 │   def write(self, request_message):                                   │
│   59 │   │   if not self._inited:                                            │
│ ❱ 60 │   │   │   self.connect()                                              │
│   61 │   │   request_id = str(uuid.uuid4())                                  │
│   62 │   │   if request_message.args.get("requestId"):                       │
│   63 │   │   │   request_id = request_message.args.get("requestId")          │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/gremlin_python/driver/connection.py:50 in connect                          │
│                                                                              │
│   47 │   │   if self._transport:                                             │
│   48 │   │   │   self._transport.close()                                     │
│   49 │   │   self._transport = self._transport_factory()                     │
│ ❱ 50 │   │   self._transport.connect(self._url, self._headers)               │
│   51 │   │   self._protocol.connection_made(self._transport)                 │
│   52 │   │   self._inited = True                                             │
│   53                                                                         │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/gremlin_python/driver/aiohttp/transport.py:79 in connect                   │
│                                                                              │
│    76 │   │   │   │   │   raise                                              │
│    77 │   │                                                                  │
│    78 │   │   # Execute the async connect synchronously.                     │
│ ❱  79 │   │   self._loop.run_until_complete(async_connect())                 │
│    80 │                                                                      │
│    81 │   def write(self, message):                                          │
│    82 │   │   # Inner function to perform async write.                       │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/nest_asyncio.py:90 in run_until_complete                                   │
│                                                                              │
│    87 │   │   │   if not f.done():                                           │
│    88 │   │   │   │   raise RuntimeError(                                    │
│    89 │   │   │   │   │   'Event loop stopped before Future completed.')     │
│ ❱  90 │   │   │   return f.result()                                          │
│    91 │                                                                      │
│    92 │   def _run_once(self):                                               │
│    93 │   │   """                                                            │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/asyncio/futu │
│ res.py:201 in result                                                         │
│                                                                              │
│   198 │   │   │   raise exceptions.InvalidStateError('Result is not ready.') │
│   199 │   │   self.__log_traceback = False                                   │
│   200 │   │   if self._exception is not None:                                │
│ ❱ 201 │   │   │   raise self._exception                                      │
│   202 │   │   return self._result                                            │
│   203 │                                                                      │
│   204 │   def exception(self):                                               │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/asyncio/task │
│ s.py:256 in __step                                                           │
│                                                                              │
│   253 │   │   │   if exc is None:                                            │
│   254 │   │   │   │   # We use the `send` method directly, because coroutine │
│   255 │   │   │   │   # don't have `__iter__` and `__next__` methods.        │
│ ❱ 256 │   │   │   │   result = coro.send(None)                               │
│   257 │   │   │   else:                                                      │
│   258 │   │   │   │   result = coro.throw(exc)                               │
│   259 │   │   except StopIteration as exc:                                   │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/gremlin_python/driver/aiohttp/transport.py:69 in async_connect             │
│                                                                              │
│    66 │   │   │   # Start client session and use it to create a websocket wi │
│    67 │   │   │   self._client_session = aiohttp.ClientSession(loop=self._lo │
│    68 │   │   │   try:                                                       │
│ ❱  69 │   │   │   │   self._websocket = await self._client_session.ws_connec │
│    70 │   │   │   except ClientResponseError as err:                         │
│    71 │   │   │   │   # If 403, just send forbidden because in some cases th │
│    72 │   │   │   │   # that includes credentials.                           │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/aiohttp/client.py:779 in _ws_connect                                       │
│                                                                              │
│    776 │   │   ssl = _merge_ssl_params(ssl, verify_ssl, ssl_context, fingerp │
│    777 │   │                                                                 │
│    778 │   │   # send request                                                │
│ ❱  779 │   │   resp = await self.request(                                    │
│    780 │   │   │   method,                                                   │
│    781 │   │   │   url,                                                      │
│    782 │   │   │   params=params,                                            │
│                                                                              │
│ /Users/rahulvramesh/miniconda3/envs/graphscope-k8/lib/python3.9/site-package │
│ s/aiohttp/client.py:425 in _request                                          │
│                                                                              │
│    422 │   │   try:                                                          │
│    423 │   │   │   url = self._build_url(str_or_url)                         │
│    424 │   │   except ValueError as e:                                       │
│ ❱  425 │   │   │   raise InvalidURL(str_or_url) from e                       │
│    426 │   │                                                                 │
│    427 │   │   skip_headers = set(self._skip_auto_headers)                   │
│    428 │   │   if skip_auto_headers is not None:                             │
╰──────────────────────────────────────────────────────────────────────────────╯
InvalidURL: ws://:50456/gremlin

[lidongze0629]

@rahulvramesh Thanks very much, there's something wrong happened to get the gremlin host with LoadBalancer type. @siyuan0322 Could you please take a look at this?

[siyuan0322]

Hi @rahulvramesh I could not reproduce the error using 0.23.0.
Are you using the version of 0.23.0? If not, it's probably a bug that has been fixed in main.

[siyuan0322]

Or check if the loadbalancer of gremlin has been created, gremlin-36657041042442728 in the following example

yuansi@iZj6cehhiq63h2ndy9fvy6Z:/mnt/siyuan$ k -n gs-zizdzf get svc
NAME                                            TYPE           CLUSTER-IP       EXTERNAL-IP      PORT(S)                          AGE
coordinator-znlmkh                              LoadBalancer   172.16.12.173    47.243.121.226   59945:31115/TCP,8000:31752/TCP   2m22s
gremlin-36657041042442728                       LoadBalancer   172.16.188.142   47.242.231.91    50373:31671/TCP                  16s
gs-engine-znlmkh-znlmkh-vineyard-etcd-0         ClusterIP      172.16.18.215    <none>           2379/TCP,2380/TCP                2m19s
gs-engine-znlmkh-znlmkh-vineyard-etcd-service   ClusterIP      172.16.158.243   <none>           2379/TCP                         2m19s
gs-engine-znlmkh-znlmkh-vineyard-rpc            LoadBalancer   172.16.250.234   47.243.60.128    9600:30492/TCP                   2m19s