Fix unit test failures on CS10 CI image

The test_async_pull_through_add test needed transaction=True because
sync_to_async runs on a thread pool worker with a separate DB connection
that can't see the main thread's uncommitted savepoint data.

Using TransactionTestCase exposed two additional issues:
- The base Repository has CONTENT_TYPES = [], so the task failed with
  "unsupported content types". Patch CONTENT_TYPES on the class so the
  re-fetched repo instance in the task also sees it.
- TransactionTestCase teardown calls flush which emits post_migrate
  signals, but Django's emit_post_migrate_signal doesn't pass the
  `apps` kwarg. Made all four post_migrate handlers accept apps=None
  with a fallback to django.apps.apps.
- After flush, the global default_domain cache is stale (old PK no
  longer in DB). Clear it in _ensure_default_domain so the domain is
  re-created, preventing FK violations in subsequent handlers.

Also mock redis_tasks.async_are_resources_available for runners that
use WORKER_TYPE=redis, where the dispatch path bypasses the postgres
advisory lock code entirely and tries to connect to Redis.

Assisted-By: Claude Opus 4.6

Author: dralley

.github/workflows/scripts/install.sh

@@ -70,6 +70,10 @@ fi
 cmd_prefix bash -c "echo '%wheel        ALL=(ALL)       NOPASSWD: ALL' > /etc/sudoers.d/nopasswd"
 cmd_prefix bash -c "usermod -a -G wheel pulp"
 
+# Workaround: Valkey on CS10 needs runtime directories that systemd-tmpfiles would create.
+# Remove once the CI image is rebuilt with these directories baked in.
+cmd_prefix bash -c "install -d -m 0755 -o valkey -g valkey /run/valkey && install -d -m 0750 -o valkey -g valkey /var/log/valkey && s6-rc -u change redis" || true
+
 # In some scenarios we want to simulate a failed redis cache.
 if [[ " s3 " =~ " ${TEST} " ]]; then
   cmd_prefix bash -c "s6-rc -d change redis"

pulpcore/app/apps.py

@@ -275,7 +275,11 @@ def _clean_app_status(sender, apps, verbosity, **kwargs):
         AppStatus.objects.filter(last_heartbeat__lt=TransactionNow() - F("ttl")).delete()
 
 
-def _populate_access_policies(sender, apps, verbosity, **kwargs):
+def _populate_access_policies(sender, apps=None, verbosity=0, **kwargs):
+    from django.apps import apps as django_apps
+
+    if apps is None:
+        apps = django_apps
     from pulpcore.app.util import get_view_urlpattern
     from pulpcore.app.viewsets import LoginViewSet
 
@@ -319,7 +323,11 @@ def _populate_access_policies(sender, apps, verbosity, **kwargs):
                             )
 
 
-def _populate_system_id(sender, apps, verbosity, **kwargs):
+def _populate_system_id(sender, apps=None, verbosity=0, **kwargs):
+    from django.apps import apps as django_apps
+
+    if apps is None:
+        apps = django_apps
     SystemID = apps.get_model("core", "SystemID")
     if not SystemID.objects.exists():
         SystemID().save()
@@ -328,8 +336,10 @@ def _populate_system_id(sender, apps, verbosity, **kwargs):
 def _ensure_default_domain(sender, **kwargs):
     table_names = connection.introspection.table_names()
     if "core_domain" in table_names:
+        import pulpcore.app.util
         from pulpcore.app.util import get_default_domain
 
+        pulpcore.app.util.default_domain = None
         default = get_default_domain()  # Cache the default domain
         # Match the Pulp settings
         if (
@@ -343,7 +353,11 @@ def _ensure_default_domain(sender, **kwargs):
             default.save(skip_hooks=True)
 
 
-def _populate_roles(sender, apps, verbosity, **kwargs):
+def _populate_roles(sender, apps=None, verbosity=0, **kwargs):
+    from django.apps import apps as django_apps
+
+    if apps is None:
+        apps = django_apps
     role_prefix = f"{sender.label}."
     # collect all plugin defined roles
     desired_roles = {}
@@ -402,7 +416,11 @@ def _get_permission(perm):
         role.permissions.set(permissions)
 
 
-def _populate_artifact_serving_distribution(sender, apps, verbosity, **kwargs):
+def _populate_artifact_serving_distribution(sender, apps=None, verbosity=0, **kwargs):
+    from django.apps import apps as django_apps
+
+    if apps is None:
+        apps = django_apps
     if (
         settings.STORAGES["default"]["BACKEND"] == "pulpcore.app.models.storage.FileSystem"
         or not settings.REDIRECT_TO_OBJECT_STORAGE

pulpcore/tests/unit/content/test_handler.py

@@ -575,15 +575,20 @@ async def test_app_status_fixture_is_reusable(app_status, repeat):
 
 
 @pytest.mark.asyncio
-@pytest.mark.django_db
+@pytest.mark.django_db(transaction=True)
 async def test_async_pull_through_add(ca1, monkeypatch, app_status):
     set_guid(uuid.uuid4())  # required for creating a task, no easily mockable
     monkeypatch.setattr(
         "pulpcore.tasking.tasks.async_are_resources_available", AsyncMock(return_value=True)
     )
     monkeypatch.setattr("pulpcore.tasking.tasks.wakeup_worker", Mock())
+    monkeypatch.setattr(
+        "pulpcore.tasking.redis_tasks.async_are_resources_available",
+        AsyncMock(return_value=True),
+    )
 
     repo = await Repository.objects.acreate(name=str(uuid.uuid4()))
+    monkeypatch.setattr(Repository, "CONTENT_TYPES", [Content])
     try:
         task = await repo.async_pull_through_add_content(ca1)
         assert task.state == TASK_STATES.COMPLETED