Add more logging to files processing

Author: marcoacierno

backend/pycon/tasks.py

@@ -52,7 +52,7 @@ def launch_heavy_processing_worker():
                 "name": "storage",
                 "managedEBSVolume": {
                     "encrypted": False,
-                    "sizeInGiB": 1_500,
+                    "sizeInGiB": 500,
                     "volumeType": "gp3",
                     "terminationPolicy": {"deleteOnTermination": True},
                     "filesystemType": "xfs",

backend/pycon/tests/test_tasks.py

@@ -68,7 +68,7 @@ def test_launch_heavy_processing_worker_starts_task(settings, mocker):
                 "name": "storage",
                 "managedEBSVolume": {
                     "encrypted": False,
-                    "sizeInGiB": 1_500,
+                    "sizeInGiB": 500,
                     "volumeType": "gp3",
                     "terminationPolicy": {"deleteOnTermination": True},
                     "filesystemType": "xfs",

backend/video_uploads/transfer.py

@@ -205,20 +205,21 @@ def download_part(self, part_info: PartInfo) -> str:
                     f"Failed to download part {str(part_info)} for wetransfer_to_s3_transfer_request {self.wetransfer_to_s3_transfer_request.id}"
                 )
 
-            logger.info(
-                "Downloading part %s for wetransfer_to_s3_transfer_request %s. Attempt = %s",
-                str(part_info),
-                self.wetransfer_to_s3_transfer_request.id,
-                attempts,
-            )
-
             part_file = tempfile.NamedTemporaryFile(
                 "wb",
                 prefix=f"wetransfer_{self.wetransfer_to_s3_transfer_request.id}.part{part_info.part_number}",
                 suffix=self.extension,
                 delete=False,
             )
 
+            logger.info(
+                "Downloading part %s for wetransfer_to_s3_transfer_request %s. Destination = %s. Attempt = %s",
+                str(part_info),
+                self.wetransfer_to_s3_transfer_request.id,
+                part_file.name,
+                attempts,
+            )
+
             with requests.get(
                 self.download_link, headers=part_info.http_range_header, stream=True
             ) as response: