diff --git a/connect/resource/fulfillment.py b/connect/resource/fulfillment.py
index 1709bac..fbbfac0 100644
--- a/connect/resource/fulfillment.py
+++ b/connect/resource/fulfillment.py
@@ -22,7 +22,7 @@ class FulfillmentResource(BaseResource):
     def build_filter(self):
         filters = super(FulfillmentResource, self).build_filter()
         if self.config.products:
-            filters['product_id'] = self.config.products
+            filters['asset.product.id__in'] = ','.join(self.config.products)
 
         filters['status'] = 'pending'
         return filters