diff --git a/src/cmd/services/m3coordinator/downsample/options.go b/src/cmd/services/m3coordinator/downsample/options.go
index a6b05b1fa6..f55e1c4acb 100644
--- a/src/cmd/services/m3coordinator/downsample/options.go
+++ b/src/cmd/services/m3coordinator/downsample/options.go
@@ -103,7 +103,7 @@ var (
 )
 
 // CustomRuleStoreFn is a function to swap the backend used for the rule stores.
-type CustomRuleStoreFn func(clusterclient.Client) (kv.TxnStore, error)
+type CustomRuleStoreFn func(clusterclient.Client, instrument.Options) (kv.TxnStore, error)
 
 // DownsamplerOptions is a set of required downsampler options.
 type DownsamplerOptions struct {
diff --git a/src/query/server/query.go b/src/query/server/query.go
index b8c24c90e8..2f82d7373f 100644
--- a/src/query/server/query.go
+++ b/src/query/server/query.go
@@ -753,7 +753,7 @@ func newDownsampler(
 				"cluster management config client")
 		}
 	} else {
-		kvStore, err = applyCustomRuleStore(clusterManagementClient)
+		kvStore, err = applyCustomRuleStore(clusterManagementClient, instrumentOpts)
 		if err != nil {
 			return nil, errors.Wrap(err, "unable to apply custom rule store")
 		}