def _interrupt(self, threadId, connection):
try:<EOL><INDENT>connection.cancel()<EOL><DEDENT>except pg.Error:<EOL><INDENT>pass<EOL><DEDENT>
Interrupts the given native connection from a separate thread.

:param      threadId   | <int>
            connection | <variant> | backend specific database.