diff --git a/product_management/__init__.py b/product_management/__init__.py
index 904a2d8..f94d924 100644
--- a/product_management/__init__.py
+++ b/product_management/__init__.py
@@ -71,10 +71,10 @@ async def get_category_tree(org_id=None):
     return await manager.get_category_tree(org_id)
 
 
-async def get_products_by_category(category_id, status='1'):
+async def get_products_by_category(category_id, org_id=None, status='1'):
     """Get all products under a category."""
     manager = get_manager()
-    return await manager.get_products_by_category(category_id, status)
+    return await manager.get_products_by_category(category_id, org_id, status)
 
 
 async def import_categories_and_products(resource_module, org_id, parent_category_id, user_id):