setup.py 30.3 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
9
import os
import re
10
import subprocess
bnellnm's avatar
bnellnm committed
11
import sys
12
from pathlib import Path
13
from shutil import which
zhuwenwen's avatar
zhuwenwen committed
14
15
import tarfile
import shutil
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 torch.utils.cpp_extension import CUDA_HOME, ROCM_HOME
22

zhuwenwen's avatar
zhuwenwen committed
23
24
25
26
from typing import Optional, Union
import subprocess
from pathlib import Path

zhuwenwen's avatar
zhuwenwen committed
27
pwd = os.path.dirname(os.path.abspath(__file__))
gaoqiong's avatar
gaoqiong committed
28
add_git_version = False
29
30
if int(os.environ.get('ADD_GIT_VERSION', '0')) == 1:
    add_git_version = True
zhuwenwen's avatar
zhuwenwen committed
31
32
33
34
    
skip_vllm_build = False
if int(os.environ.get('SKIP_VLLM_BUILD', '0')) == 1:
    skip_vllm_build = True
35

zhuwenwen's avatar
zhuwenwen committed
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68

def prepare_so_files():
    source_dir = "so.tar.gz"
    target_dir = "vllm"
    
    if not os.path.exists(source_dir):
        print(f"Warning: {source_dir} not found, skipping extraction")
        return
    
    print(f"Preparing C extension files from {source_dir}...")
    
    temp_dir = "temp_so_extract"
    os.makedirs(temp_dir, exist_ok=True)
    
    try:
        with tarfile.open(source_dir, "r:*") as tar:
            tar.extractall(temp_dir)
        
        for root, dirs, files in os.walk(temp_dir):
            for file in files:
                if file in ["_C.abi3.so", "_moe_C.abi3.so"]:
                    src_path = os.path.join(root, file)
                    dst_path = os.path.join(target_dir, file)
                    
                    os.makedirs(os.path.dirname(dst_path), exist_ok=True)
                    
                    shutil.copy2(src_path, dst_path)
                    print(f"Copied {file} to {dst_path}")
    finally:
        if os.path.exists(temp_dir):
            shutil.rmtree(temp_dir)  
            
            
69
70
71
72
73
74
75
76
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


77
ROOT_DIR = Path(__file__).parent
78
logger = logging.getLogger(__name__)
79
80
81
82
83
84

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

VLLM_TARGET_DEVICE = envs.VLLM_TARGET_DEVICE
85

86
if sys.platform.startswith("darwin") and VLLM_TARGET_DEVICE != "cpu":
87
    logger.warning(
88
89
90
91
92
93
        "VLLM_TARGET_DEVICE automatically set to `cpu` due to macOS")
    VLLM_TARGET_DEVICE = "cpu"
elif not (sys.platform.startswith("linux")
          or sys.platform.startswith("darwin")):
    logger.warning(
        "vLLM only supports Linux platform (including WSL) and MacOS."
94
95
96
        "Building on %s, "
        "so vLLM may not be able to run correctly", sys.platform)
    VLLM_TARGET_DEVICE = "empty"
97
elif (sys.platform.startswith("linux") and torch.version.cuda is None
98
99
100
      and os.getenv("VLLM_TARGET_DEVICE") is None
      and torch.version.hip is None):
    # if cuda or hip is not available and VLLM_TARGET_DEVICE is not set,
101
102
    # fallback to cpu
    VLLM_TARGET_DEVICE = "cpu"
103

Huy Do's avatar
Huy Do committed
104
MAIN_CUDA_VERSION = "12.8"
105

bnellnm's avatar
bnellnm committed
106
107
108
109
110
111
112
113
114
115
116
117
118

def is_sccache_available() -> bool:
    return which("sccache") is not None


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


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


119
120
121
122
123
124
125
126
127
128
129
130
def is_url_available(url: str) -> bool:
    from urllib.request import urlopen

    status = None
    try:
        with urlopen(url) as f:
            status = f.status
    except Exception:
        return False
    return status == 200


bnellnm's avatar
bnellnm committed
131
132
133
class CMakeExtension(Extension):

    def __init__(self, name: str, cmake_lists_dir: str = '.', **kwa) -> None:
134
        super().__init__(name, sources=[], py_limited_api=True, **kwa)
