Change content app's working directory dynamically

As of this commit, content app is no longer storing temporary files in the /var/run/ directory. The temporary files were created during on-demand downloading and were not removed until, e.g., restarting pulp services.

closes #9000

CHANGES/9000.bugfix

@@ -0,0 +1 @@
+Fixed a bug where on-demand downloads would fill up ``/var/run/`` by not deleting downloaded files.

pulpcore/content/__init__.py

@@ -55,6 +55,8 @@ def save_heartbeat_blocking():
 
 
 async def server(*args, **kwargs):
+    os.chdir(settings.WORKING_DIRECTORY)
+
     asyncio.ensure_future(_heartbeat())
     for pulp_plugin in pulp_plugin_configs():
         if pulp_plugin.name != "pulpcore.app":

pulpcore/content/handler.py

@@ -720,6 +720,12 @@ def _save_artifact(self, download_result, remote_artifact):
                         **download_result.artifact_attributes, file=download_result.path
                     )
                     artifact.save()
+                else:
+                    # The file needs to be unlinked because it was not used to create an artifact.
+                    # The artifact must have already been saved while servicing another request for
+                    # the same artifact.
+                    os.unlink(download_result.path)
+
             update_content_artifact = True
             if content_artifact._state.adding:
                 # This is the first time pull-through content was requested.

pulpcore/tests/unit/content/test_handler.py

@@ -1,6 +1,7 @@
+import tempfile
+
 from unittest.mock import Mock
 
-from django.core.files.uploadedfile import SimpleUploadedFile
 from django.test import TestCase
 
 from pulpcore.content import Handler
@@ -20,28 +21,29 @@ def setUp(self):
         )
         self.ra2 = Mock(content_artifact=self.ca2)
 
-    def download_result_mock(self, path):
+    def download_result_mock(self):
         dr = Mock()
         dr.artifact_attributes = {"size": 0}
         for digest_type in Artifact.DIGEST_FIELDS:
             dr.artifact_attributes[digest_type] = "abc123"
-        dr.path = SimpleUploadedFile(name=path, content="")
+        tmp_file = tempfile.NamedTemporaryFile(delete=False)
+        dr.path = tmp_file.name
         return dr
 
     def test_save_artifact(self):
         """Artifact needs to be created."""
         cch = Handler()
-        new_artifact = cch._save_artifact(self.download_result_mock("c1"), self.ra1)
+        new_artifact = cch._save_artifact(self.download_result_mock(), self.ra1)
         c1 = Content.objects.get(pk=self.c1.pk)
         self.assertIsNotNone(new_artifact)
         self.assertEqual(c1._artifacts.get().pk, new_artifact.pk)
 
     def test_save_artifact_artifact_already_exists(self):
         """Artifact turns out to already exist."""
         cch = Handler()
-        new_artifact = cch._save_artifact(self.download_result_mock("c1"), self.ra1)
+        new_artifact = cch._save_artifact(self.download_result_mock(), self.ra1)
 
-        existing_artifact = cch._save_artifact(self.download_result_mock("c2"), self.ra2)
+        existing_artifact = cch._save_artifact(self.download_result_mock(), self.ra2)
         c2 = Content.objects.get(pk=self.c2.pk)
         self.assertEqual(existing_artifact.pk, new_artifact.pk)
         self.assertEqual(c2._artifacts.get().pk, existing_artifact.pk)