diff --git a/lib/puppet/indirector/resource/redis.rb b/lib/puppet/indirector/resource/redis.rb
index a27fdd6..f38cb15 100644
--- a/lib/puppet/indirector/resource/redis.rb
+++ b/lib/puppet/indirector/resource/redis.rb
@@ -31,7 +31,9 @@ class Puppet::Resource::Redis < Puppet::Indirector::REST
     #
     key = "catalog_#{host}_#{environment}"
     resources = []
-    keys = redis.keys("catalog_*_#{environment}")
+    # With puppetdb, resources are picked up regardless of environment,
+    # and the user may choose to filter or not in the collector.
+    keys = redis.keys("catalog_*")
     keys.each do |k|
       next if k == key
       catalog = JSON.parse(redis.get(k))