Wire up tx

metal-stack · Feb 10, 2025 · e42bbc3 · e42bbc3
1 parent 3902b75
commit e42bbc3
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/pkg/tx/api.go b/pkg/tx/api.go
@@ -73,9 +73,7 @@ func (q *Queue) Insert(ctx context.Context, jobs ...Job) error {
 		Expiration: now.Add(defaultExpiration),
 	}
 
-	q.txStore.AddTx(ctx, tx)
-
-	return nil
+	return q.txStore.AddTx(ctx, tx)
 }
 
 func (q *Queue) List() []Tx {