diff --git a/pkg/storage/kopia/maintenance.go b/pkg/storage/kopia/maintenance.go
index 112f998..12b3ecb 100644
--- a/pkg/storage/kopia/maintenance.go
+++ b/pkg/storage/kopia/maintenance.go
@@ -43,7 +43,7 @@ func RunMaintenance(ctx context.Context, st storage.Storage, safety string) erro
 		Purpose: "datasafed:maintenance",
 	}, func(ctx context.Context, dw repo.DirectRepositoryWriter) error {
 		mode := maintenance.ModeQuick
-		_, supportsEpochManager, err := dw.ContentManager().EpochManager()
+		_, supportsEpochManager, err := dw.ContentManager().EpochManager(ctx)
 		if err != nil {
 			return fmt.Errorf("EpochManager error: %w", err)
 		}
diff --git a/pkg/storage/kopia/repo.go b/pkg/storage/kopia/repo.go
index 1e68803..3dc7488 100644
--- a/pkg/storage/kopia/repo.go
+++ b/pkg/storage/kopia/repo.go
@@ -169,7 +169,7 @@ func setDefaultMaintenanceParameters(ctx context.Context, rep repo.RepositoryWri
 	p.Owner = rep.ClientOptions().UsernameAtHost()
 
 	if dw, ok := rep.(repo.DirectRepositoryWriter); ok {
-		_, ok, err := dw.ContentReader().EpochManager()
+		_, ok, err := dw.ContentReader().EpochManager(ctx)
 		if err != nil {
 			return fmt.Errorf("epoch manager, %w", err)
 		}