How to create a reconnection pool? about txpostgres HOT 2 CLOSED

I will answer my own question:

Each Connection needs its own detector. In the code above they share the detector due to the use of partial from functools.

def connectionFactory(self, *args, **kwargs):
    return txpostgres.Connection(*args, detector=LoggingDetector(), **kwargs)

Will fix the problem.

from txpostgres.

That was indeed the problem, glad you found it!

from txpostgres.