bnellnm's avatar
bnellnm committed
135
136
137
138
139
        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.
140
    did_config: dict[str, bool] = {}
bnellnm's avatar
bnellnm committed
141
142
143
144
145

    #
    # Determine number of compilation jobs and optionally nvcc compile threads.
    #
    def compute_num_jobs(self):
146
147
        # `num_jobs` is either the value of the MAX_JOBS environment variable
        # (if defined) or the number of CPUs available.
148
        num_jobs = envs.MAX_JOBS
149
150
        if num_jobs is not None:
            num_jobs = int(num_jobs)
151
            logger.info("Using MAX_JOBS=%d as the number of jobs.", num_jobs)
152
153
154
155
156
157
158
        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
159

160
        nvcc_threads = None
161
162
163
164
165
        if _is_cuda() and get_nvcc_cuda_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.
166
            nvcc_threads = envs.NVCC_THREADS
167
168
            if nvcc_threads is not None:
                nvcc_threads = int(nvcc_threads)
169
170
171
                logger.info(
                    "Using NVCC_THREADS=%d as the number of nvcc threads.",
                    nvcc_threads)
172
173
174
            else:
                nvcc_threads = 1
            num_jobs = max(1, num_jobs // nvcc_threads)
bnellnm's avatar
bnellnm committed
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191

        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"
192
        cfg = envs.CMAKE_BUILD_TYPE or default_cfg
bnellnm's avatar
bnellnm committed
193
194
195

        cmake_args = [
            '-DCMAKE_BUILD_TYPE={}'.format(cfg),
196
            '-DVLLM_TARGET_DEVICE={}'.format(VLLM_TARGET_DEVICE),
bnellnm's avatar
bnellnm committed
197
198
        ]

199
        verbose = envs.VERBOSE
bnellnm's avatar
bnellnm committed
200
201
202
203
204
        if verbose:
            cmake_args += ['-DCMAKE_VERBOSE_MAKEFILE=ON']

        if is_sccache_available():
            cmake_args += [
205
                '-DCMAKE_C_COMPILER_LAUNCHER=sccache',
bnellnm's avatar
bnellnm committed
206
207
                '-DCMAKE_CXX_COMPILER_LAUNCHER=sccache',
                '-DCMAKE_CUDA_COMPILER_LAUNCHER=sccache',
208
                '-DCMAKE_HIP_COMPILER_LAUNCHER=sccache',
bnellnm's avatar
bnellnm committed
209
210
211
            ]
        elif is_ccache_available():
            cmake_args += [
212
                '-DCMAKE_C_COMPILER_LAUNCHER=ccache',
bnellnm's avatar
bnellnm committed
213
214
                '-DCMAKE_CXX_COMPILER_LAUNCHER=ccache',
                '-DCMAKE_CUDA_COMPILER_LAUNCHER=ccache',
215
                '-DCMAKE_HIP_COMPILER_LAUNCHER=ccache',
bnellnm's avatar
bnellnm committed
216
217
218
219
220
221
            ]

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

222
223
224
225
        # Pass the python path to cmake so it can reuse the build dependencies
        # on subsequent calls to python.
        cmake_args += ['-DVLLM_PYTHON_PATH={}'.format(":".join(sys.path))]

226
227
228
229
230
231
232
233
        # 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)
        cmake_args += ['-DFETCHCONTENT_BASE_DIR={}'.format(fc_base_dir)]

bnellnm's avatar
bnellnm committed
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
        #
        # Setup parallelism and build tool
        #
        num_jobs, nvcc_threads = self.compute_num_jobs()

        if nvcc_threads:
            cmake_args += ['-DNVCC_THREADS={}'.format(nvcc_threads)]

        if is_ninja_available():
            build_tool = ['-G', 'Ninja']
            cmake_args += [
                '-DCMAKE_JOB_POOL_COMPILE:STRING=compile',
                '-DCMAKE_JOB_POOLS:STRING=compile={}'.format(num_jobs),
            ]
        else:
            # Default build tool to whatever cmake picks.
            build_tool = []
251
252
253
        # Make sure we use the nvcc from CUDA_HOME
        if _is_cuda():
            cmake_args += [f'-DCMAKE_CUDA_COMPILER={CUDA_HOME}/bin/nvcc']
bnellnm's avatar
bnellnm committed
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
        subprocess.check_call(
            ['cmake', ext.cmake_lists_dir, *build_tool, *cmake_args],
            cwd=self.build_temp)

    def build_extensions(self) -> None:
        # Ensure that CMake is present and working
        try:
            subprocess.check_output(['cmake', '--version'])
        except OSError as e:
            raise RuntimeError('Cannot find CMake executable') from e

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

269
        targets = []
270
271
272
273

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

bnellnm's avatar
bnellnm committed
274
275
276
        # Build all the extensions
        for ext in self.extensions:
            self.configure(ext)
277
            targets.append(target_name(ext.name))
bnellnm's avatar
bnellnm committed
278

279
        num_jobs, _ = self.compute_num_jobs()
bnellnm's avatar
bnellnm committed
280

281
282
283
284
285
286
        build_args = [
            "--build",
            ".",
            f"-j={num_jobs}",
            *[f"--target={name}" for name in targets],
        ]
bnellnm's avatar
bnellnm committed
287

288
        subprocess.check_call(["cmake", *build_args], cwd=self.build_temp)
bnellnm's avatar
bnellnm committed
289

290
291
292
293
294
295
296
297
298
299
300
301
        # 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
302
            for _ in range(ext.name.count('.')):
303
304
305
306
307
308
309
310
311
                prefix = prefix.parent

            # prefix here should actually be the same for all components
            install_args = [
                "cmake", "--install", ".", "--prefix", prefix, "--component",
                target_name(ext.name)
            ]
            subprocess.check_call(install_args, cwd=self.build_temp)

312
313
314
315
    def run(self):
        # First, run the standard build_ext command to compile the extensions
        super().run()

316
        # copy vllm/vllm_flash_attn/**/*.py from self.build_lib to current
317
318
        # directory so that they can be included in the editable build
        import glob
319
320
321
        files = glob.glob(os.path.join(self.build_lib, "vllm",
                                       "vllm_flash_attn", "**", "*.py"),
                          recursive=True)
322
323
        for file in files:
            dst_file = os.path.join("vllm/vllm_flash_attn",
324
                                    file.split("vllm/vllm_flash_attn/")[-1])
325
            print(f"Copying {file} to {dst_file}")
326
            os.makedirs(os.path.dirname(dst_file), exist_ok=True)
327
328
            self.copy_file(file, dst_file)

329

330
331
332
class repackage_wheel(build_ext):
    """Extracts libraries and other files from an existing wheel."""

333
    def get_base_commit_in_main_branch(self) -> str:
334
335
336
        # Force to use the nightly wheel. This is mainly used for CI testing.
        if envs.VLLM_TEST_USE_PRECOMPILED_NIGHTLY_WHEEL:
            return "nightly"
337
338

        try:
339
340
341
342
343
344
345
            # Get the latest commit hash of the upstream main branch.
            resp_json = subprocess.check_output([
                "curl", "-s",
                "https://api.github.com/repos/vllm-project/vllm/commits/main"
            ]).decode("utf-8")
            upstream_main_commit = json.loads(resp_json)["sha"]

346
347
348
349
350
351
352
353
354
355
356
357
358
            # Check if the upstream_main_commit exists in the local repo
            try:
                subprocess.check_output(
                    ["git", "cat-file", "-e", f"{upstream_main_commit}"])
            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.
                subprocess.check_call([
                    "git", "fetch", "https://github.com/vllm-project/vllm",
                    "main"
                ])
359
360
361

            # Then get the commit hash of the current branch that is the same as
            # the upstream main commit.
362
363
364
            current_branch = subprocess.check_output(
                ["git", "branch", "--show-current"]).decode("utf-8").strip()

365
366
367
            base_commit = subprocess.check_output([
                "git", "merge-base", f"{upstream_main_commit}", current_branch
            ]).decode("utf-8").strip()
368
            return base_commit
369
370
        except ValueError as err:
            raise ValueError(err) from None
371
372
373
374
375
376
        except Exception as err:
            logger.warning(
                "Failed to get the base commit in the main branch. "
                "Using the nightly wheel. The libraries in this "
                "wheel may not be compatible with your dev branch: %s", err)
            return "nightly"
377

378
    def run(self) -> None:
379
380
381
        assert _is_cuda(
        ), "VLLM_USE_PRECOMPILED is only supported for CUDA builds"

382
383
384
385
        wheel_location = os.getenv("VLLM_PRECOMPILED_WHEEL_LOCATION", None)
        if wheel_location is None:
            base_commit = self.get_base_commit_in_main_branch()
            wheel_location = f"https://wheels.vllm.ai/{base_commit}/vllm-1.0.0.dev-cp38-abi3-manylinux1_x86_64.whl"
386
387
388
389
            # Fallback to nightly wheel if latest commit wheel is unavailable,
            # in this rare case, the nightly release CI hasn't finished on main.
            if not is_url_available(wheel_location):
                wheel_location = "https://wheels.vllm.ai/nightly/vllm-1.0.0.dev-cp38-abi3-manylinux1_x86_64.whl"
390

391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
        import zipfile

        if os.path.isfile(wheel_location):
            wheel_path = wheel_location
            print(f"Using existing wheel={wheel_path}")
        else:
            # Download the wheel from a given URL, assume
            # the filename is the last part of the URL
            wheel_filename = wheel_location.split("/")[-1]

            import tempfile

            # create a temporary directory to store the wheel
            temp_dir = tempfile.mkdtemp(prefix="vllm-wheels")
            wheel_path = os.path.join(temp_dir, wheel_filename)

            print(f"Downloading wheel from {wheel_location} to {wheel_path}")

            from urllib.request import urlretrieve

            try:
                urlretrieve(wheel_location, filename=wheel_path)
            except Exception as e:
                from setuptools.errors import SetupError

                raise SetupError(
                    f"Failed to get vLLM wheel from {wheel_location}") from e

        with zipfile.ZipFile(wheel_path) as wheel:
            files_to_copy = [
                "vllm/_C.abi3.so",
                "vllm/_moe_C.abi3.so",
423
                "vllm/_flashmla_C.abi3.so",
424
425
                "vllm/vllm_flash_attn/_vllm_fa2_C.abi3.so",
                "vllm/vllm_flash_attn/_vllm_fa3_C.abi3.so",
426
                "vllm/cumem_allocator.abi3.so",
427
428
                # "vllm/_version.py", # not available in nightly wheels yet
            ]
429
430
431
432
433
434
435
436
437
438
439
440

            file_members = list(
                filter(lambda x: x.filename in files_to_copy, wheel.filelist))

            # vllm_flash_attn python code:
            # Regex from
            #  `glob.translate('vllm/vllm_flash_attn/**/*.py', recursive=True)`
            compiled_regex = re.compile(
                r"vllm/vllm_flash_attn/(?:[^/.][^/]*/)*(?!\.)[^/]*\.py")
            file_members += list(
                filter(lambda x: compiled_regex.match(x.filename),
                       wheel.filelist))
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458

            for file in file_members:
                print(f"Extracting and including {file.filename} "
                      "from existing wheel")
                package_name = os.path.dirname(file.filename).replace("/", ".")
                file_name = os.path.basename(file.filename)

                if package_name not in package_data:
                    package_data[package_name] = []

                wheel.extract(file)
                if file_name.endswith(".py"):
                    # python files shouldn't be added to package_data
                    continue

                package_data[package_name].append(file_name)


459
def _is_hpu() -> bool:
460
461
462
463
464
465
466
    # if VLLM_TARGET_DEVICE env var was set explicitly, skip HPU autodetection
    if os.getenv("VLLM_TARGET_DEVICE", None) == VLLM_TARGET_DEVICE:
        return VLLM_TARGET_DEVICE == "hpu"

    # if VLLM_TARGET_DEVICE was not set explicitly, check if hl-smi succeeds,
    # and if it doesn't, check if habanalabs driver is loaded
    is_hpu_available = False
467
    try:
468
469
        out = subprocess.run(["hl-smi"], capture_output=True, check=True)
        is_hpu_available = out.returncode == 0
470
    except (FileNotFoundError, PermissionError, subprocess.CalledProcessError):
471
        if sys.platform.startswith("linux"):
472
473
474
475
476
477
            try:
                output = subprocess.check_output(
                    'lsmod | grep habanalabs | wc -l', shell=True)
                is_hpu_available = int(output) > 0
            except (ValueError, FileNotFoundError, PermissionError,
                    subprocess.CalledProcessError):
478
479
                pass
    return is_hpu_available
480
481


482
483
484
485
def _no_device() -> bool:
    return VLLM_TARGET_DEVICE == "empty"


486
def _is_cuda() -> bool:
487
488
    has_cuda = torch.version.cuda is not None
    return (VLLM_TARGET_DEVICE == "cuda" and has_cuda
489
            and not (_is_neuron() or _is_tpu() or _is_hpu()))
490
491
492


def _is_hip() -> bool:
493
494
    return (VLLM_TARGET_DEVICE == "cuda"
            or VLLM_TARGET_DEVICE == "rocm") and torch.version.hip is not None
495
496


497
def _is_neuron() -> bool:
498
    return VLLM_TARGET_DEVICE == "neuron"
499
500


501
502
503
504
def _is_tpu() -> bool:
    return VLLM_TARGET_DEVICE == "tpu"


505
506
def _is_cpu() -> bool:
    return VLLM_TARGET_DEVICE == "cpu"
507
508


509
510
511
512
def _is_xpu() -> bool:
    return VLLM_TARGET_DEVICE == "xpu"


513
def _build_custom_ops() -> bool:
zhuwenwen's avatar
zhuwenwen committed
514
515
    if not skip_vllm_build:
        return _is_cuda() or _is_hip() or _is_cpu()
516
517


518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
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:
        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()
537

538
539
        if (get_rocm_core_version(ctypes.byref(major), ctypes.byref(minor),
                                  ctypes.byref(patch)) == 0):
540
            return f"{major.value}.{minor.value}.{patch.value}"
541
        return None
542
    except Exception:
543
        return None
Woosuk Kwon's avatar
Woosuk Kwon committed
544

545

546
547
548
def get_neuronxcc_version():
    import sysconfig
    site_dir = sysconfig.get_paths()["purelib"]
549
550
    version_file = os.path.join(site_dir, "neuronxcc", "version",
                                "__init__.py")
551
552

    # Check if the command was executed successfully
553
    with open(version_file) as fp:
554
555
556
557
558
559
560
561
        content = fp.read()

    # Extract the version using a regular expression
    match = re.search(r"__version__ = '(\S+)'", content)
    if match:
        # Return the version string
        return match.group(1)
    else:
562
        raise RuntimeError("Could not find Neuron version in the output")
563
564


bnellnm's avatar
bnellnm committed
565
def get_nvcc_cuda_version() -> Version:
566
567
568
569
    """Get the CUDA version from nvcc.

    Adapted from https://github.com/NVIDIA/apex/blob/8b7a1ff183741dd8f9b87e7bafd04cfde99cea28/setup.py
    """
570
    assert CUDA_HOME is not None, "CUDA_HOME is not set"
bnellnm's avatar
bnellnm committed
571
    nvcc_output = subprocess.check_output([CUDA_HOME + "/bin/nvcc", "-V"],
572
573
574
575
576
577
578
                                          universal_newlines=True)
    output = nvcc_output.split()
    release_idx = output.index("release") + 1
    nvcc_cuda_version = parse(output[release_idx].split(",")[0])
    return nvcc_cuda_version


zhuwenwen's avatar
zhuwenwen committed
579
580
581
582
583
584
def get_sha(root: Union[str, Path]) -> str:
    try:
        return subprocess.check_output(['git', 'rev-parse', 'HEAD'], cwd=root).decode('ascii').strip()
    except Exception:
        return 'Unknown'

585

zhuwenwen's avatar
zhuwenwen committed
586
def get_version_add(sha: Optional[str] = None) -> str:
zhuwenwen's avatar
zhuwenwen committed
587
588
    command = "git config --global --add safe.directory "+pwd  
    result = subprocess.run(command, shell=True, capture_output=False, text=True) 
zhuwenwen's avatar
zhuwenwen committed
589
590
    vllm_root = os.path.dirname(os.path.abspath(__file__))
    add_version_path = os.path.join(os.path.join(vllm_root, "vllm"), "version.py")
zhuwenwen's avatar
zhuwenwen committed
591
    major, minor, _ = torch.__version__.split('.')
592
593
594
595
    if add_git_version:
        if sha != 'Unknown':
            if sha is None:
                sha = get_sha(vllm_root)
zhuwenwen's avatar
zhuwenwen committed
596
            if (major, minor) >= ('2', '5'):
zhuwenwen's avatar
zhuwenwen committed
597
                version = 'das.opt5.' + sha[:7]
598
    else:
zhuwenwen's avatar
zhuwenwen committed
599
        if (major, minor) >= ('2', '5'):
zhuwenwen's avatar
zhuwenwen committed
600
            version = 'das.opt5'
601

zhuwenwen's avatar
zhuwenwen committed
602
603
604
605
606
607
608

    # dtk version
    if os.getenv("ROCM_PATH"):
        rocm_path = os.getenv('ROCM_PATH', "")
        rocm_version_path = os.path.join(rocm_path, '.info', "rocm_version")
        with open(rocm_version_path, 'r',encoding='utf-8') as file:
            lines = file.readlines()
zhuwenwen's avatar
zhuwenwen committed
609
        rocm_version=lines[0].replace(".", "")
zhuwenwen's avatar
zhuwenwen committed
610
        version += ".dtk" + rocm_version
zhuwenwen's avatar
zhuwenwen committed
611
    
612
    new_version_content = f"""
613
try:
zhuwenwen's avatar
zhuwenwen committed
614
615
616
    __version__ = "0.9.2"
    __version_tuple__ = (0, 9, 2)
    __hcu_version__ = f'0.9.2+{version}' 
zhuwenwen's avatar
zhuwenwen committed
617
    
zhuwenwen's avatar
zhuwenwen committed
618
    from vllm.version import __version__, __version_tuple__, __hcu_version__
619
except Exception as e:
zhuwenwen's avatar
zhuwenwen committed
620
621
    import warnings

zhuwenwen's avatar
zhuwenwen committed
622
    warnings.warn(f"Failed to read commit hash:\\n + str(e)",
623
624
                  RuntimeWarning,
                  stacklevel=2)
625
626
    __version__ = "dev"
    __version_tuple__ = (0, 0, __version__)
zhuwenwen's avatar
zhuwenwen committed
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
    
    
def _prev_minor_version_was(version_str):
    '''Check whether a given version matches the previous minor version.

    Return True if version_str matches the previous minor version.

    For example - return True if the current version if 0.7.4 and the
    supplied version_str is '0.6'.

    Used for --show-hidden-metrics-for-version.
    '''
    # Match anything if this is a dev tree
    if __version_tuple__[0:2] == (0, 0):
        return True

    # Note - this won't do the right thing when we release 1.0!
644
    # assert __version_tuple__[0] == 0
zhuwenwen's avatar
zhuwenwen committed
645
646
647
648
649
650
651
652
653
    assert isinstance(__version_tuple__[1], int)
    return version_str == f"{{__version_tuple__[0]}}.{{__version_tuple__[1] - 1}}"


def _prev_minor_version():
    '''For the purpose of testing, return a previous minor version number.'''
    # In dev tree, this will return "0.-1", but that will work fine"
    assert isinstance(__version_tuple__[1], int)
    return f"{{__version_tuple__[0]}}.{{__version_tuple__[1] - 1}}"
654
"""
zhuwenwen's avatar
zhuwenwen committed
655
    
zhuwenwen's avatar
zhuwenwen committed
656
    with open(add_version_path, encoding="utf-8",mode="w") as file:
zhuwenwen's avatar
zhuwenwen committed
657
        file.write(new_version_content)
zhuwenwen's avatar
zhuwenwen committed
658
659
660
661
662
663
664
665
    file.close()
    
    
def get_version():
    get_version_add()
    version_file = 'vllm/version.py'
    with open(version_file, encoding='utf-8') as f:
        exec(compile(f.read(), version_file, 'exec'))
zhuwenwen's avatar
zhuwenwen committed
666
    return locals()['__hcu_version__']
zhuwenwen's avatar
zhuwenwen committed
667
668


669
670
671
672
673
674
675
676
def get_gaudi_sw_version():
    """
    Returns the driver version.
    """
    # Enable console printing for `hl-smi` check
    output = subprocess.run("hl-smi",
                            shell=True,
                            text=True,
677
                            capture_output=True,
678
679
680
681
682
683
684
                            env={"ENABLE_CONSOLE": "true"})
    if output.returncode == 0 and output.stdout:
        return output.stdout.split("\n")[2].replace(
            " ", "").split(":")[1][:-1].split("-")[0]
    return "0.0.0"  # when hl-smi is not available


685
def get_vllm_version() -> str:
686
687
688
    # from setuptools_scm import get_version
    # version = get_version(write_to="vllm/_version.py")
    # sep = "+" if "+" not in version else "."  # dev versions might contain +
689

690
    if _no_device():
691
        if envs.VLLM_TARGET_DEVICE == "empty":
692
            version += f"{sep}empty"
693
    elif _is_cuda():
694
        if envs.VLLM_USE_PRECOMPILED:
695
            version += f"{sep}precompiled"
696
697
698
699
700
701
702
        else:
            cuda_version = str(get_nvcc_cuda_version())
            if cuda_version != MAIN_CUDA_VERSION:
                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}"
