diff --git a/commerce_coordinator/apps/commercetools/pipeline.py b/commerce_coordinator/apps/commercetools/pipeline.py
index 8ff30b83..acd65572 100644
--- a/commerce_coordinator/apps/commercetools/pipeline.py
+++ b/commerce_coordinator/apps/commercetools/pipeline.py
@@ -54,7 +54,7 @@ def run_filter(self, request, params, order_data):  # pylint: disable=arguments-
         try:
             ct_api_client = CommercetoolsAPIClient()
             ct_orders = ct_api_client.get_orders_for_customer(
-                customer_id=params.get("customer_id"),
+                customer_id=params["customer_id"],
                 email=params["email"],
                 username=params["username"],
                 edx_lms_user_id=params["edx_lms_user_id"],