diff --git a/Makefile b/Makefile
index 663b03527..8dfeec2fa 100644
--- a/Makefile
+++ b/Makefile
@@ -90,7 +90,7 @@ staticcheck:
 errcheck:
 	docker run --rm -v $(shell pwd):/go/src/github.com/portworx/kdmp $(DOCK_BUILD_CNT) \
 		/bin/bash -c "cd /go/src/github.com/portworx/kdmp; \
-	GO111MODULE=off go get -u github.com/kisielk/errcheck; \
+	go install github.com/kisielk/errcheck@v1.7.0; \
 	git config --global --add safe.directory /go/src/github.com/portworx/kdmp; \
 	errcheck -ignoregenerated -ignorepkg fmt -verbose -blank $(PKGS); \
 	errcheck -ignoregenerated -ignorepkg fmt -verbose -blank -tags unittest $(PKGS)"
diff --git a/pkg/kopia/backup.go b/pkg/kopia/backup.go
index a47c4b4af..5e2b07676 100644
--- a/pkg/kopia/backup.go
+++ b/pkg/kopia/backup.go
@@ -4,14 +4,21 @@ import (
 	"bytes"
 	"encoding/json"
 	"fmt"
+	"io"
+	"log"
 	"os"
 	"os/exec"
+	"sync"
 	"time"
 
 	cmdexec "github.com/portworx/kdmp/pkg/executor"
 	"github.com/sirupsen/logrus"
 )
 
+const (
+	commandExecLogInterval = 30 * time.Second
+)
+
 // BackupSummaryResponse describes single snapshot entry.
 type BackupSummaryResponse struct {
 	ID               string     `json:"id"`
@@ -74,6 +81,34 @@ type backupExecutor struct {
 	lastError       error
 }
 
+type logWriter struct {
+	logger      *log.Logger
+	lastLogTime time.Time
+	interval    time.Duration
+	mu          sync.Mutex
+}
+
+func newLogWriter(l *log.Logger, interval time.Duration) *logWriter {
+	return &logWriter{
+		logger:   l,
+		interval: interval,
+	}
+}
+
+func (lw *logWriter) Write(p []byte) (n int, err error) {
+	lw.mu.Lock()
+	defer lw.mu.Unlock()
+
+	now := time.Now()
+	// log if the interval has passed since the last log
+	// this is to avoid bloating the logs
+	if now.Sub(lw.lastLogTime) >= lw.interval {
+		lw.logger.Println(string(p), time.Now())
+		lw.lastLogTime = now
+	}
+	return len(p), nil
+}
+
 // GetBackupCommand returns a wrapper over the kopia backup command
 func GetBackupCommand(path, repoName, password, provider, sourcePath string) (*Command, error) {
 	if repoName == "" {
@@ -103,8 +138,13 @@ func NewBackupExecutor(cmd *Command) Executor {
 
 func (b *backupExecutor) Run() error {
 	b.execCmd = b.cmd.BackupCmd()
-	b.execCmd.Stdout = b.outBuf
-	b.execCmd.Stderr = b.errBuf
+
+	// Create multi-writers to stream output to both buffer and CLI
+	stdoutWriter := io.MultiWriter(b.outBuf, newLogWriter(log.New(os.Stdout, "", 0), commandExecLogInterval))
+	stderrWriter := io.MultiWriter(b.errBuf, newLogWriter(log.New(os.Stderr, "", 0), commandExecLogInterval))
+
+	b.execCmd.Stdout = stdoutWriter
+	b.execCmd.Stderr = stderrWriter
 
 	if err := b.execCmd.Start(); err != nil {
 		b.lastError = err
diff --git a/pkg/kopia/restore.go b/pkg/kopia/restore.go
index 5d53965ef..2150ba22c 100644
--- a/pkg/kopia/restore.go
+++ b/pkg/kopia/restore.go
@@ -3,6 +3,8 @@ package kopia
 import (
 	"bytes"
 	"fmt"
+	"io"
+	"log"
 	"os"
 	"os/exec"
 	"strconv"
@@ -98,8 +100,13 @@ func NewRestoreExecutor(cmd *Command) Executor {
 func (b *restoreExecutor) Run() error {
 
 	b.execCmd = b.cmd.RestoreCmd()
-	b.execCmd.Stdout = b.outBuf
-	b.execCmd.Stderr = b.errBuf
+
+	// Create multi-writers to stream output to both buffer and CLI
+	stdoutWriter := io.MultiWriter(b.outBuf, newLogWriter(log.New(os.Stdout, "", 0), commandExecLogInterval))
+	stderrWriter := io.MultiWriter(b.errBuf, newLogWriter(log.New(os.Stderr, "", 0), commandExecLogInterval))
+
+	b.execCmd.Stdout = stdoutWriter
+	b.execCmd.Stderr = stderrWriter
 
 	if err := b.execCmd.Start(); err != nil {
 		b.lastError = err