1 files changed, 3 insertions, 2 deletions

diff --git a/common/pipeline.cpp b/common/pipeline.cpp
index 4e55e76..434f732 100644
--- a/common/pipeline.cpp
+++ b/common/pipeline.cpp
@@ -63,8 +63,9 @@ public:
 Pipeline::Pipeline(const ResourceContext &context, const Sink::Log::Context &ctx) : QObject(nullptr), d(new Private(context, ctx))
 {
     //Create main store immediately on first start
-    d->entityStore.startTransaction(DataStore::ReadWrite);
-    d->entityStore.commitTransaction();
+    auto store = Sink::Storage::DataStore(Sink::storageLocation(), context.instanceId(), Sink::Storage::DataStore::ReadWrite);
+    auto t = store.createTransaction(Storage::DataStore::ReadWrite);
+    Storage::DataStore::setDatabaseVersion(t, Sink::latestDatabaseVersion());
 }
 
 Pipeline::~Pipeline()