Function _run_garbage_collection

ci/runners/docker_runner.py:215–252

Run garbage collection to clean up orphaned containers and old volumes. This is best-effort and non-critical - don't let GC errors block the build. Runs in a subprocess with timeout to prevent hanging.

()

def _run_garbage_collection() -> None:
    """Run garbage collection to clean up orphaned containers and old volumes.

    This is best-effort and non-critical - don't let GC errors block the build.
    Runs in a subprocess with timeout to prevent hanging.
    """
    import concurrent.futures

    def _gc_task() -> tuple[int, int]:
        """Run GC in a separate thread with timeout protection."""
        db = ContainerDatabase()
        orphans = cleanup_orphaned_containers(db)
        old = garbage_collect_platform_containers(
            "unit-tests", max_containers=MAX_CONTAINERS_PER_PROJECT, db=db
        )
        return orphans, old

    try:
        # Run GC with a 30-second timeout to prevent hanging on Docker API errors
        with concurrent.futures.ThreadPoolExecutor(max_workers=1) as executor:
            future = executor.submit(_gc_task)
            try:
                orphans_cleaned, old_cleaned = future.result(timeout=30)
                if orphans_cleaned > 0:
                    ts_print(f"Cleaned up {orphans_cleaned} orphaned container(s)")
                if old_cleaned > 0:
                    ts_print(
                        f"Garbage collected {old_cleaned} old unit-test container(s)"
                    )
            except concurrent.futures.TimeoutError:
                ts_print("Warning: Garbage collection timed out (30s) - skipping")
                future.cancel()
    except KeyboardInterrupt as ki:
        handle_keyboard_interrupt(ki)
        raise
    except Exception as e:
        # Don't fail the build if garbage collection fails
        ts_print(f"Warning: Garbage collection failed: {e}")


def _build_sync_script() -> str: