setup.py 37 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
600
601
                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",
                    "vllm/_moe_C.abi3.so",
                    "vllm/_flashmla_C.abi3.so",
602
603
                    "vllm/_flashmla_extension_C.abi3.so",
                    "vllm/_sparse_flashmla_C.abi3.so",
604
605
606
                    "vllm/vllm_flash_attn/_vllm_fa2_C.abi3.so",
                    "vllm/vllm_flash_attn/_vllm_fa3_C.abi3.so",
                    "vllm/cumem_allocator.abi3.so",
607
608
                    # ROCm-specific libraries
                    "vllm/_rocm_C.abi3.so",
609
610
                ]

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

                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)
639
640
641
642
                    with (
                        wheel.open(file.filename) as src,
                        open(target_path, "wb") as dst,
                    ):
643
644
645
646
                        shutil.copyfileobj(src, dst)

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

            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:
658
        try:
659
            # Get the latest commit hash of the upstream main branch.
660
661
662
663
664
665
666
667
668
669
            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}",
670
                ]
671
            resp_json = subprocess.check_output(curl_cmd).decode("utf-8")
672
            upstream_main_commit = json.loads(resp_json)["sha"]
673
            print(f"Upstream main branch latest commit: {upstream_main_commit}")
674

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

679
680
681
            # Check if the upstream_main_commit exists in the local repo
            try:
                subprocess.check_output(
682
683
                    ["git", "cat-file", "-e", f"{upstream_main_commit}"]
                )
684
685
686
687
688
            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.
689
690
691
                subprocess.check_call(
                    ["git", "fetch", "https://github.com/vllm-project/vllm", "main"]
                )
692
693
694

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

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


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


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


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


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


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


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


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


752
753
754
755
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:
756
757
        if ROCM_HOME is None:
            return None
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
        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()
773

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

785

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

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


801
def get_vllm_version() -> str:
802
803
804
    # 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"):
805
806
807
        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")
808

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

812
    if _no_device():
813
        if envs.VLLM_TARGET_DEVICE == "empty":
814
            version += f"{sep}empty"
815
    elif _is_cuda():
816
        if envs.VLLM_USE_PRECOMPILED and not envs.VLLM_SKIP_PRECOMPILED_VERSION_SUFFIX:
817
            version += f"{sep}precompiled"
818
819
        else:
            cuda_version = str(get_nvcc_cuda_version())
820
            if cuda_version != envs.VLLM_MAIN_CUDA_VERSION:
821
822
823
824
                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}"
825
    elif _is_hip():
826
827
        # Get the Rocm Version
        rocm_version = get_rocm_version() or torch.version.hip
828
        if rocm_version and rocm_version != envs.VLLM_MAIN_CUDA_VERSION:
829
            version += f"{sep}rocm{rocm_version.replace('.', '')[:3]}"
830
    elif _is_tpu():
831
        version += f"{sep}tpu"
832
    elif _is_cpu():
833
834
        if envs.VLLM_TARGET_DEVICE == "cpu":
            version += f"{sep}cpu"
835
    elif _is_xpu():
836
        version += f"{sep}xpu"
837
    else:
838
        raise RuntimeError("Unknown runtime environment")
839

840
841
842
    return version


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

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

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


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

890
if _is_cuda() or _is_hip():
bnellnm's avatar
bnellnm committed
891
    ext_modules.append(CMakeExtension(name="vllm._moe_C"))
892
    ext_modules.append(CMakeExtension(name="vllm.cumem_allocator"))
893
894
895
    # 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
896

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

900
if _is_cuda():
901
    ext_modules.append(CMakeExtension(name="vllm.vllm_flash_attn._vllm_fa2_C"))
902
903
904
    if envs.VLLM_USE_PRECOMPILED or (
        CUDA_HOME and get_nvcc_cuda_version() >= Version("12.3")
    ):
905
        # FA3 requires CUDA 12.3 or later
906
        ext_modules.append(CMakeExtension(name="vllm.vllm_flash_attn._vllm_fa3_C"))
907
908
909
910
911
    # 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)
    )
912
913
914
915
    if envs.VLLM_USE_PRECOMPILED or (
        CUDA_HOME and get_nvcc_cuda_version() >= Version("12.9")
    ):
        # FlashMLA requires CUDA 12.9 or later
916
917
        # Optional since this doesn't get built (produce an .so file) when
        # not targeting a hopper system
918
        ext_modules.append(CMakeExtension(name="vllm._flashmla_C", optional=True))
919
        ext_modules.append(
920
921
            CMakeExtension(name="vllm._flashmla_extension_C", optional=True)
        )
922

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

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

933
if _build_custom_ops():
bnellnm's avatar
bnellnm committed
934
935
    ext_modules.append(CMakeExtension(name="vllm._C"))

936
package_data = {
937
938
939
940
    "vllm": [
        "py.typed",
        "model_executor/layers/fused_moe/configs/*.json",
        "model_executor/layers/quantization/utils/configs/*.json",
941
942
        "entrypoints/serve/instrumentator/static/*.js",
        "entrypoints/serve/instrumentator/static/*.css",
943
    ]
944
}
Simon Mo's avatar
Simon Mo committed
945

946

947
948
# If using precompiled, extract and patch package_data (in advance of setup)
if envs.VLLM_USE_PRECOMPILED:
949
950
951
952
    wheel_url, download_filename = precompiled_wheel_utils.determine_wheel_url()
    patch = precompiled_wheel_utils.extract_precompiled_and_patch_package(
        wheel_url, download_filename
    )
953
954
955
    for pkg, files in patch.items():
        package_data.setdefault(pkg, []).extend(files)

956
957
958
if _no_device():
    ext_modules = []

959
if not ext_modules:
960
    cmdclass = {}
961
else:
962
    cmdclass = {
963
964
        "build_ext": precompiled_build_ext
        if envs.VLLM_USE_PRECOMPILED
965
        else cmake_build_ext,
966
    }
967

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