diff --git a/go/vt/vtorc/logic/keyspace_shard_discovery.go b/go/vt/vtorc/logic/keyspace_shard_discovery.go index 4473e993c37..cff5b9fa2ac 100644 --- a/go/vt/vtorc/logic/keyspace_shard_discovery.go +++ b/go/vt/vtorc/logic/keyspace_shard_discovery.go @@ -166,7 +166,7 @@ func refreshAllShards(ctx context.Context, keyspaceName string) error { return err } } - return inst.DeleteStaleKeyspaceShards(keyspace, beginSaveTime) + return inst.DeleteStaleKeyspaceShards(keyspaceName, beginSaveTime) } // refreshSingleShardHelper is a helper function that refreshes the shard record of the given keyspace/shard.