feat: added patches + updated model for bulk email skip/failure details

Author: eemaanamir

lms/djangoapps/instructor_task/migrations/0007_alter_instructortask_task_output.py

@@ -0,0 +1,18 @@
+# Generated by Django 4.2.20 on 2025-10-17 15:37
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('instructor_task', '0006_alter_historicalinstructortaskschedule_options'),
+    ]
+
+    operations = [
+        migrations.AlterField(
+            model_name='instructortask',
+            name='task_output',
+            field=models.TextField(null=True),
+        ),
+    ]

lms/djangoapps/instructor_task/models.py

@@ -76,7 +76,7 @@ class Meta:
     task_input = models.TextField()
     task_id = models.CharField(max_length=255, db_index=True)  # max_length from celery_taskmeta
     task_state = models.CharField(max_length=50, null=True, db_index=True)  # max_length from celery_taskmeta
-    task_output = models.CharField(max_length=1024, null=True)
+    task_output = models.TextField(null=True)
     requester = models.ForeignKey(User, db_index=True, on_delete=models.CASCADE)
     created = models.DateTimeField(auto_now_add=True, null=True)
     updated = models.DateTimeField(auto_now=True)

lms/djangoapps/instructor_task/subtasks.py

@@ -17,6 +17,7 @@
 
 
 from common.djangoapps.util.db import outer_atomic
+from openedx_wikilearn_features.wikimedia_general.djangoapps_patches.instructor_task.utils import update_task_dict
 
 from .exceptions import DuplicateTaskException
 from .models import PROGRESS, QUEUING, InstructorTask
@@ -249,7 +250,7 @@ def initialize_subtask_info(entry, action_name, total_num, subtask_id_list):
         'duration_ms': int(0),
         'start_time': time()
     }
-    entry.task_output = InstructorTask.create_output_for_success(task_progress)
+    entry.task_output = InstructorTask.create_output_for_success(update_task_dict(task_progress))
     entry.task_state = PROGRESS
 
     # Write out the subtasks information.
@@ -263,7 +264,7 @@ def initialize_subtask_info(entry, action_name, total_num, subtask_id_list):
         'failed': 0,
         'status': subtask_status
     }
-    entry.subtasks = json.dumps(subtask_dict)
+    entry.subtasks = json.dumps(update_task_dict(subtask_dict))
 
     # and save the entry immediately, before any subtasks actually start work:
     entry.save_now()
@@ -549,7 +550,7 @@ def _update_subtask_status(entry_id, current_task_id, new_subtask_status):
         # retry.
         new_state = new_subtask_status.state
         if new_subtask_status is not None and new_state in READY_STATES:
-            for statname in ['attempted', 'succeeded', 'failed', 'skipped']:
+            for statname in ['attempted', 'succeeded', 'failed', 'skipped','skip_details', 'failure_details']:
                 task_progress[statname] += getattr(new_subtask_status, statname)
 
         # Figure out if we're actually done (i.e. this is the last task to complete).

lms/djangoapps/instructor_task/views.py

@@ -9,6 +9,7 @@
 
 from lms.djangoapps.instructor_task.api_helper import get_status_from_instructor_task, get_updated_instructor_task
 from lms.djangoapps.instructor_task.models import PROGRESS
+from openedx_wikilearn_features.wikimedia_general.djangoapps_patches.instructor_task.utils import get_detailed_message
 
 log = logging.getLogger(__name__)
 
@@ -228,5 +229,5 @@ def get_task_completion_info(instructor_task):  # lint-amnesty, pylint: disable=
         total=num_total,
         skipped=num_skipped,
         student=student
-    )
+    ) + "\n" + get_detailed_message(task_output)
     return (succeeded, message)