Class FlakyConnectionPool

distributed.tests.test_semaphore.FlakyConnectionPool

Declaration

class FlakyConnectionPool(ConnectionPool)

Methods

▶ def __init__(self, *args, failing_connections=0, **kwargs) override
source link
This method overrides distributed.core.ConnectionPool.__init__.
▷ def activate(self)
source link
▷ def deactivate(self)
source link

Inherited methods

Methods inherited from distributed.core.ConnectionPool:
__await__, __call__, __repr__, active, collect, open, remove, reuse