setup.py 37.2 KB
Newer Older
1
# SPDX-License-Identifier: Apache-2.0
2
# SPDX-FileCopyrightText: Copyright contributors to the vLLM project
3

4
import ctypes
5
import importlib.util
6
import json
7
import logging
8
import os
9
import re
10
import shutil
11
import subprocess
bnellnm's avatar
bnellnm committed
12
import sys
13
import sysconfig
14
from pathlib import Path
15
from shutil import which
16

Woosuk Kwon's avatar
Woosuk Kwon committed
17
import torch
18
from packaging.version import Version, parse
19
from setuptools import Extension, setup
20
from setuptools.command.build_ext import build_ext
21
from setuptools_scm import get_version
22
from torch.utils.cpp_extension import CUDA_HOME, ROCM_HOME
23

24
25
26
27
28
29
30
31
32

def load_module_from_path(module_name, path):
    spec = importlib.util.spec_from_file_location(module_name, path)
    module = importlib.util.module_from_spec(spec)
    sys.modules[module_name] = module
    spec.loader.exec_module(module)
    return module


33
ROOT_DIR = Path(__file__).parent
34
logger = logging.getLogger(__name__)
35
36
37

# cannot import envs directly because it depends on vllm,
#  which is not installed yet
38
envs = load_module_from_path("envs", os.path.join(ROOT_DIR, "vllm", "envs.py"))
39
40

VLLM_TARGET_DEVICE = envs.VLLM_TARGET_DEVICE
41

42
if sys.platform.startswith("darwin") and VLLM_TARGET_DEVICE != "cpu":
43
    logger.warning("VLLM_TARGET_DEVICE automatically set to `cpu` due to macOS")
44
    VLLM_TARGET_DEVICE = "cpu"
45
elif not (sys.platform.startswith("linux") or sys.platform.startswith("darwin")):
46
47
    logger.warning(
        "vLLM only supports Linux platform (including WSL) and MacOS."
48
        "Building on %s, "
49
50
51
        "so vLLM may not be able to run correctly",
        sys.platform,
    )
52
    VLLM_TARGET_DEVICE = "empty"
53
54
55
56
57
58
59
60
61
elif sys.platform.startswith("linux") and os.getenv("VLLM_TARGET_DEVICE") is None:
    if torch.version.hip is not None:
        VLLM_TARGET_DEVICE = "rocm"
        logger.info("Auto-detected ROCm")
    elif torch.version.cuda is not None:
        VLLM_TARGET_DEVICE = "cuda"
        logger.info("Auto-detected CUDA")
    else:
        VLLM_TARGET_DEVICE = "cpu"
62

bnellnm's avatar
bnellnm committed
63
64

def is_sccache_available() -> bool:
65
66
67
    return which("sccache") is not None and not bool(
        int(os.getenv("VLLM_DISABLE_SCCACHE", "0"))
    )
bnellnm's avatar
bnellnm committed
68
69
70
71
72
73
74
75
76
77


def is_ccache_available() -> bool:
    return which("ccache") is not None


def is_ninja_available() -> bool:
    return which("ninja") is not None


78
79
80
81
def is_freethreaded():
    return bool(sysconfig.get_config_var("Py_GIL_DISABLED"))


bnellnm's avatar
bnellnm committed
82
class CMakeExtension(Extension):
83
    def __init__(self, name: str, cmake_lists_dir: str = ".", **kwa) -> None:
84
        super().__init__(name, sources=[], py_limited_api=not is_freethreaded(), **kwa)
bnellnm's avatar
bnellnm committed
85
86
87
88
89
        self.cmake_lists_dir = os.path.abspath(cmake_lists_dir)


class cmake_build_ext(build_ext):
    # A dict of extension directories that have been configured.
90
    did_config: dict[str, bool] = {}
bnellnm's avatar
bnellnm committed
91
92
93
94
95

    #
    # Determine number of compilation jobs and optionally nvcc compile threads.
    #
    def compute_num_jobs(self):
96
97
        # `num_jobs` is either the value of the MAX_JOBS environment variable
        # (if defined) or the number of CPUs available.
98
        num_jobs = envs.MAX_JOBS
99
100
        if num_jobs is not None:
            num_jobs = int(num_jobs)
101
            logger.info("Using MAX_JOBS=%d as the number of jobs.", num_jobs)
102
103
104
105
106
107
108
        else:
            try:
                # os.sched_getaffinity() isn't universally available, so fall
                #  back to os.cpu_count() if we get an error here.
                num_jobs = len(os.sched_getaffinity(0))
            except AttributeError:
                num_jobs = os.cpu_count()
bnellnm's avatar
bnellnm committed
109

