tmp

Author: jobselko

pulp_python/app/migrations/0019_create_missing_metadata_artifacts.py

@@ -155,12 +155,12 @@ def create_missing_metadata_artifacts(apps, schema_editor):
         PythonPackageContent.objects.filter(metadata_sha256__isnull=False)
         .exclude(metadata_sha256="")
         .prefetch_related("contentartifact_set")
+        .only("filename", "metadata_sha256")
     )
     # todo: only for testing, remove later
     created_count = 0
     skipped_count = 0
 
-    # todo: do i need temp dir? (not needed in localhost)
     with tempfile.TemporaryDirectory(dir=settings.WORKING_DIRECTORY) as temp_dir:
         for package in packages:
             metadata_relative_path = f"{package.filename}.metadata"
@@ -195,7 +195,7 @@ def create_missing_metadata_artifacts(apps, schema_editor):
                 )
                 created_count += 1
             except Exception:
-                # Failed to save metadata artifact
+                # Failed to save metadata content artifact
                 skipped_count += 1
 
     print(f"Created {created_count} missing metadata artifacts. Skipped {skipped_count} packages.")

pulp_python/app/tasks/sync.py

@@ -255,6 +255,7 @@ async def create_content(self, pkg):
                     if upstream_pkg.has_metadata:
                         url = upstream_pkg.metadata_url
                         md_sha256 = upstream_pkg.metadata_digests.get("sha256")
+                        package.metadata_sha256 = md_sha256
                         artifact = Artifact(sha256=md_sha256)
 
                         metadata_artifact = DeclarativeArtifact(

pulp_python/app/utils.py

@@ -303,10 +303,11 @@ def artifact_to_metadata_artifact(
         return metadata_artifact
 
     finally:
-        if temp_wheel_path and os.path.exists(temp_wheel_path):
-            os.unlink(temp_wheel_path)
-        if temp_metadata_path and os.path.exists(temp_metadata_path):
-            os.unlink(temp_metadata_path)
+        pass
+    #     if temp_wheel_path and os.path.exists(temp_wheel_path):
+    #         os.unlink(temp_wheel_path)
+    #     if temp_metadata_path and os.path.exists(temp_metadata_path):
+    #         os.unlink(temp_metadata_path)
 
 
 def fetch_json_release_metadata(name: str, version: str, remotes: set[Remote]) -> dict: