Add entry points for inbox and outbox cleanup processes
Change the way to work with the Session. We can't always call self._engine.connect(), because it creates a new connection with own transaction each time. Instead of this, ScopedSession with autoflush=False and autocommit=True is used. So, there is only on db connection (and Session) during event handling. All operations during event handling are in transaction.
Add on_process_start and on_process_stop hooks. Now, they are used only for managing test coverage
self._engine.connect()
, because it creates a new connection with own transaction each time. Instead of this,ScopedSession
withautoflush=False
andautocommit=True
is used. So, there is only on db connection (and Session) during event handling. All operations during event handling are in transaction.on_process_start
andon_process_stop
hooks. Now, they are used only for managing test coverage