diff --git a/src/frontend/src/components/rdi/details/households/RegistrationDetails.tsx b/src/frontend/src/components/rdi/details/households/RegistrationDetails.tsx
index c8b8dcc6d1..67af86fa9c 100644
--- a/src/frontend/src/components/rdi/details/households/RegistrationDetails.tsx
+++ b/src/frontend/src/components/rdi/details/households/RegistrationDetails.tsx
@@ -34,7 +34,7 @@ export function RegistrationDetails({
   const { t } = useTranslation();
   const { data } = useRegistrationDataImportQuery({
     variables: {
-      id: btoa(`RegistrationDataImportNode:${hctId}`),
+      id: hctId,
     },
   });
   if (!data) {
diff --git a/src/hct_mis_api/apps/registration_datahub/tasks/rdi_kobo_create.py b/src/hct_mis_api/apps/registration_datahub/tasks/rdi_kobo_create.py
index 0190011404..1c83501b95 100644
--- a/src/hct_mis_api/apps/registration_datahub/tasks/rdi_kobo_create.py
+++ b/src/hct_mis_api/apps/registration_datahub/tasks/rdi_kobo_create.py
@@ -87,6 +87,7 @@ def __init__(
         super().__init__()
 
     def _handle_image_field(self, value: Any, is_flex_field: bool) -> Optional[Union[str, File]]:
+        logger.info(f"Processing image field: {value}")
         if not self.registration_data_import.pull_pictures:
             return None
         if self.attachments is None:
@@ -101,6 +102,7 @@ def _handle_image_field(self, value: Any, is_flex_field: bool) -> Optional[Union
         file = File(image_bytes, name=value)
         if is_flex_field:
             return default_storage.save(value, file)
+        logger.info(f"Image field processed: {value}")
         return file
 
     def _handle_geopoint_field(self, value: Any, is_flex_field: bool) -> Point:
@@ -220,7 +222,11 @@ def execute(
         collectors_to_create = defaultdict(list)
         household_hash_list = []
         household_batch_size = 50
+        logger.info(f"Processing {len(self.reduced_submissions)} households")
+        chunk_index = 0
         for reduced_submission_chunk in chunks(self.reduced_submissions, household_batch_size):
+            chunk_index += 1
+            logger.info(f"Processing chunk {chunk_index}/{len(self.reduced_submissions) // household_batch_size}")
             for household in reduced_submission_chunk:
                 # AB#199540
                 household_hash = calculate_hash_for_kobo_submission(household)