diff --git a/backend/hct_mis_api/apps/core/kobo/common.py b/backend/hct_mis_api/apps/core/kobo/common.py
index 5029669d14..79255189f9 100644
--- a/backend/hct_mis_api/apps/core/kobo/common.py
+++ b/backend/hct_mis_api/apps/core/kobo/common.py
@@ -111,12 +111,6 @@ def count_population(results: list, business_area: BusinessArea) -> tuple[int, i
     return total_households_count, total_individuals_count
 
 
-def filter_by_owner(data: List, kobo_username: str) -> List:
-    if data:
-        return [element for element in data if element["owner__username"] == kobo_username]
-    return []
-
-
 def get_submission_metadata(household_data_dict: Dict) -> Dict:
     meta_fields_mapping = {
         "_uuid": "kobo_submission_uuid",
diff --git a/backend/hct_mis_api/apps/registration_datahub/tests/test_pull_kobo_submissions.py b/backend/hct_mis_api/apps/registration_datahub/tests/test_pull_kobo_submissions.py
index fc12f8817b..90edb8568c 100644
--- a/backend/hct_mis_api/apps/registration_datahub/tests/test_pull_kobo_submissions.py
+++ b/backend/hct_mis_api/apps/registration_datahub/tests/test_pull_kobo_submissions.py
@@ -8,7 +8,8 @@
 import pytest
 
 from hct_mis_api.apps.core.fixtures import create_afghanistan
-from hct_mis_api.apps.registration_datahub.models import KoboImportData
+from hct_mis_api.apps.program.fixtures import ProgramFactory
+from hct_mis_api.apps.registration_data.models import KoboImportData
 from hct_mis_api.apps.registration_datahub.tasks.pull_kobo_submissions import (
     PullKoboSubmissions,
 )
@@ -32,6 +33,7 @@ def test_pull_kobo_submissions(self) -> None:
             only_active_submissions=False,
         )
         kobo_import_data.save()
+        program = ProgramFactory()
 
         content = Path(
             f"{settings.PROJECT_ROOT}/apps/registration_datahub/tests/test_file/kobo_submissions_collectors.json"
@@ -42,7 +44,7 @@ def test_pull_kobo_submissions(self) -> None:
             return_value=content,
         ):
             service = PullKoboSubmissions()
-            result = service.execute(kobo_import_data)
+            result = service.execute(kobo_import_data, program)
 
         kobo_import_data.refresh_from_db()
         assert kobo_import_data.id == result["kobo_import_data_id"]