703
    elif _is_hip():
704
        # Get the Rocm Version
zhuwenwen's avatar
zhuwenwen committed
705
706
707
        # rocm_version = get_rocm_version() or torch.version.hip
        # if rocm_version and rocm_version != MAIN_CUDA_VERSION:
        #     version += f"{sep}rocm{rocm_version.replace('.', '')[:3]}"
zhuwenwen's avatar
zhuwenwen committed
708
        version = get_version()
709
710
    elif _is_neuron():
        # Get the Neuron version
bnellnm's avatar
bnellnm committed
711
        neuron_version = str(get_neuronxcc_version())
712
713
        if neuron_version != MAIN_CUDA_VERSION:
            neuron_version_str = neuron_version.replace(".", "")[:3]
714
            version += f"{sep}neuron{neuron_version_str}"
715
716
717
718
719
720
    elif _is_hpu():
        # Get the Intel Gaudi Software Suite version
        gaudi_sw_version = str(get_gaudi_sw_version())
        if gaudi_sw_version != MAIN_CUDA_VERSION:
            gaudi_sw_version = gaudi_sw_version.replace(".", "")[:3]
            version += f"{sep}gaudi{gaudi_sw_version}"
721
    elif _is_tpu():
722
        version += f"{sep}tpu"
723
    elif _is_cpu():
724
725
        if envs.VLLM_TARGET_DEVICE == "cpu":
            version += f"{sep}cpu"
726
    elif _is_xpu():
727
        version += f"{sep}xpu"
728
    else:
729
        raise RuntimeError("Unknown runtime environment")
730

731
732
733
    return version


734
def get_requirements() -> list[str]:
735
    """Get Python package dependencies from requirements.txt."""
736
    requirements_dir = ROOT_DIR / "requirements"
737

738
    def _read_requirements(filename: str) -> list[str]:
739
        with open(requirements_dir / filename) as f:
740
            requirements = f.read().strip().split("\n")
741
742
743
744
        resolved_requirements = []
        for line in requirements:
            if line.startswith("-r "):
                resolved_requirements += _read_requirements(line.split()[1])
745
746
            elif not line.startswith("--") and not line.startswith(
                    "#") and line.strip() != "":
747
748
749
                resolved_requirements.append(line)
        return resolved_requirements

750
    if _no_device():
751
        requirements = _read_requirements("common.txt")
752
    elif _is_cuda():
753
        requirements = _read_requirements("cuda.txt")
754
        cuda_major, cuda_minor = torch.version.cuda.split(".")
755
756
        modified_requirements = []
        for req in requirements:
757
758
            if ("vllm-flash-attn" in req and cuda_major != "12"):
                # vllm-flash-attn is built only for CUDA 12.x.
