Add the task output in the webhook Slack payload in case of run failure #1587 (#1634)

Signed-off-by: tdruez <tdruez@nexb.com>

Author: tdruez

scanpipe/models.py

@@ -4191,22 +4191,34 @@ def get_slack_payload(pipeline_run):
         pipeline_name = pipeline_run.pipeline_name
         pretext = f"Project *{project_display}* update:"
         text = f"Pipeline `{pipeline_name}` completed with {status}."
+        blocks = [
+            {
+                "type": "section",
+                "text": {
+                    "type": "mrkdwn",
+                    "text": text,
+                },
+            }
+        ]
+
+        # Adds the task output in case of run failure
+        if pipeline_run.status == Run.Status.FAILURE and pipeline_run.task_output:
+            task_output_block = {
+                "type": "section",
+                "text": {
+                    "type": "mrkdwn",
+                    "text": f"```{pipeline_run.task_output}```",
+                },
+            }
+            blocks.append(task_output_block)
 
         return {
             "username": "ScanCode.io",
             "text": pretext,
             "attachments": [
                 {
                     "color": color,
-                    "blocks": [
-                        {
-                            "type": "section",
-                            "text": {
-                                "type": "mrkdwn",
-                                "text": text,
-                            },
-                        }
-                    ],
+                    "blocks": blocks,
                 }
             ],
         }

scanpipe/tests/test_models.py

@@ -2232,6 +2232,17 @@ def test_scanpipe_webhook_subscription_model_get_slack_payload(self):
         payload = WebhookSubscription.get_slack_payload(run1)
         self.assertDictEqual(expected_payload, payload)
 
+        run1.set_task_ended(exitcode=1, output="Exception")
+        self.assertEqual(Run.Status.FAILURE, run1.status)
+        payload = WebhookSubscription.get_slack_payload(run1)
+        payload_blocks = payload["attachments"][0]["blocks"]
+        self.assertEqual(2, len(payload_blocks))
+        expected_task_output_block = {
+            "text": {"text": "```Exception```", "type": "mrkdwn"},
+            "type": "section",
+        }
+        self.assertEqual(expected_task_output_block, payload_blocks[1])
+
     def test_scanpipe_discovered_package_model_extract_purl_data(self):
         package_data = {}
         expected = {