31 from pickle import loads, dumps

    31 from pickle import loads, dumps

    32 from threading import Lock

    32 from threading import Lock

    33 from datetime import datetime

    33 from datetime import datetime

    34 from base64 import b64decode, b64encode

    34 from base64 import b64decode, b64encode

    35 from contextlib import contextmanager

    35 from contextlib import contextmanager

    36 

    37 

    37 from logilab.common.compat import any

    38 from logilab.common.compat import any

    38 from logilab.common.cache import Cache

    39 from logilab.common.cache import Cache

    39 from logilab.common.decorators import cached, clear_cache

    40 from logilab.common.decorators import cached, clear_cache

    40 from logilab.common.configuration import Method

    41 from logilab.common.configuration import Method

   262         # XXX no_sqlite_wrap trick since we've a sqlite locking pb when

   263         # XXX no_sqlite_wrap trick since we've a sqlite locking pb when

   263         # running unittest_multisources with the wrapping below

   264         # running unittest_multisources with the wrapping below

   264         if self.dbdriver == 'sqlite' and \

   265         if self.dbdriver == 'sqlite' and \

   265                not getattr(repo.config, 'no_sqlite_wrap', False):

   266                not getattr(repo.config, 'no_sqlite_wrap', False):

   266             from cubicweb.server.sources.extlite import ConnectionWrapper

   267             from cubicweb.server.sources.extlite import ConnectionWrapper

   267             self.get_connection = lambda: ConnectionWrapper(self)

   269             self.get_connection = lambda: ConnectionWrapper(self)

   268             self.check_connection = lambda cnx: cnx

   270             self.check_connection = lambda cnx: cnx

   269             def pool_reset(cnx):

   271             def pool_reset(cnx):

   270                 cnx.close()

   272                 cnx.close()

   271             self.pool_reset = pool_reset

   273             self.pool_reset = pool_reset