Fix homepage processor

kolzchut · May 23, 2024 · 11cb642 · 11cb642
1 parent a707c7c
commit 11cb642
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/operators/presets/__init__.py b/operators/presets/__init__.py
@@ -43,6 +43,8 @@ def operator(*args):
         enumerate_rows(),
         DF.set_primary_key(['id']),
         DF.select_fields(['id', 'group', 'title', 'situation_id', 'response_id', 'score']),
+        DF.set_type('situation_id', type='string', transform=lambda v: v[0] if v else None),
+        DF.set_type('response_id', type='string', transform=lambda v: v[0] if v else None),
         dump_to_es_and_delete(
             indexes=dict(srm__homepage=[dict(resource_name='homepage')]),
         ),