Соединения Gremlin Python зависают после сбоя - PullRequest
Новая
       31

Соединения Gremlin Python зависают после сбоя

0 голосов
/ 12 октября 2018

если отправка gremlin не удалась по какой-либо причине (здесь я специально делаю сбой, пытаясь вставить тот же идентификатор снова) больше, чем pool_size, тогда следующий вызов отправки завершается неудачей.

Мне ясно, что послекаждое неудачное соединение не освобождается обратно в пул.Но как я могу это сделать? 

>>> from gremlin_python.driver.driver_remote_connection import DriverRemoteConnection
>>> from gremlin_python.structure.graph import Graph
>>> from gremlin_python.process.traversal import T
>>>
>>> NEPTUNE_END_POINT = 'ws://127.0.0.1:8182/gremlin'
>>> graph = Graph()
>>> g = graph.traversal().withRemote(DriverRemoteConnection(NEPTUNE_END_POINT, 'g',pool_size=2))
>>>
>>> g.addV('test1').property(T.id,'id1').toList()
[v[id1]]
>>> g.addV('test1').property(T.id,'id1').toList()
Traceback (most recent call last):
  ...
gremlin_python.driver.protocol.GremlinServerError: 499: {"requestId":"1a357c30-6595-437b-864d-f69e0ae6556c","detailedMessage":"Vertex with id already exists: id1","code":"ConstraintViolationException"}
>>> g.addV('test1').property(T.id,'id1').toList()
Traceback (most recent call last):
  ...
gremlin_python.driver.protocol.GremlinServerError: 499: {"requestId":"27005abb-17fc-4603-aa35-05104236e1a8","detailedMessage":"Vertex with id already exists: id1","code":"ConstraintViolationException"}
>>> g.addV('test1').property(T.id,'id1').toList() # Hangs here
...