diff --git a/specs/ingestion/common/schemas/source.yml b/specs/ingestion/common/schemas/source.yml
index a49e88e783..735376e3d0 100644
--- a/specs/ingestion/common/schemas/source.yml
+++ b/specs/ingestion/common/schemas/source.yml
@@ -135,6 +135,10 @@ SourceCommercetools:
       default: true
       description: |
         Whether a fallback value is stored in the Algolia record if there's no inventory information about the product.
+    productQueryPredicate:
+        type: string
+        description: |
+            Predicate to filter out specific products when indexing. For more information, see [Query Predicate](https://docs.commercetools.com/api/predicates/query).
     customFields:
       $ref: '#/CommercetoolsCustomFields'
   required:
@@ -405,6 +409,10 @@ SourceUpdateCommercetools:
       type: boolean
       description: |
         Whether a fallback value is stored in the Algolia record if there's no inventory information about the product.
+    productQueryPredicate:
+        type: string
+        description: |
+            Predicate to filter out specific products when indexing. For more information, see [Query Predicate](https://docs.commercetools.com/api/predicates/query).
     customFields:
       $ref: '#/CommercetoolsCustomFields'
 
diff --git a/tests/CTS/requests/ingestion/createSource.json b/tests/CTS/requests/ingestion/createSource.json
index ec94ead0b2..be8452047c 100644
--- a/tests/CTS/requests/ingestion/createSource.json
+++ b/tests/CTS/requests/ingestion/createSource.json
@@ -12,7 +12,8 @@
           "de"
         ],
         "url": "http://commercetools.com",
-        "projectKey": "keyID"
+        "projectKey": "keyID",
+        "productQueryPredicate": "masterVariant(attributes(name=\"Brand\" and value=\"Algolia\"))"
       },
       "authenticationID": "6c02aeb1-775e-418e-870b-1faccd4b2c0f"
     },
@@ -30,7 +31,8 @@
             "de"
           ],
           "url": "http://commercetools.com",
-          "projectKey": "keyID"
+          "projectKey": "keyID",
+          "productQueryPredicate": "masterVariant(attributes(name=\"Brand\" and value=\"Algolia\"))"
         },
         "authenticationID": "6c02aeb1-775e-418e-870b-1faccd4b2c0f"
       }