1 files changed, 1 insertions, 1 deletions

diff --git a/common/pipeline.h b/common/pipeline.h
index fee6a5e..a3b3735 100644
--- a/common/pipeline.h
+++ b/common/pipeline.h
@@ -142,7 +142,7 @@ public:
 
     void process(const PipelineState &state, Akonadi2::Storage::Transaction &transaction) Q_DECL_OVERRIDE
     {
-        transaction.scan(state.key(), [this, &state, &transaction](const QByteArray &key, const QByteArray &value) -> bool {
+        transaction.openDatabase().scan(state.key(), [this, &state, &transaction](const QByteArray &key, const QByteArray &value) -> bool {
             auto entity = Akonadi2::GetEntity(value);
             mFunction(state, *entity, transaction);
             processingCompleted(state);