X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/aa9507e1633819259794ea4d6cf391dc88621dac..09cbdc3074b3f1e69c9c537875146f6da0a6ed8f:/lib/controller/trash.go

diff --git a/lib/controller/trash.go b/lib/controller/trash.go
index afdf95b782..99e7aec0b6 100644
--- a/lib/controller/trash.go
+++ b/lib/controller/trash.go
@@ -20,7 +20,7 @@ func (h *Handler) periodicWorker(workerName string, interval time.Duration, lock
 		logger.Debugf("interval is %v, not running worker", interval)
 		return
 	}
-	if !locker.Lock(ctx, h.db) {
+	if !locker.Lock(ctx, h.dbConnector.GetDB) {
 		// context canceled
 		return
 	}
@@ -47,7 +47,7 @@ func (h *Handler) trashSweepWorker() {
 
 func (h *Handler) containerLogSweepWorker() {
 	h.periodicWorker("container log sweep", h.Cluster.Containers.Logging.SweepInterval.Duration(), dblock.ContainerLogSweep, func(ctx context.Context) error {
-		db, err := h.db(ctx)
+		db, err := h.dbConnector.GetDB(ctx)
 		if err != nil {
 			return err
 		}