759
760
761
                # Skip for other versions.
                continue
            modified_requirements.append(req)
762
        requirements = modified_requirements
763
    elif _is_hip():
764
        requirements = _read_requirements("rocm.txt")
765
    elif _is_neuron():
766
        requirements = _read_requirements("neuron.txt")
767
    elif _is_hpu():
768
        requirements = _read_requirements("hpu.txt")
769
    elif _is_tpu():
770
        requirements = _read_requirements("tpu.txt")
771
    elif _is_cpu():
772
        requirements = _read_requirements("cpu.txt")
773
    elif _is_xpu():
774
        requirements = _read_requirements("xpu.txt")
775
    else:
776
        raise ValueError(
777
            "Unsupported platform, please use CUDA, ROCm, Neuron, HPU, "
778
            "or CPU.")
779
780
781
    return requirements


bnellnm's avatar
bnellnm committed
782
783
ext_modules = []

zhuwenwen's avatar
zhuwenwen committed
784
785
786
if not skip_vllm_build:
    if _is_cuda() or _is_hip():
        ext_modules.append(CMakeExtension(name="vllm._moe_C"))
bnellnm's avatar
bnellnm committed
787

788
789
# if _is_hip():
#     ext_modules.append(CMakeExtension(name="vllm._rocm_C"))
790

