Don't just set the db version, only when we create the db first.

1 files changed, 1 insertions, 3 deletions

diff --git a/common/pipeline.cpp b/common/pipeline.cpp
index 434f732..ee9d3af 100644
--- a/common/pipeline.cpp
+++ b/common/pipeline.cpp
@@ -63,9 +63,7 @@ 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
-    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());
+    d->entityStore.createIfMissing();
 }
 
 Pipeline::~Pipeline()