diff --git a/go.mod b/go.mod
index 915e7ee..144dce0 100644
--- a/go.mod
+++ b/go.mod
@@ -4,7 +4,6 @@ go 1.23.2
 
 require (
 	gitea.com/logicamp/lc v1.14.6
-	github.com/dgraph-io/badger/v4 v4.5.0
 	github.com/logi-camp/go-flink-client v0.1.3
 	github.com/matoous/go-nanoid/v2 v2.1.0
 	github.com/tidwall/buntdb v1.3.2
diff --git a/go.sum b/go.sum
index c0ba322..ea25b17 100644
--- a/go.sum
+++ b/go.sum
@@ -260,12 +260,6 @@ github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
 github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
-github.com/logi-camp/go-flink-client v0.1.0 h1:uzBV6RGkyzZVdSQ8zAlUGbJ5hdXRspaPjzzYJUQ2aJU=
-github.com/logi-camp/go-flink-client v0.1.0/go.mod h1:A79abedX6wGQI0FoICdZI7SRoGHj15QwMwWowgsKYFI=
-github.com/logi-camp/go-flink-client v0.1.1 h1:N/XLXE/WZGPKgJo8pN+Q3JrHBOoZHwUoditd399coRo=
-github.com/logi-camp/go-flink-client v0.1.1/go.mod h1:A79abedX6wGQI0FoICdZI7SRoGHj15QwMwWowgsKYFI=
-github.com/logi-camp/go-flink-client v0.1.2 h1:LH9SD7jbVi6CJ9ZTyIAmlLGqLV0KZEIQulZSZiVuMr8=
-github.com/logi-camp/go-flink-client v0.1.2/go.mod h1:A79abedX6wGQI0FoICdZI7SRoGHj15QwMwWowgsKYFI=
 github.com/logi-camp/go-flink-client v0.1.3 h1:YaVH0yJUIcZn8KPodNLXKuo2T394ph9XUEGUhU8+sDQ=
 github.com/logi-camp/go-flink-client v0.1.3/go.mod h1:A79abedX6wGQI0FoICdZI7SRoGHj15QwMwWowgsKYFI=
 github.com/lufia/plan9stats v0.0.0-20211012122336-39d0f177ccd0 h1:6E+4a0GO5zZEnZ81pIr0yLvtUWk2if982qA3F3QD6H4=
diff --git a/internal/managed_job/state.go b/internal/managed_job/state.go
index 44e02e9..68ca259 100644
--- a/internal/managed_job/state.go
+++ b/internal/managed_job/state.go
@@ -2,16 +2,14 @@ package managed_job
 
 import (
 	"encoding/json"
-	"errors"
 	"time"
 
-	"github.com/dgraph-io/badger/v4"
 	"github.com/tidwall/buntdb"
 )
 
 // get state of job from local db
 func (job *ManagedJob) loadState() {
-	err := job.db.View(
+	job.db.View(
 		func(tx *buntdb.Tx) error {
 			if val, err := tx.Get(string(job.def.GetUID())); err != nil {
 				return err
@@ -19,9 +17,6 @@ func (job *ManagedJob) loadState() {
 				return json.Unmarshal([]byte(val), job.state)
 			}
 		})
-	if errors.Is(err, badger.ErrKeyNotFound) {
-		err = nil
-	}
 }
 
 // save state of job to local db