791
if _is_cuda():
792
    ext_modules.append(CMakeExtension(name="vllm.vllm_flash_attn._vllm_fa2_C"))
793
794
    if envs.VLLM_USE_PRECOMPILED or get_nvcc_cuda_version() >= Version("12.3"):
        # FA3 requires CUDA 12.3 or later
795
796
        ext_modules.append(
            CMakeExtension(name="vllm.vllm_flash_attn._vllm_fa3_C"))
797
798
799
800
        # Optional since this doesn't get built (produce an .so file) when
        # not targeting a hopper system
        ext_modules.append(
            CMakeExtension(name="vllm._flashmla_C", optional=True))
801
    ext_modules.append(CMakeExtension(name="vllm.cumem_allocator"))
802

803
if _build_custom_ops():
bnellnm's avatar
bnellnm committed
804
805
    ext_modules.append(CMakeExtension(name="vllm._C"))

zhuwenwen's avatar
zhuwenwen committed
806
if skip_vllm_build:
zhuwenwen's avatar
zhuwenwen committed
807
    prepare_so_files()
zhuwenwen's avatar
zhuwenwen committed
808
809
810
811
812
813
814
815
    package_data = {
        "vllm": [
            "py.typed",
            "model_executor/layers/fused_moe/configs/*.json",
            "model_executor/layers/quantization/utils/configs/*.json",
            "perf/*.py",
            "attention/backends/configs/*.json",
            "model_executor/layers/quantization/configs/awq/*.json",
zhuwenwen's avatar
zhuwenwen committed
816
817
            "_C.abi3.so",
            "_moe_C.abi3.so",
zhuwenwen's avatar
zhuwenwen committed
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
        ]
    }