110
        nvcc_threads = None
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
        if _is_cuda() and CUDA_HOME is not None:
            try:
                nvcc_version = get_nvcc_cuda_version()
                if nvcc_version >= Version("11.2"):
                    # `nvcc_threads` is either the value of the NVCC_THREADS
                    # environment variable (if defined) or 1.
                    # when it is set, we reduce `num_jobs` to avoid
                    # overloading the system.
                    nvcc_threads = envs.NVCC_THREADS
                    if nvcc_threads is not None:
                        nvcc_threads = int(nvcc_threads)
                        logger.info(
                            "Using NVCC_THREADS=%d as the number of nvcc threads.",
                            nvcc_threads,
                        )
                    else:
                        nvcc_threads = 1
                    num_jobs = max(1, num_jobs // nvcc_threads)
            except Exception as e:
                logger.warning("Failed to get NVCC version: %s", e)
bnellnm's avatar
bnellnm committed
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147

        return num_jobs, nvcc_threads

    #
    # Perform cmake configuration for a single extension.
    #
    def configure(self, ext: CMakeExtension) -> None:
        # If we've already configured using the CMakeLists.txt for
        # this extension, exit early.
        if ext.cmake_lists_dir in cmake_build_ext.did_config:
            return

        cmake_build_ext.did_config[ext.cmake_lists_dir] = True

        # Select the build type.
        # Note: optimization level + debug info are set by the build type
        default_cfg = "Debug" if self.debug else "RelWithDebInfo"
148
        cfg = envs.CMAKE_BUILD_TYPE or default_cfg
bnellnm's avatar
bnellnm committed
149
150

        cmake_args = [
151
152
            "-DCMAKE_BUILD_TYPE={}".format(cfg),
            "-DVLLM_TARGET_DEVICE={}".format(VLLM_TARGET_DEVICE),
bnellnm's avatar
bnellnm committed
153
154
        ]

155
        verbose = envs.VERBOSE
bnellnm's avatar
bnellnm committed
156
        if verbose:
157
            cmake_args += ["-DCMAKE_VERBOSE_MAKEFILE=ON"]
bnellnm's avatar
bnellnm committed
158
159
160

        if is_sccache_available():
            cmake_args += [
161
162
163
164
                "-DCMAKE_C_COMPILER_LAUNCHER=sccache",
                "-DCMAKE_CXX_COMPILER_LAUNCHER=sccache",
                "-DCMAKE_CUDA_COMPILER_LAUNCHER=sccache",
                "-DCMAKE_HIP_COMPILER_LAUNCHER=sccache",
bnellnm's avatar
bnellnm committed
165
166
167
            ]
        elif is_ccache_available():
            cmake_args += [
168
169
170
171
                "-DCMAKE_C_COMPILER_LAUNCHER=ccache",
                "-DCMAKE_CXX_COMPILER_LAUNCHER=ccache",
                "-DCMAKE_CUDA_COMPILER_LAUNCHER=ccache",
                "-DCMAKE_HIP_COMPILER_LAUNCHER=ccache",
bnellnm's avatar
bnellnm committed
172
173
174
175
            ]

        # Pass the python executable to cmake so it can find an exact
        # match.
176
        cmake_args += ["-DVLLM_PYTHON_EXECUTABLE={}".format(sys.executable)]
bnellnm's avatar
bnellnm committed
177

178
179
        # Pass the python path to cmake so it can reuse the build dependencies
        # on subsequent calls to python.
180
        cmake_args += ["-DVLLM_PYTHON_PATH={}".format(":".join(sys.path))]
181

182
183
184
185
186
187
        # Override the base directory for FetchContent downloads to $ROOT/.deps
        # This allows sharing dependencies between profiles,
        # and plays more nicely with sccache.
        # To override this, set the FETCHCONTENT_BASE_DIR environment variable.
        fc_base_dir = os.path.join(ROOT_DIR, ".deps")
        fc_base_dir = os.environ.get("FETCHCONTENT_BASE_DIR", fc_base_dir)
188
        cmake_args += ["-DFETCHCONTENT_BASE_DIR={}".format(fc_base_dir)]
189

bnellnm's avatar
bnellnm committed
190
191
192
193
194
195
        #
        # Setup parallelism and build tool
        #
        num_jobs, nvcc_threads = self.compute_num_jobs()

        if nvcc_threads:
196
            cmake_args += ["-DNVCC_THREADS={}".format(nvcc_threads)]
bnellnm's avatar
bnellnm committed
197
198

        if is_ninja_available():
199
            build_tool = ["-G", "Ninja"]
bnellnm's avatar
bnellnm committed
200
            cmake_args += [
201
202
                "-DCMAKE_JOB_POOL_COMPILE:STRING=compile",
                "-DCMAKE_JOB_POOLS:STRING=compile={}".format(num_jobs),
bnellnm's avatar
bnellnm committed
203
204
205
206
            ]
        else:
            # Default build tool to whatever cmake picks.
            build_tool = []
207
        # Make sure we use the nvcc from CUDA_HOME
208
        if _is_cuda() and CUDA_HOME is not None:
209
            cmake_args += [f"-DCMAKE_CUDA_COMPILER={CUDA_HOME}/bin/nvcc"]
210
        elif _is_hip() and ROCM_HOME is not None:
211
            cmake_args += [f"-DROCM_PATH={ROCM_HOME}"]
212
213
214
215
216

        other_cmake_args = os.environ.get("CMAKE_ARGS")
        if other_cmake_args:
            cmake_args += other_cmake_args.split()

bnellnm's avatar
bnellnm committed
217
        subprocess.check_call(
218
219
220
            ["cmake", ext.cmake_lists_dir, *build_tool, *cmake_args],
            cwd=self.build_temp,
        )
bnellnm's avatar
bnellnm committed
221
222
223
224

    def build_extensions(self) -> None:
        # Ensure that CMake is present and working
        try:
225
            subprocess.check_output(["cmake", "--version"])
bnellnm's avatar
bnellnm committed
226
        except OSError as e:
227
            raise RuntimeError("Cannot find CMake executable") from e
bnellnm's avatar
bnellnm committed
228
229
230
231
232

        # Create build directory if it does not exist.
        if not os.path.exists(self.build_temp):
            os.makedirs(self.build_temp)

233
        targets = []
234
235
236
237

        def target_name(s: str) -> str:
            return s.removeprefix("vllm.").removeprefix("vllm_flash_attn.")

bnellnm's avatar
bnellnm committed
238
239
240
        # Build all the extensions
        for ext in self.extensions:
            self.configure(ext)
241
            targets.append(target_name(ext.name))
bnellnm's avatar
bnellnm committed
242

243
        num_jobs, _ = self.compute_num_jobs()
bnellnm's avatar
bnellnm committed
244

245
246
247
248
249
250
        build_args = [
            "--build",
            ".",
            f"-j={num_jobs}",
            *[f"--target={name}" for name in targets],
        ]
bnellnm's avatar
bnellnm committed
251

252
        subprocess.check_call(["cmake", *build_args], cwd=self.build_temp)
253

254
255
256
257
258
259
260
261
262
263
264
265
        # Install the libraries
        for ext in self.extensions:
            # Install the extension into the proper location
            outdir = Path(self.get_ext_fullpath(ext.name)).parent.absolute()

            # Skip if the install directory is the same as the build directory
            if outdir == self.build_temp:
                continue

            # CMake appends the extension prefix to the install path,
            # and outdir already contains that prefix, so we need to remove it.
            prefix = outdir
266
            for _ in range(ext.name.count(".")):
267
268
269
270
                prefix = prefix.parent

            # prefix here should actually be the same for all components
            install_args = [
271
272
273
274
275
276
277
                "cmake",
                "--install",
                ".",
                "--prefix",
                prefix,
                "--component",
                target_name(ext.name),
278
279
280
            ]
            subprocess.check_call(install_args, cwd=self.build_temp)

281
282
283
284
    def run(self):
        # First, run the standard build_ext command to compile the extensions
        super().run()

285
        # copy vllm/vllm_flash_attn/**/*.py from self.build_lib to current
286
287
        # directory so that they can be included in the editable build
        import glob
288
289
290
291
292

        files = glob.glob(
            os.path.join(self.build_lib, "vllm", "vllm_flash_attn", "**", "*.py"),
            recursive=True,
        )
293
        for file in files:
294
295
296
            dst_file = os.path.join(
                "vllm/vllm_flash_attn", file.split("vllm/vllm_flash_attn/")[-1]
            )
297
            print(f"Copying {file} to {dst_file}")
298
            os.makedirs(os.path.dirname(dst_file), exist_ok=True)
299
300
            self.copy_file(file, dst_file)

301
302
303
304
305
306
307
308
309
310
311
312
313
314
        if _is_cuda() or _is_hip():
            # copy vllm/third_party/triton_kernels/**/*.py from self.build_lib
            # to current directory so that they can be included in the editable
            # build
            print(
                f"Copying {self.build_lib}/vllm/third_party/triton_kernels "
                "to vllm/third_party/triton_kernels"
            )
            shutil.copytree(
                f"{self.build_lib}/vllm/third_party/triton_kernels",
                "vllm/third_party/triton_kernels",
                dirs_exist_ok=True,
            )

315

316
317
318
class precompiled_build_ext(build_ext):
    """Disables extension building when using precompiled binaries."""

319
    def run(self) -> None:
320
        return
321

322
323
324
325
326
327
    def build_extensions(self) -> None:
        print("Skipping build_ext: using precompiled extensions.")
        return


class precompiled_wheel_utils:
328
329
    """Extracts libraries and other files from an existing wheel."""

330
    @staticmethod
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
    def fetch_metadata_for_variant(
        commit: str, variant: str | None
    ) -> tuple[list[dict], str]:
        """
        Fetches metadata for a specific variant of the precompiled wheel.
        """
        variant_dir = f"{variant}/" if variant is not None else ""
        repo_url = f"https://wheels.vllm.ai/{commit}/{variant_dir}vllm/"
        meta_url = repo_url + "metadata.json"
        print(f"Trying to fetch nightly build metadata from {meta_url}")
        from urllib.request import urlopen

        with urlopen(meta_url) as resp:
            # urlopen raises HTTPError on unexpected status code
            wheels = json.loads(resp.read().decode("utf-8"))
        return wheels, repo_url

348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
    @staticmethod
    def is_rocm_system() -> bool:
        """Detect ROCm without relying on torch (for build environment)."""
        if os.getenv("ROCM_PATH"):
            return True
        if os.path.isdir("/opt/rocm"):
            return True
        if which("rocminfo") is not None:
            return True
        try:
            import torch

            return torch.version.hip is not None
        except ImportError:
            return False

364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
    @staticmethod
    def detect_system_cuda_variant() -> str:
        """Auto-detect CUDA variant from torch, nvidia-smi, or env default."""

        # Map CUDA major version to hosted wheel variants on wheels.vllm.ai
        supported = {12: "cu129", 13: "cu130"}

        # Respect explicitly set VLLM_MAIN_CUDA_VERSION
        if envs.is_set("VLLM_MAIN_CUDA_VERSION"):
            v = envs.VLLM_MAIN_CUDA_VERSION
            print(f"Using VLLM_MAIN_CUDA_VERSION={v}")
            return "cu" + v.replace(".", "")[:3]

        # Try torch.version.cuda
        cuda_version = None
        try:
            import torch

            cuda_version = torch.version.cuda
        except Exception:
            pass

        # Try nvidia-smi
        if not cuda_version:
            try:
                out = subprocess.run(
                    ["nvidia-smi"], capture_output=True, text=True, timeout=10
                )
                if m := re.search(r"CUDA Version:\s*(\d+\.\d+)", out.stdout):
                    cuda_version = m.group(1)
            except Exception:
                pass

        # Fall back to default
        if not cuda_version:
            cuda_version = envs.VLLM_MAIN_CUDA_VERSION

        # Map to supported variant
        major = int(cuda_version.split(".")[0])
        variant = supported.get(major, supported[max(supported)])
        print(f"Detected CUDA {cuda_version}, using variant {variant}")
        return variant

407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
    @staticmethod
    def find_local_rocm_wheel() -> str | None:
        """Search for a local vllm wheel in common locations."""
        import glob

        for pattern in ["/vllm-workspace/dist/vllm-*.whl", "./dist/vllm-*.whl"]:
            wheels = glob.glob(pattern)
            if wheels:
                return sorted(wheels)[-1]
        return None

    @staticmethod
    def fetch_wheel_from_pypi_index(index_url: str, package: str = "vllm") -> str:
        """Fetch the latest wheel URL from a PyPI-style simple index."""
        import platform
        from html.parser import HTMLParser
        from urllib.parse import urljoin
        from urllib.request import urlopen

        arch = platform.machine()

        class WheelLinkParser(HTMLParser):
            def __init__(self):
                super().__init__()
                self.wheels = []

            def handle_starttag(self, tag, attrs):
                if tag == "a":
                    for name, value in attrs:
                        if name == "href" and value.endswith(".whl"):
                            self.wheels.append(value)

        simple_url = f"{index_url.rstrip('/')}/{package}/"
        print(f"Fetching wheel list from {simple_url}")
        with urlopen(simple_url) as resp:
            html = resp.read().decode("utf-8")

        parser = WheelLinkParser()
        parser.feed(html)

        for wheel in reversed(parser.wheels):
            if arch in wheel:
                if wheel.startswith("http"):
                    return wheel
                return urljoin(simple_url, wheel)

        raise ValueError(f"No compatible wheel found for {arch} at {simple_url}")

    @staticmethod
    def determine_wheel_url_rocm() -> tuple[str, str | None]:
        """Determine the precompiled wheel for ROCm."""
        # Search for local wheel first
        local_wheel = precompiled_wheel_utils.find_local_rocm_wheel()
        if local_wheel is not None:
            print(f"Found local ROCm wheel: {local_wheel}")
            return local_wheel, None

        # Fall back to AMD's PyPI index
        index_url = os.getenv(
            "VLLM_ROCM_WHEEL_INDEX", "https://pypi.amd.com/vllm-rocm/simple"
        )
        print(f"Fetching ROCm precompiled wheel from {index_url}")
        wheel_url = precompiled_wheel_utils.fetch_wheel_from_pypi_index(index_url)
        download_filename = wheel_url.split("/")[-1].split("#")[0]
        print(f"Using ROCm precompiled wheel: {wheel_url}")
        return wheel_url, download_filename

474
475
476
477
478
479
480
    @staticmethod
    def determine_wheel_url() -> tuple[str, str | None]:
        """
        Try to determine the precompiled wheel URL or path to use.
        The order of preference is:
        1. user-specified wheel location (can be either local or remote, via
           VLLM_PRECOMPILED_WHEEL_LOCATION)
481
        2. user-specified variant (VLLM_PRECOMPILED_WHEEL_VARIANT) from nightly repo
482
483
           or auto-detected CUDA variant based on system (torch, nvidia-smi)
        3. the default variant from nightly repo
484
485
486
487

        If downloading from the nightly repo, the commit can be specified via
        VLLM_PRECOMPILED_WHEEL_COMMIT; otherwise, the head commit in the main branch
        is used.
488
489
490
491
492
493
        """
        wheel_location = os.getenv("VLLM_PRECOMPILED_WHEEL_LOCATION", None)
        if wheel_location is not None:
            print(f"Using user-specified precompiled wheel location: {wheel_location}")
            return wheel_location, None
        else:
494
495
496
497
498
            # ROCm: use local wheel or AMD's PyPI index
            # TODO: When we have ROCm nightly wheels, we can update this logic.
            if precompiled_wheel_utils.is_rocm_system():
                return precompiled_wheel_utils.determine_wheel_url_rocm()

499
500
501
            import platform

            arch = platform.machine()
502
503
504
505
506
            # try to fetch the wheel metadata from the nightly wheel repo,
            # detecting CUDA variant from system if not specified
            variant = os.getenv("VLLM_PRECOMPILED_WHEEL_VARIANT", None)
            if variant is None:
                variant = precompiled_wheel_utils.detect_system_cuda_variant()
507
508
509
510
511
512
513
            commit = os.getenv("VLLM_PRECOMPILED_WHEEL_COMMIT", "").lower()
            if not commit or len(commit) != 40:
                print(
                    f"VLLM_PRECOMPILED_WHEEL_COMMIT not valid: {commit}"
                    ", trying to fetch base commit in main branch"
                )
                commit = precompiled_wheel_utils.get_base_commit_in_main_branch()
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
            print(f"Using precompiled wheel commit {commit} with variant {variant}")
            try_default = False
            wheels, repo_url, download_filename = None, None, None
            try:
                wheels, repo_url = precompiled_wheel_utils.fetch_metadata_for_variant(
                    commit, variant
                )
            except Exception as e:
                logger.warning(
                    "Failed to fetch precompiled wheel metadata for variant %s: %s",
                    variant,
                    e,
                )
                try_default = True  # try outside handler to keep the stacktrace simple
            if try_default:
                print("Trying the default variant from remote")
                wheels, repo_url = precompiled_wheel_utils.fetch_metadata_for_variant(
                    commit, None
                )
                # if this also fails, then we have nothing more to try / cache
            assert wheels is not None and repo_url is not None, (
                "Failed to fetch precompiled wheel metadata"
            )
            # The metadata.json has the following format:
            # see .buildkite/scripts/generate-nightly-index.py for details
            """[{
    "package_name": "vllm",
    "version": "0.11.2.dev278+gdbc3d9991",
    "build_tag": null,
    "python_tag": "cp38",
    "abi_tag": "abi3",
    "platform_tag": "manylinux1_x86_64",
    "variant": null,
    "filename": "vllm-0.11.2.dev278+gdbc3d9991-cp38-abi3-manylinux1_x86_64.whl",
    "path": "../vllm-0.11.2.dev278%2Bgdbc3d9991-cp38-abi3-manylinux1_x86_64.whl"
    },
    ...]"""
            from urllib.parse import urljoin

            for wheel in wheels:
                # TODO: maybe check more compatibility later? (python_tag, abi_tag, etc)
                if wheel.get("package_name") == "vllm" and arch in wheel.get(
                    "platform_tag", ""
                ):
                    print(f"Found precompiled wheel metadata: {wheel}")
                    if "path" not in wheel:
                        raise ValueError(f"Wheel metadata missing path: {wheel}")
                    wheel_url = urljoin(repo_url, wheel["path"])
                    download_filename = wheel.get("filename")
                    print(f"Using precompiled wheel URL: {wheel_url}")
                    break
            else:
                raise ValueError(
                    f"No precompiled vllm wheel found for architecture {arch} "
                    f"from repo {repo_url}. All available wheels: {wheels}"
                )

        return wheel_url, download_filename

    @staticmethod
    def extract_precompiled_and_patch_package(
        wheel_url_or_path: str, download_filename: str | None
    ) -> dict:
577
578
579
580
581
582
        import tempfile
        import zipfile

        temp_dir = None
        try:
            if not os.path.isfile(wheel_url_or_path):
583
584
                # use provided filename first, then derive from URL
                wheel_filename = download_filename or wheel_url_or_path.split("/")[-1]
585
586
                temp_dir = tempfile.mkdtemp(prefix="vllm-wheels")
                wheel_path = os.path.join(temp_dir, wheel_filename)
587
                print(f"Downloading wheel from {wheel_url_or_path} to {wheel_path}")
588
                from urllib.request import urlretrieve
589

590
591
592
593
594
595
596
597
598
599
                urlretrieve(wheel_url_or_path, filename=wheel_path)
            else:
                wheel_path = wheel_url_or_path
                print(f"Using existing wheel at {wheel_path}")

            package_data_patch = {}

            with zipfile.ZipFile(wheel_path) as wheel:
                files_to_copy = [
                    "vllm/_C.abi3.so",
600
                    "vllm/_C_stable_libtorch.abi3.so",
601
602
                    "vllm/_moe_C.abi3.so",
                    "vllm/_flashmla_C.abi3.so",
603
604
                    "vllm/_flashmla_extension_C.abi3.so",
                    "vllm/_sparse_flashmla_C.abi3.so",
605
606
607
                    "vllm/vllm_flash_attn/_vllm_fa2_C.abi3.so",
                    "vllm/vllm_flash_attn/_vllm_fa3_C.abi3.so",
                    "vllm/cumem_allocator.abi3.so",
608
609
                    # ROCm-specific libraries
                    "vllm/_rocm_C.abi3.so",
610
611
                ]

612
                flash_attn_regex = re.compile(
613
614
                    r"vllm/vllm_flash_attn/(?:[^/.][^/]*/)*(?!\.)[^/]*\.py"
                )
615
616
617
                triton_kernels_regex = re.compile(
                    r"vllm/third_party/triton_kernels/(?:[^/.][^/]*/)*(?!\.)[^/]*\.py"
                )
618
619
620
                flashmla_regex = re.compile(
                    r"vllm/third_party/flashmla/(?:[^/.][^/]*/)*(?!\.)[^/]*\.py"
                )
621
                file_members = list(
622
623
                    filter(lambda x: x.filename in files_to_copy, wheel.filelist)
                )
624
                file_members += list(
625
626
627
628
629
630
                    filter(lambda x: flash_attn_regex.match(x.filename), wheel.filelist)
                )
                file_members += list(
                    filter(
                        lambda x: triton_kernels_regex.match(x.filename), wheel.filelist
                    )
631
                )
632
633
634
                file_members += list(
                    filter(lambda x: flashmla_regex.match(x.filename), wheel.filelist)
                )
635
636
637
638
639

                for file in file_members:
                    print(f"[extract] {file.filename}")
                    target_path = os.path.join(".", file.filename)
                    os.makedirs(os.path.dirname(target_path), exist_ok=True)
640
641
642
643
                    with (
                        wheel.open(file.filename) as src,
                        open(target_path, "wb") as dst,
                    ):
644
645
646
647
                        shutil.copyfileobj(src, dst)

                    pkg = os.path.dirname(file.filename).replace("/", ".")
                    package_data_patch.setdefault(pkg, []).append(
648
649
                        os.path.basename(file.filename)
                    )
650
651
652
653
654
655
656
657
658

            return package_data_patch
        finally:
            if temp_dir is not None:
                print(f"Removing temporary directory {temp_dir}")
                shutil.rmtree(temp_dir)

    @staticmethod
    def get_base_commit_in_main_branch() -> str:
659
        try:
660
            # Get the latest commit hash of the upstream main branch.
661
662
663
664
665
666
667
668
669
670
            curl_cmd = [
                "curl",
                "-s",
                "https://api.github.com/repos/vllm-project/vllm/commits/main",
            ]
            github_token = os.getenv("GH_TOKEN", os.getenv("GITHUB_TOKEN"))
            if github_token:
                curl_cmd += [
                    "-H",
                    f"Authorization: token {github_token}",
671
                ]
672
            resp_json = subprocess.check_output(curl_cmd).decode("utf-8")
673
            upstream_main_commit = json.loads(resp_json)["sha"]
674
            print(f"Upstream main branch latest commit: {upstream_main_commit}")
675

676
677
678
679
            # In Docker build context, .git may be immutable or missing.
            if envs.VLLM_DOCKER_BUILD_CONTEXT:
                return upstream_main_commit

680
681
682
            # Check if the upstream_main_commit exists in the local repo
            try:
                subprocess.check_output(
683
684
                    ["git", "cat-file", "-e", f"{upstream_main_commit}"]
                )
685
686
687
688
689
            except subprocess.CalledProcessError:
                # If not present, fetch it from the remote repository.
                # Note that this does not update any local branches,
                # but ensures that this commit ref and its history are
                # available in our local repo.
690
691
692
                subprocess.check_call(
                    ["git", "fetch", "https://github.com/vllm-project/vllm", "main"]
                )
693
694
695

            # Then get the commit hash of the current branch that is the same as
            # the upstream main commit.
696
697
698
699
700
            current_branch = (
                subprocess.check_output(["git", "branch", "--show-current"])
                .decode("utf-8")
                .strip()
            )
701

702
703
704
705
706
707
708
            base_commit = (
                subprocess.check_output(
                    ["git", "merge-base", f"{upstream_main_commit}", current_branch]
                )
                .decode("utf-8")
                .strip()
            )
709
            return base_commit
710
711
        except ValueError as err:
            raise ValueError(err) from None
712
713
714
715
        except Exception as err:
            logger.warning(
                "Failed to get the base commit in the main branch. "
                "Using the nightly wheel. The libraries in this "
716
717
718
                "wheel may not be compatible with your dev branch: %s",
                err,
            )
719
            return "nightly"
720
721


722
723
724
725
def _no_device() -> bool:
    return VLLM_TARGET_DEVICE == "empty"


726
def _is_cuda() -> bool:
727
    has_cuda = torch.version.cuda is not None
728
    return VLLM_TARGET_DEVICE == "cuda" and has_cuda and not _is_tpu()
729
730


731
def _is_hip() -> bool:
732
733
734
    return (
        VLLM_TARGET_DEVICE == "cuda" or VLLM_TARGET_DEVICE == "rocm"
    ) and torch.version.hip is not None
735
736


737
738
739
740
def _is_tpu() -> bool:
    return VLLM_TARGET_DEVICE == "tpu"


741
742
743
744
def _is_cpu() -> bool:
    return VLLM_TARGET_DEVICE == "cpu"


745
746
747
748
def _is_xpu() -> bool:
    return VLLM_TARGET_DEVICE == "xpu"


749
def _build_custom_ops() -> bool:
750
    return _is_cuda() or _is_hip()
751
752


753
754
755
756
def get_rocm_version():
    # Get the Rocm version from the ROCM_HOME/bin/librocm-core.so
    # see https://github.com/ROCm/rocm-core/blob/d11f5c20d500f729c393680a01fa902ebf92094b/rocm_version.cpp#L21
    try:
757
758
        if ROCM_HOME is None:
            return None
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
        librocm_core_file = Path(ROCM_HOME) / "lib" / "librocm-core.so"
        if not librocm_core_file.is_file():
            return None
        librocm_core = ctypes.CDLL(librocm_core_file)
        VerErrors = ctypes.c_uint32
        get_rocm_core_version = librocm_core.getROCmVersion
        get_rocm_core_version.restype = VerErrors
        get_rocm_core_version.argtypes = [
            ctypes.POINTER(ctypes.c_uint32),
            ctypes.POINTER(ctypes.c_uint32),
            ctypes.POINTER(ctypes.c_uint32),
        ]
        major = ctypes.c_uint32()
        minor = ctypes.c_uint32()
        patch = ctypes.c_uint32()
774

775
776
777
778
779
780
        if (
            get_rocm_core_version(
                ctypes.byref(major), ctypes.byref(minor), ctypes.byref(patch)
            )
            == 0
        ):
781
            return f"{major.value}.{minor.value}.{patch.value}"
782
        return None
783
    except Exception:
784
        return None
Woosuk Kwon's avatar
Woosuk Kwon committed
785

786

bnellnm's avatar
bnellnm committed
787
def get_nvcc_cuda_version() -> Version:
788
789
790
791
    """Get the CUDA version from nvcc.

    Adapted from https://github.com/NVIDIA/apex/blob/8b7a1ff183741dd8f9b87e7bafd04cfde99cea28/setup.py
    """
792
    assert CUDA_HOME is not None, "CUDA_HOME is not set"
793
794
795
    nvcc_output = subprocess.check_output(
        [CUDA_HOME + "/bin/nvcc", "-V"], universal_newlines=True
    )
796
797
798
799
800
801
    output = nvcc_output.split()
    release_idx = output.index("release") + 1
    nvcc_cuda_version = parse(output[release_idx].split(",")[0])
    return nvcc_cuda_version


802
def get_vllm_version() -> str:
803
804
805
    # Allow overriding the version. This is useful to build platform-specific
    # wheels (e.g. CPU, TPU) without modifying the source.
    if env_version := os.getenv("VLLM_VERSION_OVERRIDE"):
806
807
808
        print(f"Overriding VLLM version with {env_version} from VLLM_VERSION_OVERRIDE")
        os.environ["SETUPTOOLS_SCM_PRETEND_VERSION"] = env_version
        return get_version(write_to="vllm/_version.py")
809

810
    version = get_version(write_to="vllm/_version.py")
811
    sep = "+" if "+" not in version else "."  # dev versions might contain +
812

813
    if _no_device():
814
        if envs.VLLM_TARGET_DEVICE == "empty":
815
            version += f"{sep}empty"
816
    elif _is_cuda():
817
        if envs.VLLM_USE_PRECOMPILED and not envs.VLLM_SKIP_PRECOMPILED_VERSION_SUFFIX:
818
            version += f"{sep}precompiled"
819
820
        else:
            cuda_version = str(get_nvcc_cuda_version())
821
            if cuda_version != envs.VLLM_MAIN_CUDA_VERSION:
822
823
824
825
                cuda_version_str = cuda_version.replace(".", "")[:3]
                # skip this for source tarball, required for pypi
                if "sdist" not in sys.argv:
                    version += f"{sep}cu{cuda_version_str}"
826
    elif _is_hip():
827
828
        # Get the Rocm Version
        rocm_version = get_rocm_version() or torch.version.hip
829
        if rocm_version and rocm_version != envs.VLLM_MAIN_CUDA_VERSION:
830
            version += f"{sep}rocm{rocm_version.replace('.', '')[:3]}"
831
    elif _is_tpu():
832
        version += f"{sep}tpu"
833
    elif _is_cpu():
834
835
        if envs.VLLM_TARGET_DEVICE == "cpu":
            version += f"{sep}cpu"
836
    elif _is_xpu():
837
        version += f"{sep}xpu"
838
    else:
839
        raise RuntimeError("Unknown runtime environment")
840

841
842
843
    return version


844
def get_requirements() -> list[str]:
845
    """Get Python package dependencies from requirements.txt."""
846
    requirements_dir = ROOT_DIR / "requirements"
847

848
    def _read_requirements(filename: str) -> list[str]:
849
        with open(requirements_dir / filename) as f:
850
            requirements = f.read().strip().split("\n")
851
852
853
854
        resolved_requirements = []
        for line in requirements:
            if line.startswith("-r "):
                resolved_requirements += _read_requirements(line.split()[1])
855
856
857
858
859
            elif (
                not line.startswith("--")
                and not line.startswith("#")
                and line.strip() != ""
            ):
860
861
862
                resolved_requirements.append(line)
        return resolved_requirements

863
    if _no_device():
864
        requirements = _read_requirements("common.txt")
865
    elif _is_cuda():
866
        requirements = _read_requirements("cuda.txt")
867
        cuda_major, cuda_minor = torch.version.cuda.split(".")
868
869
        modified_requirements = []
        for req in requirements:
870
            if "vllm-flash-attn" in req and cuda_major != "12":
871
                # vllm-flash-attn is built only for CUDA 12.x.
872
873
874
                # Skip for other versions.
                continue
            modified_requirements.append(req)
875
        requirements = modified_requirements
876
    elif _is_hip():
877
        requirements = _read_requirements("rocm.txt")
878
    elif _is_tpu():
879
        requirements = _read_requirements("tpu.txt")
880
    elif _is_cpu():
881
        requirements = _read_requirements("cpu.txt")
882
    elif _is_xpu():
883
        requirements = _read_requirements("xpu.txt")
884
    else:
885
        raise ValueError("Unsupported platform, please use CUDA, ROCm, or CPU.")
886
887
888
    return requirements


bnellnm's avatar
bnellnm committed
889
890
ext_modules = []

891
if _is_cuda() or _is_hip():
bnellnm's avatar
bnellnm committed
892
    ext_modules.append(CMakeExtension(name="vllm._moe_C"))
893
    ext_modules.append(CMakeExtension(name="vllm.cumem_allocator"))
894
895
896
    # Optional since this doesn't get built (produce an .so file). This is just
    # copying the relevant .py files from the source repository.
    ext_modules.append(CMakeExtension(name="vllm.triton_kernels", optional=True))
bnellnm's avatar
bnellnm committed
897

898
899
900
if _is_hip():
    ext_modules.append(CMakeExtension(name="vllm._rocm_C"))

901
if _is_cuda():
902
    ext_modules.append(CMakeExtension(name="vllm.vllm_flash_attn._vllm_fa2_C"))
903
904
905
    if envs.VLLM_USE_PRECOMPILED or (
        CUDA_HOME and get_nvcc_cuda_version() >= Version("12.3")
    ):
906
        # FA3 requires CUDA 12.3 or later
907
        ext_modules.append(CMakeExtension(name="vllm.vllm_flash_attn._vllm_fa3_C"))
908
909
910
911
912
    # FA4 CuteDSL - Python-only component for FA4's cute DSL support
    # Optional since this doesn't produce a .so file, just copies Python files
    ext_modules.append(
        CMakeExtension(name="vllm.vllm_flash_attn._vllm_fa4_cutedsl_C", optional=True)
    )
913
914
915
916
    if envs.VLLM_USE_PRECOMPILED or (
        CUDA_HOME and get_nvcc_cuda_version() >= Version("12.9")
    ):
        # FlashMLA requires CUDA 12.9 or later
917
918
        # Optional since this doesn't get built (produce an .so file) when
        # not targeting a hopper system
919
        ext_modules.append(CMakeExtension(name="vllm._flashmla_C", optional=True))
920
        ext_modules.append(
921
922
            CMakeExtension(name="vllm._flashmla_extension_C", optional=True)
        )
923

924
925
926
927
928
if _is_cpu():
    import platform

    if platform.machine() in ("x86_64", "AMD64"):
        ext_modules.append(CMakeExtension(name="vllm._C"))
929
        ext_modules.append(CMakeExtension(name="vllm._C_AVX512"))
930
931
932
933
        ext_modules.append(CMakeExtension(name="vllm._C_AVX2"))
    else:
        ext_modules.append(CMakeExtension(name="vllm._C"))

934
if _build_custom_ops():
bnellnm's avatar
bnellnm committed
935
    ext_modules.append(CMakeExtension(name="vllm._C"))
936
937
938
939
    # also _is_hip() once https://github.com/vllm-project/vllm/issues/35163 is
    # fixed
    if _is_cuda():
        ext_modules.append(CMakeExtension(name="vllm._C_stable_libtorch"))
bnellnm's avatar
bnellnm committed
940

941
package_data = {
942
943
944
945
    "vllm": [
        "py.typed",
        "model_executor/layers/fused_moe/configs/*.json",
        "model_executor/layers/quantization/utils/configs/*.json",
946
947
        "entrypoints/serve/instrumentator/static/*.js",
        "entrypoints/serve/instrumentator/static/*.css",
948
    ]
949
}
Simon Mo's avatar
Simon Mo committed
950

951

952
953
# If using precompiled, extract and patch package_data (in advance of setup)
if envs.VLLM_USE_PRECOMPILED:
954
955
956
957
    wheel_url, download_filename = precompiled_wheel_utils.determine_wheel_url()
    patch = precompiled_wheel_utils.extract_precompiled_and_patch_package(
        wheel_url, download_filename
    )
958
959
960
    for pkg, files in patch.items():
        package_data.setdefault(pkg, []).extend(files)

961
962
963
if _no_device():
    ext_modules = []

964
if not ext_modules:
965
    cmdclass = {}
966
else:
967
    cmdclass = {
968
969
        "build_ext": precompiled_build_ext
        if envs.VLLM_USE_PRECOMPILED
970
        else cmake_build_ext,
971
    }
972

bnellnm's avatar
bnellnm committed
973
setup(
974
    # static metadata should rather go in pyproject.toml
975
    version=get_vllm_version(),
Woosuk Kwon's avatar
Woosuk Kwon committed
976
    ext_modules=ext_modules,
977
    install_requires=get_requirements(),
978
    extras_require={
979
980
        # AMD Zen CPU optimizations via zentorch
        "zen": ["zentorch"],
981
        "bench": ["pandas", "matplotlib", "seaborn", "datasets", "scipy", "plotly"],
982
        "tensorizer": ["tensorizer==2.10.1"],
983
        "fastsafetensors": ["fastsafetensors >= 0.2.2"],
984
        "instanttensor": ["instanttensor >= 0.1.5"],
985
        "runai": ["runai-model-streamer[s3,gcs,azure] >= 0.15.7"],
986
987
        "audio": [
            "librosa",
988
            "scipy",
989
990
            "soundfile",
            "mistral_common[audio]",
991
            "av",
992
        ],  # Required for audio processing
993
        "video": [],  # Kept for backwards compatibility
994
        "flashinfer": [],  # Kept for backwards compatibility
995
996
        # Optional deps for AMD FP4 quantization support
        "petit-kernel": ["petit-kernel"],
997
        # Optional deps for Helion kernel development
Yanan Cao's avatar
Yanan Cao committed
998
        "helion": ["helion==0.3.2"],
999
        # Optional deps for gRPC server (vllm serve --grpc)
1000
        "grpc": ["smg-grpc-servicer[vllm] >= 0.5.0"],
1001
1002
1003
1004
1005
1006
1007
        # Optional deps for OpenTelemetry tracing
        "otel": [
            "opentelemetry-sdk>=1.26.0",
            "opentelemetry-api>=1.26.0",
            "opentelemetry-exporter-otlp>=1.26.0",
            "opentelemetry-semantic-conventions-ai>=0.4.1",
        ],
1008
    },
1009
    cmdclass=cmdclass,
Simon Mo's avatar
Simon Mo committed
1010
    package_data=package_data,
Woosuk Kwon's avatar
Woosuk Kwon committed
1011
)