diff --git a/gremlin-go/driver/connection.go b/gremlin-go/driver/connection.go index c01526bb37b..cb52c526d01 100644 --- a/gremlin-go/driver/connection.go +++ b/gremlin-go/driver/connection.go @@ -58,6 +58,10 @@ func (connection *connection) errorCallback() { connection.syncLock.Lock() defer connection.syncLock.Unlock() + if connection.state == closed || connection.state == closedDueToError { + return + } + connection.logHandler.log(Error, errorCallback) connection.state = closedDueToError