else:
    package_data = {
        "vllm": [
            "py.typed",
            "model_executor/layers/fused_moe/configs/*.json",
            "model_executor/layers/quantization/utils/configs/*.json",
            "perf/*.py",
            "attention/backends/configs/*.json",
            "model_executor/layers/quantization/configs/awq/*.json",
        ]
    }

if _no_device() or skip_vllm_build:
833
834
    ext_modules = []

835
836
837
838
839
840
841
842
if not ext_modules:
    cmdclass = {}
else:
    cmdclass = {
        "build_ext":
        repackage_wheel if envs.VLLM_USE_PRECOMPILED else cmake_build_ext
    }

bnellnm's avatar
bnellnm committed
843
setup(
844
    # static metadata should rather go in pyproject.toml
845
    version=get_vllm_version(),
Woosuk Kwon's avatar
Woosuk Kwon committed
846
    ext_modules=ext_modules,
847
    install_requires=get_requirements(),
848
    extras_require={
849
        "bench": ["pandas", "datasets"],
850
        "tensorizer": ["tensorizer>=2.9.0"],
851
        "fastsafetensors": ["fastsafetensors >= 0.1.10"],
852
        "runai": ["runai-model-streamer", "runai-model-streamer-s3", "boto3"],
853
        "audio": ["librosa", "soundfile"],  # Required for audio processing
854
        "video": []  # Kept for backwards compatibility
855
    },
856
    cmdclass=cmdclass,
Simon Mo's avatar
Simon Mo committed
857
    package_data=package_data,
zhuwenwen's avatar
zhuwenwen committed
858
)