Saving analysis and migrating from logs

Author: snyaggarwal

core/map_projects/migrations/0029_mapproject_analysis.py

@@ -0,0 +1,18 @@
+# Generated by Django 4.2.16 on 2026-02-21 02:48
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('map_projects', '0028_auto_20260211_1447'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='mapproject',
+            name='analysis',
+            field=models.JSONField(blank=True, default=dict, null=True),
+        ),
+    ]

core/map_projects/migrations/0030_auto_20260221_0250.py

@@ -0,0 +1,33 @@
+# Generated by Django 4.2.16 on 2026-02-21 02:50
+
+from django.db import migrations
+from pydash import get
+
+
+def populate_analysis_from_row_logs(apps, schema_editor):
+    MapProject = apps.get_model('map_projects', 'MapProject')
+    for map_project in MapProject.objects.all():
+        analysis = {}
+        if map_project.logs and not map_project.analysis:
+            for row_id, logs in map_project.logs.get('row_logs', {}).items():
+                ai_log = next((log for log in sorted(logs, key=lambda log: log.get('created_at', ''), reverse=True) if get(log, 'action') == 'AIRecommendation'), False)
+                if ai_log and not get(ai_log, 'extras.error'):
+                    response = get(ai_log, 'extras')
+                    response['model'] = get(response, 'model.id') or 'anthropic/claude-haiku-4.5'
+                    response['timestamp'] = get(ai_log, 'created_at')
+                    response['user'] = get(ai_log, 'user')
+                    analysis[row_id] = response
+            if analysis:
+                map_project.analysis = analysis
+                map_project.save(update_fields=['analysis'])
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('map_projects', '0029_mapproject_analysis'),
+    ]
+
+    operations = [
+        migrations.RunPython(populate_analysis_from_row_logs),
+    ]

core/map_projects/models.py

@@ -37,6 +37,7 @@ class MapProject(BaseModel):
     filters = models.JSONField(default=dict, null=True, blank=True)
     candidates = models.JSONField(default=dict, null=True, blank=True)
     lookup_config = models.JSONField(default=dict, null=True, blank=True)
+    analysis = models.JSONField(default=dict, null=True, blank=True)
 
     class Meta:
         db_table = 'map_projects'
@@ -159,13 +160,14 @@ def _delete_uploaded_file(file_path):
     def format_request_data(cls, data, parent_resource=None):
         new_data = {
             key: val[0] if isinstance(val, list) and len(val) == 1 and key not in [
-                'candidates'] else val for key, val in data.items()
+                'candidates', 'analysis'] else val for key, val in data.items()
         }
         cls.format_json(new_data, 'matches')
         cls.format_json(new_data, 'columns')
         cls.format_json(new_data, 'score_configuration')
         cls.format_json(new_data, 'filters')
         cls.format_json(new_data, 'candidates')
+        cls.format_json(new_data, 'analysis')
         cls.format_json(new_data, 'algorithms')
         cls.format_json(new_data, 'lookup_config')
 

core/map_projects/serializers.py

@@ -22,7 +22,7 @@ class Meta:
             'created_by', 'updated_by', 'created_at', 'updated_at', 'url', 'is_active',
             'public_access', 'file', 'user_id', 'organization_id', 'description',
             'target_repo_url', 'include_retired', 'score_configuration',
-            'filters', 'candidates', 'algorithms', 'lookup_config'
+            'filters', 'candidates', 'algorithms', 'lookup_config', 'analysis'
         ]
 
     def prepare_object(self, validated_data, instance=None, file=None):
@@ -36,7 +36,7 @@ def prepare_object(self, validated_data, instance=None, file=None):
             instance.columns = columns
         for attr in [
             'name', 'description', 'extras', 'target_repo_url', 'include_retired',
-            'score_configuration', 'filters', 'candidates', 'algorithms', 'lookup_config'
+            'score_configuration', 'filters', 'candidates', 'algorithms', 'lookup_config', 'analysis'
         ]:
             setattr(instance, attr, validated_data.get(attr, get(instance, attr)))
         if not instance.id:
@@ -109,7 +109,7 @@ class Meta:
             'created_by', 'updated_by', 'created_at', 'updated_at', 'url', 'is_active',
             'owner', 'owner_type', 'owner_url', 'public_access',
             'target_repo_url', 'summary', 'logs', 'include_retired',
-            'score_configuration', 'filters', 'candidates', 'algorithms', 'lookup_config'
+            'score_configuration', 'filters', 'candidates', 'algorithms', 'lookup_config', 'analysis'
         ]
 
     def __init__(self, *args, **kwargs):