✨(backend) revert default transcoding pipeline from Peertube to AWS

As the BBB VODs are fetched and processed by a Lambda, some deeper changes need
to be done to change the default transcoding pipeline from AWS to Peertube.
Reverting the changes so the default pipeline for VODs is AWS.

Author: wilbrdt

CHANGELOG.md

@@ -16,7 +16,6 @@ Versioning](https://semver.org/spec/v2.0.0.html).
 
 - Increase connection timeout on Nginx for peertube runner success request
 - Allow disabling Cloudfront signed URLs
-- Use Peertube pipeline by default for BBB VOD transcoding
 
 ## [5.5.3] - 2025-01-09
 

src/backend/marsha/bbb/api.py

@@ -763,7 +763,7 @@ def create_vod(self, request, pk=None, classroom_id=None):
         classroom_recording.vod = Video.objects.create(
             title=request.data.get("title"),
             playlist=classroom_recording.classroom.playlist,
-            transcode_pipeline=defaults.PEERTUBE_PIPELINE,
+            transcode_pipeline=defaults.AWS_PIPELINE,
         )
         classroom_recording.save()
 

src/backend/marsha/bbb/tests/api/classroom/recordings/test_create_vod.py

@@ -163,12 +163,12 @@ def test_api_classroom_recording_create_vod_instructor_or_admin(self):
             status=200,
         )
 
-        with (
-            mock.patch(
-                "marsha.bbb.api.invoke_lambda_convert"
-            ) as mock_invoke_lambda_convert,
-            mock.patch.object(timezone, "now", return_value=now),
-            self.assertNumQueries(9),
+        with mock.patch(
+            "marsha.bbb.api.invoke_lambda_convert"
+        ) as mock_invoke_lambda_convert, mock.patch.object(
+            timezone, "now", return_value=now
+        ), self.assertNumQueries(
+            9
         ):
             response = self.client.post(
                 f"/api/classrooms/{recording.classroom.id}/recordings/{recording.id}/create-vod/",
@@ -177,7 +177,7 @@ def test_api_classroom_recording_create_vod_instructor_or_admin(self):
             )
 
         self.assertEqual(Video.objects.count(), 1)
-        self.assertEqual(Video.objects.first().transcode_pipeline, "peertube")
+        self.assertEqual(Video.objects.first().transcode_pipeline, "AWS")
         self.assertEqual(response.status_code, 201)
 
         recording.refresh_from_db()
@@ -225,10 +225,9 @@ def test_api_classroom_recording_create_vod_instructor_or_admin_unknown_recordin
 
         now = timezone.now()
 
-        with (
-            mock.patch.object(timezone, "now", return_value=now),
-            self.assertNumQueries(1),
-        ):
+        with mock.patch.object(
+            timezone, "now", return_value=now
+        ), self.assertNumQueries(1):
             response = self.client.post(
                 f"/api/classrooms/{recording.classroom.id}"
                 f"/recordings/{recording.classroom.id}/create-vod/",
@@ -332,7 +331,7 @@ def test_api_classroom_recording_create_vod_user_access_token_organization_admin
 
         self.assertEqual(response.status_code, 201)
         self.assertEqual(Video.objects.count(), 1)
-        self.assertEqual(Video.objects.first().transcode_pipeline, "peertube")
+        self.assertEqual(Video.objects.first().transcode_pipeline, "AWS")
 
     @responses.activate
     def test_api_classroom_recording_create_vod_from_standalone_site_no_consumer_site(
@@ -411,7 +410,7 @@ def test_api_classroom_recording_create_vod_from_standalone_site_no_consumer_sit
 
         self.assertEqual(response.status_code, 201)
         self.assertEqual(Video.objects.count(), 1)
-        self.assertEqual(Video.objects.first().transcode_pipeline, "peertube")
+        self.assertEqual(Video.objects.first().transcode_pipeline, "AWS")
 
     def test_api_classroom_recording_create_vod_from_standalone_site_inactive_conversion(
         self,
@@ -511,7 +510,7 @@ def test_api_classroom_recording_create_vod_user_access_token_playlist_admin(
 
         self.assertEqual(response.status_code, 201)
         self.assertEqual(Video.objects.count(), 1)
-        self.assertEqual(Video.objects.first().transcode_pipeline, "peertube")
+        self.assertEqual(Video.objects.first().transcode_pipeline, "AWS")
 
     @responses.activate
     def test_api_classroom_recording_create_vod_user_access_token_playlist_instructor(
@@ -585,7 +584,7 @@ def test_api_classroom_recording_create_vod_user_access_token_playlist_instructo
 
         self.assertEqual(response.status_code, 201)
         self.assertEqual(Video.objects.count(), 1)
-        self.assertEqual(Video.objects.first().transcode_pipeline, "peertube")
+        self.assertEqual(Video.objects.first().transcode_pipeline, "AWS")
 
     def test_api_classroom_recording_create_vod_user_access_token_playlist_student(
         self,
@@ -667,12 +666,12 @@ def test_api_classroom_recording_create_vod_instructor_or_admin_inactive_convers
 
         now = timezone.now()
 
-        with (
-            mock.patch(
-                "marsha.bbb.api.invoke_lambda_convert"
-            ) as mock_invoke_lambda_convert,
-            mock.patch.object(timezone, "now", return_value=now),
-            self.assertNumQueries(1),
+        with mock.patch(
+            "marsha.bbb.api.invoke_lambda_convert"
+        ) as mock_invoke_lambda_convert, mock.patch.object(
+            timezone, "now", return_value=now
+        ), self.assertNumQueries(
+            1
         ):
             response = self.client.post(
                 f"/api/classrooms/{recording.classroom.id}/recordings/{recording.id}/create-vod/",