diff --git a/backend/onboarders/factory.py b/backend/onboarders/factory.py
index 13dd5505..2ff7dcbc 100644
--- a/backend/onboarders/factory.py
+++ b/backend/onboarders/factory.py
@@ -3,8 +3,8 @@ from onboarders.parity import ParityOnboarder
 
 class OnboarderFactory:
     @staticmethod
-    def create_onboarder(onboarder_type):
+    def create_onboarder(onboarder_type, **kwargs):
         if onboarder_type == "parity":
-            return ParityOnboarder
+            return ParityOnboarder(**kwargs)
 
         raise ValueError(f"Unknown onboarder type: {onboarder_type}")
diff --git a/backend/onboarders/handler.py b/backend/onboarders/handler.py
index 91ec11d2..d66b5796 100644
--- a/backend/onboarders/handler.py
+++ b/backend/onboarders/handler.py
@@ -33,8 +33,8 @@ def handler(event, context):
             logger.info("Processing record with body: %s", event_body)
 
             validated_event = OnboardingEvent(**event_body)
-            Onboarder = OnboarderFactory.create_onboarder(validated_event.system)
-            onboarder = Onboarder(
+            onboarder = OnboarderFactory.create_onboarder(
+                validated_event.system,
                 fileuri=validated_event.s3_uri,
                 format=validated_event.format,
                 sheet_name=validated_event.sheet_name,