Ray is an AI compute engine. Ray consists of a core distributed runtime and a set of AI Libraries for accelerating ML workloads.
This report presents the forensic synthetic code analysis of ray-project/ray, a Python project with 43,407 GitHub stars. SynthScan v2.0 examined 1,576,244 lines of code across 7451 source files, recording 27042 pattern matches distributed across 26 syntactic categories. The overall adjusted score of 22.0 places this repository in the Moderate AI signal band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 27042 distinct pattern matches across 26 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/setup.py | 423 | def is_native_windows_or_msys(): | CODE |
| LOW | python/setup.py | 429 | def is_invalid_windows_platform(): | CODE |
| LOW | python/setup.py | 484 | def replace_symlinks_with_junctions(): | CODE |
| LOW | python/ray/client_builder.py | 345 | def _get_builder_from_address(address: Optional[str]) -> ClientBuilder: | CODE |
| LOW | python/ray/runtime_context.py | 461 | def was_current_actor_reconstructed(self): | CODE |
| LOW | python/ray/runtime_context.py | 475 | def current_placement_group_id(self): | CODE |
| LOW | python/ray/runtime_context.py | 493 | def should_capture_child_tasks_in_placement_group(self): | CODE |
| LOW | python/ray/cross_language.py | 124 | def _get_function_descriptor_for_actor_method( | CODE |
| LOW | python/ray/cluster_utils.py | 402 | def remaining_processes_alive(self): | CODE |
| LOW | python/ray/exceptions.py | 121 | def _is_hidden_internal_frame(line: str, extra_markers: Sequence[str] = ()) -> bool: | CODE |
| LOW | python/ray/exceptions.py | 207 | def make_dual_exception_instance(self) -> "RayTaskError": | CODE |
| LOW | python/ray/exceptions.py | 221 | def _make_normal_dual_exception_instance(self) -> "RayTaskError": | CODE |
| LOW | python/ray/exceptions.py | 255 | def _make_exceptiongroup_dual_exception_instance(self) -> "RayTaskError": | CODE |
| LOW | python/ray/actor.py | 1690 | def _ray_from_function_descriptor( | CODE |
| LOW | python/ray/job_config.py | 172 | def set_default_actor_lifetime(self, default_actor_lifetime: str) -> None: | CODE |
| LOW⚡ | python/ray/job_config.py | 256 | def _runtime_env_has_working_dir(self): | CODE |
| LOW⚡ | python/ray/job_config.py | 259 | def _get_serialized_runtime_env(self) -> str: | CODE |
| LOW⚡ | python/ray/job_config.py | 263 | def _get_proto_runtime_env_config(self) -> str: | CODE |
| LOW | python/ray/runtime_env/runtime_env.py | 97 | def parse_and_validate_runtime_env_config( | CODE |
| LOW | python/ray/runtime_env/runtime_env.py | 124 | def build_proto_runtime_env_config(self) -> ProtoRuntimeEnvConfig: | CODE |
| LOW | python/ray/experimental/shuffle.py | 286 | def output_writer_non_streaming( | CODE |
| LOW | python/ray/experimental/internal_kv.py | 16 | def internal_kv_get_gcs_client(): | CODE |
| LOW | python/ray/experimental/locations.py | 45 | def get_local_object_locations( | CODE |
| LOW | python/ray/experimental/tqdm_ray.py | 316 | def _process_state_update_locked(self, state: ProgressBarState) -> None: | CODE |
| LOW | python/ray/experimental/tqdm_ray.py | 378 | def _get_or_allocate_bar_group(self, state: ProgressBarState): | CODE |
| LOW | python/ray/experimental/collective/conftest.py | 201 | def mock_do_destroy_nccl_group(self, group_id: str) -> None: | CODE |
| LOW | python/ray/experimental/collective/conftest.py | 231 | def check_nccl_group_teardown( | CODE |
| LOW | python/ray/experimental/collective/collective.py | 39 | def remove_remote_communicator(self, name: str): | CODE |
| LOW | python/ray/experimental/collective/collective.py | 134 | def _do_init_collective_group(self, rank: int): | CODE |
| LOW | python/ray/experimental/collective/collective.py | 182 | def _do_destroy_collective_group(self): | CODE |
| LOW | python/ray/experimental/collective/collective.py | 200 | def destroy_all_collective_groups(): | CODE |
| LOW | python/ray/experimental/channel/accelerator_context.py | 222 | def register_accelerator_context( | CODE |
| LOW | python/ray/experimental/channel/accelerator_context.py | 236 | def is_accelerator_context_registered(): | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 335 | def ensure_registered_as_writer(self) -> None: | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 357 | def ensure_registered_as_reader(self) -> None: | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 369 | def _deserialize_reader_channel( | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 410 | def _resize_channel_if_needed(self, serialized_value: str, timeout_ms: int): | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 584 | def ensure_registered_as_writer(self): | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 591 | def ensure_registered_as_reader(self): | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 760 | def ensure_registered_as_writer(self) -> None: | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 767 | def ensure_registered_as_reader(self) -> None: | CODE |
| LOW | python/ray/experimental/channel/torch_tensor_type.py | 117 | def register_custom_serializer(self) -> None: | CODE |
| LOW | …thon/ray/experimental/channel/intra_process_channel.py | 38 | def ensure_registered_as_writer(self) -> None: | CODE |
| LOW | …thon/ray/experimental/channel/intra_process_channel.py | 41 | def ensure_registered_as_reader(self) -> None: | CODE |
| LOW | python/ray/experimental/channel/cached_channel.py | 38 | def ensure_registered_as_writer(self) -> None: | CODE |
| LOW | python/ray/experimental/channel/cached_channel.py | 42 | def ensure_registered_as_reader(self) -> None: | CODE |
| LOW⚡ | …thon/ray/experimental/channel/serialization_context.py | 74 | def set_use_external_transport(self, use_external_transport: bool) -> None: | CODE |
| LOW⚡ | …thon/ray/experimental/channel/serialization_context.py | 81 | def reset_out_of_band_tensors( | CODE |
| LOW | …thon/ray/experimental/channel/serialization_context.py | 113 | def serialize_to_numpy_or_scalar( | CODE |
| LOW | …thon/ray/experimental/channel/serialization_context.py | 170 | def deserialize_from_numpy_or_scalar( | CODE |
| LOW | python/ray/experimental/channel/common.py | 35 | def retry_and_check_interpreter_exit(f: Callable[[], None]) -> bool: | CODE |
| LOW | python/ray/experimental/channel/common.py | 68 | def register_custom_serializer(self) -> None: | CODE |
| LOW | python/ray/experimental/channel/common.py | 201 | def ensure_registered_as_writer(self): | CODE |
| LOW | python/ray/experimental/channel/common.py | 207 | def ensure_registered_as_reader(self): | CODE |
| LOW | python/ray/experimental/channel/common.py | 324 | def _consume_leftover_channels_if_needed( | CODE |
| LOW | python/ray/experimental/channel/utils.py | 17 | def split_readers_by_locality( | CODE |
| LOW | python/ray/experimental/channel/utils.py | 46 | def split_actors_by_node_locality( | CODE |
| LOW | …perimental/channel/torch_tensor_accelerator_channel.py | 167 | def ensure_registered_as_writer(self): | CODE |
| LOW | …perimental/channel/torch_tensor_accelerator_channel.py | 174 | def ensure_registered_as_reader(self): | CODE |
| LOW | …perimental/channel/torch_tensor_accelerator_channel.py | 463 | def ensure_registered_as_writer(self): | CODE |
| 13677 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | python/requirements/ml/rllib-test-requirements.txt | 6 | # --------------------- | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 27 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 29 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 126 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 128 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 179 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 181 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 399 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 401 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 440 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 442 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | …y/llm/_internal/batch/benchmark/benchmark_processor.py | 416 | # ----------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …y/llm/_internal/batch/benchmark/benchmark_processor.py | 418 | # ----------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …y/llm/_internal/batch/benchmark/benchmark_processor.py | 508 | # ----------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …y/llm/_internal/batch/benchmark/benchmark_processor.py | 510 | # ----------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/interactive.py | 47 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/interactive.py | 49 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/interactive.py | 57 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/interactive.py | 59 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/interactive.py | 799 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/interactive.py | 801 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/interactive.py | 87 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/interactive.py | 89 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/interactive.py | 166 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/interactive.py | 168 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/interactive.py | 400 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/interactive.py | 402 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/interactive.py | 737 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/interactive.py | 739 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/runners.py | 63 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/runners.py | 65 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/runners.py | 545 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/runners.py | 547 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/runners.py | 550 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/runners.py | 552 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/runners.py | 763 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/runners.py | 765 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/runners.py | 771 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/runners.py | 773 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 37 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 39 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 257 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 259 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 278 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 280 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 466 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 468 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 522 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 524 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 616 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 618 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 686 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 688 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 823 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 825 | # ============================================================================ | COMMENT |
| MEDIUM | …ernal/serve/serving_patterns/prefill_decode/builder.py | 45 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ernal/serve/serving_patterns/prefill_decode/builder.py | 48 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ernal/serve/serving_patterns/prefill_decode/builder.py | 72 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ernal/serve/serving_patterns/prefill_decode/builder.py | 74 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ernal/serve/serving_patterns/prefill_decode/builder.py | 217 | # --------------------------------------------------------------------------- | COMMENT |
| 717 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 108 | CODE | |
| LOW | python/ray/__init__.py | 108 | CODE | |
| LOW | python/ray/__init__.py | 108 | CODE | |
| LOW | python/ray/__init__.py | 108 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 132 | CODE | |
| LOW | python/ray/__init__.py | 137 | CODE | |
| LOW | python/ray/__init__.py | 140 | CODE | |
| LOW | python/ray/__init__.py | 140 | CODE | |
| LOW | python/ray/__init__.py | 141 | CODE | |
| LOW | python/ray/__init__.py | 142 | CODE | |
| LOW | python/ray/__init__.py | 143 | CODE | |
| LOW | python/ray/__init__.py | 147 | CODE | |
| LOW | python/ray/__init__.py | 147 | CODE | |
| LOW | python/ray/__init__.py | 283 | CODE | |
| LOW | python/ray/__init__.py | 284 | CODE | |
| LOW | python/ray/__init__.py | 285 | CODE | |
| LOW | python/ray/cross_language.py | 1 | CODE | |
| LOW | python/ray/cross_language.py | 1 | CODE | |
| LOW | python/ray/cross_language.py | 1 | CODE | |
| LOW | python/ray/runtime_env/__init__.py | 1 | CODE | |
| LOW | python/ray/runtime_env/__init__.py | 1 | CODE | |
| LOW | python/ray/experimental/queue.py | 3 | CODE | |
| LOW | python/ray/experimental/queue.py | 3 | CODE | |
| LOW | python/ray/experimental/queue.py | 3 | CODE | |
| LOW | python/ray/experimental/__init__.py | 1 | CODE | |
| LOW | python/ray/experimental/__init__.py | 2 | CODE | |
| LOW | python/ray/experimental/__init__.py | 2 | CODE | |
| LOW | python/ray/experimental/__init__.py | 3 | CODE | |
| LOW | python/ray/experimental/__init__.py | 3 | CODE | |
| LOW | python/ray/experimental/__init__.py | 3 | CODE | |
| 2458 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .readthedocs.yaml | 1 | # .readthedocs.yaml | COMMENT |
| LOW | .readthedocs.yaml | 21 | # Code sources (python/ray/, rllib/) are intentionally not matched, so a | COMMENT |
| LOW | .readthedocs.yaml | 61 | # config value differs between the environment that produced the cache and | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 1 | --extra-index-url https://download.pytorch.org/whl/cpu | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 21 | # tensorflow-metadata | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 41 | aioboto3==12.1.0 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 61 | # delta-sharing | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 81 | alembic==1.18.4 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 101 | # httpx | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 121 | # via | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 141 | # via -r python/requirements/py313/test-requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 161 | # via cfn-lint | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 181 | # azure-mgmt-core | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 201 | # via -r python/requirements/py313/test-requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 221 | # via | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 241 | # glom | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 261 | # aws-xray-sdk | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 281 | celery==5.6.3 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 301 | # moocore | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 321 | # click-didyoumean | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 341 | click-plugins==1.1.1.2 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 361 | # nevergrad | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 381 | # ipykernel | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 401 | # via gsutil | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 421 | # -r python/requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 441 | # evaluate | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 461 | # via delta-sharing | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 481 | # -r python/requirements/ml/py313/data-requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 501 | # mlflow | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 521 | # array-record | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 541 | # -r python/requirements/py313/test-requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 561 | filelock==3.29.0 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 581 | # via | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 601 | fsspec==2023.12.1 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 621 | fugue==0.9.7 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 641 | # mujoco | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 661 | # gcs-oauth2-boto-plugin | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 681 | # -r python/requirements/ml/py313/data-test-requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 701 | # google-cloud-bigquery | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 721 | # graphene | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 741 | # opentelemetry-exporter-otlp-proto-grpc | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 761 | # shimmy | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 781 | # -r python/requirements/ml/py313/tune-test-requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 801 | # gradio-client | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 821 | # via azure-cli-core | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 841 | # moviepy | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 861 | # prophet | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 881 | # via | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 901 | # via ipython | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 921 | # torch-geometric | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 941 | jsonpath-ng==1.8.0 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 961 | jsonschema-path==0.3.4 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 981 | # nbconvert | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 1001 | jupyterlab-server==2.28.0 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 1021 | kubernetes==24.2.0 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 1041 | # lightning | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 1061 | # -r python/requirements/py313/test-requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 1081 | # rich | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 1101 | mdit-py-plugins==0.3.5 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 1121 | # via | COMMENT |
| 2737 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | python/setup.py | 716 | # Create the target directory if it doesn't already exist. | COMMENT |
| MEDIUM | python/ray/cluster_utils.py | 172 | # Create a new global state accessor for fetching GCS table. | COMMENT |
| MEDIUM | python/ray/actor.py | 1284 | # Create an instance without __init__ called. | COMMENT |
| MEDIUM | python/ray/runtime_env/runtime_env.py | 160 | """This class is used to define a runtime environment for a job, task, | STRING |
| MEDIUM | python/ray/experimental/shuffle.py | 42 | """This class is used to stream shuffle map outputs to the object store. | STRING |
| MEDIUM | …thon/ray/experimental/channel/shared_memory_channel.py | 720 | # Create a local channel for the writer and the local readers. | COMMENT |
| MEDIUM | python/ray/experimental/channel/common.py | 36 | """This function is only useful when f contains channel read/write. | STRING |
| MEDIUM | …perimental/channel/torch_tensor_accelerator_channel.py | 136 | # Create a CPU channel to send non-tensor data. | COMMENT |
| MEDIUM | python/ray/experimental/rdt/cuda_ipc_transport.py | 77 | # Create an interprocess-shareable CUDA event so that the receiver | COMMENT |
| MEDIUM | python/ray/llm/_internal/common/utils/cloud_utils.py | 530 | # Create a single cache instance for this function | COMMENT |
| MEDIUM | python/ray/llm/_internal/common/utils/download_utils.py | 278 | # Create the torch cache kernels directory if it doesn't exist. | COMMENT |
| MEDIUM | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 145 | # Create the adlfs filesystem | COMMENT |
| MEDIUM | …/ray/llm/_internal/batch/stages/sglang_engine_stage.py | 264 | # Create an LLM engine. | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/core/ingress/ingress.py | 210 | # Create a new class that inherits from the original to avoid modifying it | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/core/ingress/utils.py | 118 | # Create a new generator that yields the peeked item first | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/utils/registry.py | 74 | # Create a loader callable that imports on demand | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/utils/registry.py | 100 | # Create a registry for a component category | STRING |
| MEDIUM | python/ray/llm/_internal/serve/utils/registry.py | 151 | # Create a loader callable (handles both direct values and string paths) | COMMENT |
| MEDIUM⚡ | …_internal/serve/observability/usage_telemetry/usage.py | 83 | """This method is only used in tests to record the telemetry tags to a different | STRING |
| MEDIUM⚡ | …_internal/serve/observability/usage_telemetry/usage.py | 88 | """This method is only used in tests to clean up the models list.""" | STRING |
| MEDIUM | python/ray/llm/tests/conftest.py | 244 | # Create a vLLM serve deployment | STRING |
| MEDIUM | python/ray/llm/tests/common/cloud/test_s3_filesystem.py | 344 | # Create a test file | COMMENT |
| MEDIUM⚡ | python/ray/llm/tests/common/cloud/test_s3_filesystem.py | 365 | # Create a test file | COMMENT |
| MEDIUM | …y/llm/tests/batch/gpu/stages/test_vllm_engine_stage.py | 27 | # Create a mock instance that will be returned by the wrapper class | COMMENT |
| MEDIUM | …/tests/batch/gpu/stages/test_serve_deployment_stage.py | 69 | # Create a mock response that will be returned directly | COMMENT |
| MEDIUM | …llm/tests/batch/gpu/stages/test_sglang_engine_stage.py | 23 | # Create a mock instance that will be returned by the wrapper class | COMMENT |
| MEDIUM | …llm/tests/batch/gpu/stages/test_sglang_engine_stage.py | 90 | # Create a mock SGLang output | COMMENT |
| MEDIUM | …llm/tests/batch/gpu/stages/test_sglang_engine_stage.py | 265 | # Create a task type that doesn't exist in the prepare_llm_request method | COMMENT |
| MEDIUM | …/llm/tests/batch/cpu/stages/test_http_request_stage.py | 99 | # Create a fake session | COMMENT |
| MEDIUM⚡ | python/ray/llm/tests/serve/conftest.py | 124 | # Create a mock audio file for testing | COMMENT |
| MEDIUM⚡ | python/ray/llm/tests/serve/conftest.py | 129 | # Create a simple mock audio file (WAV format) | COMMENT |
| MEDIUM | …llm/tests/serve/cpu/deployments/routers/test_router.py | 501 | # Create a mock deployment handle that captures raw_request_info | COMMENT |
| MEDIUM | …llm/tests/serve/cpu/deployments/routers/test_router.py | 537 | # Create a mock FastAPI request | COMMENT |
| MEDIUM | …e/cpu/deployments/routers/test_make_fastapi_ingress.py | 29 | # Create the ingress class - should not raise | COMMENT |
| MEDIUM | …llm/tests/serve/cpu/deployments/llm/test_llm_server.py | 328 | # Create a server with a mocked engine | COMMENT |
| MEDIUM | …llm/tests/serve/cpu/deployments/llm/test_llm_server.py | 351 | # Create a server with a mocked engine | COMMENT |
| MEDIUM | …llm/tests/serve/cpu/deployments/llm/test_llm_server.py | 374 | # Create a server with a mocked engine | COMMENT |
| MEDIUM | …llm/tests/serve/cpu/deployments/llm/test_llm_server.py | 397 | # Create a server with a mocked engine | COMMENT |
| MEDIUM | …llm/tests/serve/cpu/deployments/llm/test_llm_server.py | 428 | # Create a chat completion request | COMMENT |
| MEDIUM | …loyments/llm/vllm/kv_transfer_backends/test_factory.py | 40 | # Create a Serve deployment that will run in a different process than the | COMMENT |
| MEDIUM | …/cpu/deployments/llm/multiplex/test_multiplex_utils.py | 32 | # Create a mock that raises ValueError twice then succeeds | COMMENT |
| MEDIUM | …/cpu/deployments/llm/multiplex/test_multiplex_utils.py | 52 | # Create a mock that always raises ValueError | COMMENT |
| MEDIUM | …/cpu/deployments/llm/multiplex/test_multiplex_utils.py | 74 | # Create a mock that raises TypeError | COMMENT |
| MEDIUM | …/cpu/deployments/llm/multiplex/test_multiplex_utils.py | 96 | # Create a mock that always raises ValueError | COMMENT |
| MEDIUM | …/cpu/deployments/llm/multiplex/test_multiplex_utils.py | 121 | # Create a mock that always raises ValueError | COMMENT |
| MEDIUM⚡ | …/cpu/deployments/llm/multiplex/test_multiplex_utils.py | 146 | # Define a function with docstring and name | COMMENT |
| MEDIUM | …pu/deployments/llm/multiplex/test_lora_model_loader.py | 56 | # Create a simple mock for sync_model | COMMENT |
| MEDIUM | …pu/deployments/llm/multiplex/test_lora_model_loader.py | 93 | # Create a mock for sync_files_with_lock that tracks calls and fails initially | COMMENT |
| MEDIUM | …pu/deployments/llm/multiplex/test_lora_model_loader.py | 140 | # Create a mock for sync_files_with_lock that tracks calls and fails initially | COMMENT |
| MEDIUM | …lm/tests/serve/cpu/deployments/utils/test_broadcast.py | 11 | # Define a simple deployment for testing | COMMENT |
| MEDIUM | python/ray/util/tracing/setup_tempo_tracing.py | 1 | # This file is intended for examples exporting traces to a local OTLP listener | COMMENT |
| MEDIUM | …ective/collective_group/torch_gloo_collective_group.py | 106 | # Create a subgroup for this logical group. For the default group, use WORLD. | COMMENT |
| MEDIUM | python/ray/util/state/state_cli.py | 253 | # Create a table. | STRING |
| MEDIUM | python/ray/util/state/state_cli.py | 296 | # Create a table per callsite. | STRING |
| MEDIUM | python/ray/util/state/state_cli.py | 453 | # Create the State API server and put it into context | STRING |
| MEDIUM | python/ray/util/state/state_cli.py | 604 | # Create the State API server and put it into context | STRING |
| MEDIUM | python/ray/_common/tests/test_usage_stats.py | 1551 | # Create a mock response based on the URL. | COMMENT |
| MEDIUM | python/ray/_common/tests/test_signature.py | 95 | # Create a mock Cython function missing required attributes | COMMENT |
| MEDIUM | python/ray/_common/observability/__init__.py | 1 | """This module provides the Python API for emitting internal Ray events | STRING |
| MEDIUM | python/ray/dag/compiled_dag_node.py | 1660 | # Create an output channel for each output of the current node. | STRING |
| 739 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/ray/remote_function.py | 203 | Configures and overrides the task invocation parameters. The arguments are the same as those that can be passed | STRING |
| HIGH | python/ray/cluster_utils.py | 352 | Waits for correct number of nodes to be registered. This will wait until the number of live nodes in the client | STRING |
| HIGH | python/ray/actor.py | 948 | Convenience method for executing an actor method call with options. Same arguments as func._remote(), but retur | STRING |
| HIGH | python/ray/actor.py | 1732 | Configures and overrides the actor instantiation parameters. The arguments are the same as those that can be pa | STRING |
| HIGH | python/ray/actor.py | 2611 | Handle dynamic attribute access for actor methods. This method is called when accessing attributes that don't e | STRING |
| HIGH | python/ray/actor.py | 2844 | Run a closure remotely on this actor instance. Provides a standard way to execute an arbitrary callable on | STRING |
| HIGH | python/ray/job_config.py | 269 | Generates a JobConfig object from json. Examples: .. testcode:: from ray.job_confi | STRING |
| HIGH | python/ray/experimental/locations.py | 10 | Lookup the locations for a list of objects. It returns a dict maps from an object to its location. The dict exclude | STRING |
| HIGH | python/ray/experimental/locations.py | 48 | Lookup the locations for a list of objects *from the local core worker*. No RPCs are made in this method. It re | STRING |
| HIGH | python/ray/experimental/rdt/tensor_transport_manager.py | 224 | Wait for a previously initiated fetch to complete and return the tensors. The default implementation returns th | STRING |
| HIGH | python/ray/experimental/rdt/rdt_manager.py | 877 | Fetch and get RDT objects for a list of object IDs, pipelining async fetches. This is used in the ray. | STRING |
| HIGH | python/ray/experimental/rdt/nixl_tensor_transport.py | 478 | Waits for a previously initiated fetch to complete and returns the tensors. Args: fetch_request: Th | STRING |
| HIGH | python/ray/experimental/rdt/nixl_memory_pool.py | 107 | Allocate pool blocks for unique storages, copy data in, and return pool-backed tensor views for each input tenso | STRING |
| HIGH | python/ray/llm/_internal/common/utils/cloud_utils.py | 148 | Get the appropriate provider-specific filesystem class based on URI. Args: bucket_uri: URI of the c | STRING |
| HIGH | python/ray/llm/_internal/common/utils/import_utils.py | 11 | Try importing the module and returns the module (or None). Args: name: The name of the module to import. | STRING |
| HIGH | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 45 | Parse S3 URI into bucket and key. Args: uri: S3 URI (e.g., s3://bucket/path/to/object or s3://anony | STRING |
| HIGH | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 81 | Create an Azure filesystem for Azure Blob Storage or ABFSS. Args: object_uri: Azure URI (azure://co | STRING |
| HIGH | python/ray/llm/_internal/batch/benchmark/dataset.py | 45 | Sample prompts from the loaded dataset. Args: num_requests: The number of prompts to sampl | STRING |
| HIGH | python/ray/llm/_internal/batch/stages/base.py | 107 | A stage UDF wrapper that processes the input and output columns before and after the UDF. The expected | STRING |
| HIGH | python/ray/llm/_internal/batch/processor/base.py | 93 | Return a normalized dict of worker pool parameters from `self.concurrency`. Behavior: - If `concurrency | STRING |
| HIGH | …rnal/serve/serving_patterns/data_parallel/dp_server.py | 72 | Retrieve the DP master info for gang_id, polling until available. Args: gang_id: The ID of the gang | STRING |
| HIGH | python/ray/llm/_internal/serve/core/ingress/ingress.py | 177 | Create a Ray Serve ingress deployment from a class and endpoint mapping. Args: cls: The class to conve | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 59 | Run a ChatCompletion with the engine. To implement this method, you need to take a openAI compatible chat reque | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 88 | Run a Completion with the engine. Similar to chat, this method is an async generator, so it yields chunks | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 149 | Run a Transcription with the engine. Similar to chat and completion, this method is an async generator, | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 181 | Tokenize the input text. This method tokenizes the input prompt or chat messages and returns the token | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 205 | Detokenize the input token IDs. This method converts token IDs back into text. Args: reque | STRING |
| HIGH | python/ray/llm/_internal/serve/utils/registry.py | 52 | Create a loader callable for a value. Handles both direct objects/classes and string paths for lazy loading. A | STRING |
| HIGH | python/ray/llm/_internal/serve/utils/registry.py | 126 | Register a component. Args: name: The name to register under value: The component to re | STRING |
| HIGH | python/ray/llm/_internal/serve/utils/registry.py | 176 | Get a registered component. Args: name: The name of the component Returns: The | STRING |
| HIGH | …lm/_internal/serve/engines/vllm/kv_transfer/factory.py | 57 | Get the connector backend class by name. For registered connectors, returns the registered backend class. | STRING |
| HIGH | …_internal/serve/routing_policies/kv_aware/tokenizer.py | 121 | Tokenize a request ``payload`` into prompt token IDs. Args: payload: The request body, already pars | STRING |
| HIGH | …rnal/serve/routing_policies/kv_aware/vllm/tokenizer.py | 121 | Tokenize a request ``payload`` into prompt token IDs. Args: payload: The request body, already pars | STRING |
| HIGH | …e/routing_policies/prefix_aware/prefix_aware_router.py | 135 | Extracts the text content from a pending request for prefix matching. Searches through request arguments for ei | STRING |
| HIGH | python/ray/util/queue.py | 156 | Gets an item from the queue. If block is True and the queue is empty, blocks until the queue is no long | STRING |
| HIGH | python/ray/util/queue.py | 193 | Gets an item from the queue. There is no guarantee of order if multiple consumers get from the same emp | STRING |
| HIGH | python/ray/util/queue.py | 261 | Gets items from the queue and returns them in a list in order. Args: num_items: Number of i | STRING |
| HIGH | python/ray/util/iter.py | 86 | Create a parallel iterator from a list of iterables. An iterable can be a conatiner (list, str, tuple, set, etc.), | STRING |
| HIGH | python/ray/util/iter.py | 233 | Remotely transform the iterator. This is advanced version of for_each that allows you to apply arbitrary | STRING |
| HIGH | python/ray/util/iter.py | 266 | Remotely apply fn to each item in this iterator. If `max_concurrency` == 1 then `fn` will be executed serially | STRING |
| HIGH | python/ray/util/iter.py | 310 | Remotely filter items from this iterator. Args: fn: returns False for items to drop from the iterat | STRING |
| HIGH | python/ray/util/iter.py | 327 | Remotely batch together items in this iterator. Args: n: Number of items to batch together. | STRING |
| HIGH | python/ray/util/iter.py | 367 | Remotely shuffle items of each shard independently Args: shuffle_buffer_size: The algorithm fills a | STRING |
| HIGH | python/ray/util/iter.py | 404 | Returns a new ParallelIterator instance with num_partitions shards. The new iterator contains the same data in | STRING |
| HIGH | python/ray/util/iter.py | 558 | Returns a local iterable for asynchronous iteration. New items will be fetched from the shards asynchronously a | STRING |
| HIGH | python/ray/util/placement_group.py | 142 | Asynchronously creates a PlacementGroup. Args: bundles: A list of bundles which represent the r | STRING |
| HIGH | python/ray/util/tpu.py | 42 | Extracts the version from the accelerator type. Args: accelerator_type: The full accelerator type string (e | STRING |
| HIGH | python/ray/util/tpu.py | 997 | Run a remote function on every host in a TPU slice. Dispatches one task per host in the slice, pinning each task to | STRING |
| HIGH | python/ray/util/tpu.py | 2166 | Asynchronously creates a PlacementGroup for a TPU subslice. A subslice placement group reserves a contiguous subset | STRING |
| HIGH | python/ray/util/actor_pool.py | 255 | Returns the next pending result in order. This returns the next result produced by submit(), blocking for up to | STRING |
| HIGH | python/ray/util/actor_pool.py | 330 | Returns any of the next pending results. This returns some result produced by submit(), blocking for up to | STRING |
| HIGH | python/ray/util/annotations.py | 34 | Annotation for documenting public APIs. Public APIs are classes and methods exposed to end users of Ray. If `` | STRING |
| HIGH | python/ray/util/annotations.py | 108 | Annotation for documenting developer APIs. Developer APIs are lower-level methods explicitly exposed to advanced Ra | STRING |
| HIGH | python/ray/util/annotations.py | 168 | Annotation for documenting a deprecated API. Deprecated APIs may be removed in future releases of Ray. Args: | STRING |
| HIGH | python/ray/util/dask/scheduler_utils.py | 48 | Start state from a dask. Args: dsk: A dask dictionary specifying a workflow. cache: Temporary stora | STRING |
| HIGH | python/ray/util/dask/scheduler_utils.py | 196 | Get nested index from collection. Args: ind: Index or nested list of indices. coll: Collection to i | STRING |
| HIGH | python/ray/util/state/state_manager.py | 79 | Apply the network error handling logic to each APIs, such as retry or exception policies. Args: | STRING |
| HIGH | python/ray/util/state/api.py | 263 | Get resources states by id Args: resource: Resource names, i.e. 'workers', 'actors', 'nodes', | STRING |
| HIGH | python/ray/util/state/api.py | 476 | List resources states Args: resource: Resource names, i.e. 'jobs', 'actors', 'nodes', | STRING |
| HIGH | python/ray/util/state/api.py | 525 | Summarize resources states Args: resource: Resource names, see `SummaryResource` fo | STRING |
| 366 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/client_builder.py | 367 | except Exception as e: | CODE |
| MEDIUM | python/ray/setup-dev.py | 146 | print("Error: --skip and --allow cannot be used together.") | CODE |
| LOW | python/ray/exceptions.py | 51 | except Exception: | CODE |
| LOW | python/ray/exceptions.py | 314 | except Exception as e: | CODE |
| LOW | python/ray/exceptions.py | 834 | except Exception: | CODE |
| LOW | python/ray/actor.py | 1646 | except Exception as e: | CODE |
| MEDIUM | python/ray/actor.py | 1643 | def __init__(self, *args, **kwargs): | CODE |
| LOW | python/ray/experimental/shuffle.py | 319 | except Exception: | CODE |
| LOW | python/ray/experimental/compiled_dag_ref.py | 139 | except Exception as execution_error: | CODE |
| LOW | python/ray/experimental/compiled_dag_ref.py | 145 | except Exception: | CODE |
| LOW | python/ray/experimental/rdt/cuda_ipc_transport.py | 181 | except Exception as e: | CODE |
| LOW | python/ray/experimental/rdt/rdt_manager.py | 330 | except Exception as e: | CODE |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 69 | except Exception: | CODE |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 462 | except Exception: | CODE |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 525 | except Exception: | CODE |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 682 | except Exception as e: | CODE |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 756 | except Exception: | CODE |
| LOW | python/ray/experimental/rdt/rdt_store.py | 88 | except Exception as e: | CODE |
| LOW | python/ray/experimental/rdt/nixl_memory_pool.py | 196 | except Exception: | CODE |
| LOW | python/ray/experimental/rdt/nixl_memory_pool.py | 203 | except Exception as cleanup_err: | CODE |
| LOW | python/ray/llm/_internal/common/callbacks/base.py | 109 | except Exception as e: | CODE |
| LOW | python/ray/llm/_internal/common/callbacks/base.py | 131 | except Exception as e: | CODE |
| LOW | …ray/llm/_internal/common/patches/vllm/tokenize_once.py | 87 | except Exception as e: # pragma: no cover - defensive | CODE |
| LOW | python/ray/llm/_internal/common/utils/cloud_utils.py | 286 | except Exception as e: | CODE |
| LOW | python/ray/llm/_internal/common/utils/cloud_utils.py | 336 | except Exception as e: | CODE |
| LOW | python/ray/llm/_internal/common/utils/lora_utils.py | 127 | except Exception as e: | CODE |
| LOW | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 126 | except Exception as e: | CODE |
| LOW | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 165 | except Exception as e: | CODE |
| LOW | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 225 | except Exception as e: | CODE |
| LOW | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 346 | except Exception as e: | CODE |
| LOW | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 395 | except Exception as e: | CODE |
| LOW⚡ | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 248 | except Exception as e: | CODE |
| LOW | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 280 | except Exception as e: | CODE |
| LOW | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 358 | except Exception as e: | CODE |
| LOW | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 362 | except Exception as e: | CODE |
| LOW | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 387 | except Exception as e: | CODE |
| LOW | python/ray/llm/_internal/batch/benchmark/dataset.py | 138 | except Exception as e: | CODE |
| LOW⚡ | …y/llm/_internal/batch/benchmark/benchmark_processor.py | 322 | except Exception as e: | CODE |
| MEDIUM⚡ | …y/llm/_internal/batch/benchmark/benchmark_processor.py | 323 | print(f"Error checking app status: {e}") | CODE |
| LOW | …on/ray/llm/_internal/batch/stages/vllm_engine_stage.py | 784 | except Exception as e: | CODE |
| LOW | …y/llm/_internal/batch/stages/serve_deployment_stage.py | 183 | except Exception as e: | CODE |
| LOW | …ay/llm/_internal/batch/processor/sglang_engine_proc.py | 236 | except Exception as e: | CODE |
| LOW | …/ray/llm/_internal/batch/processor/vllm_engine_proc.py | 315 | except Exception: | CODE |
| LOW | …_internal/batch/observability/usage_telemetry/usage.py | 142 | except Exception: | CODE |
| LOW | …_internal/batch/observability/usage_telemetry/usage.py | 156 | except Exception: | CODE |
| LOW⚡ | python/ray/llm/_internal/serve/benchmark/interactive.py | 809 | except Exception as e: | CODE |
| LOW | python/ray/llm/_internal/serve/benchmark/interactive.py | 378 | except Exception as e: | CODE |
| LOW | python/ray/llm/_internal/serve/benchmark/interactive.py | 517 | except Exception as e: | CODE |
| LOW | python/ray/llm/_internal/serve/benchmark/interactive.py | 578 | except Exception as e: | CODE |
| LOW | python/ray/llm/_internal/serve/benchmark/interactive.py | 822 | except Exception as e: | CODE |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/runners.py | 45 | def emit(self, record): | CODE |
| LOW⚡ | python/ray/llm/_internal/serve/benchmark/runners.py | 50 | except Exception: | CODE |
| LOW | python/ray/llm/_internal/serve/benchmark/runners.py | 357 | except Exception as e: | CODE |
| LOW | python/ray/llm/_internal/serve/benchmark/runners.py | 645 | except Exception as e: | CODE |
| LOW | python/ray/llm/_internal/serve/benchmark/runners.py | 913 | except Exception as e: | CODE |
| LOW | python/ray/llm/_internal/serve/benchmark/runners.py | 929 | except Exception as e: | CODE |
| LOW | …rnal/serve/serving_patterns/data_parallel/dp_server.py | 59 | except Exception: | CODE |
| LOW | …nal/serve/serving_patterns/prefill_decode/pd_server.py | 425 | except Exception as exc: # pragma: no cover - defensive | CODE |
| LOW | …nal/serve/serving_patterns/prefill_decode/pd_server.py | 526 | except Exception as exc: | CODE |
| LOW | …hon/ray/llm/_internal/serve/core/ingress/middleware.py | 115 | except Exception as e: | CODE |
| 1425 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/ray/experimental/channel/cpu_communicator.py | 0 | return the given actor's rank in the group. args: actor: the actor handle to look up. returns: the rank of ``actor`` wit | STRING |
| HIGH | python/ray/experimental/channel/nccl_group.py | 0 | return the given actor's rank in the group. args: actor: the actor handle to look up. returns: the rank of ``actor`` wit | STRING |
| HIGH | python/ray/experimental/channel/communicator.py | 0 | return the given actor's rank in the group. args: actor: the actor handle to look up. returns: the rank of ``actor`` wit | STRING |
| HIGH | python/ray/llm/_internal/common/models.py | 0 | take a blocking function, and run it on in an executor thread. this function prevents the blocking function from blockin | STRING |
| HIGH | python/ray/llm/_internal/serve/utils/server_utils.py | 0 | take a blocking function, and run it on in an executor thread. this function prevents the blocking function from blockin | STRING |
| HIGH | release/llm_tests/serve/probes/util.py | 0 | take a blocking function, and run it on in an executor thread. this function prevents the blocking function from blockin | STRING |
| HIGH | python/ray/llm/_internal/common/utils/cloud_utils.py | 0 | download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8 | STRING |
| HIGH | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 0 | download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8 | STRING |
| HIGH | …ay/llm/_internal/common/utils/cloud_filesystem/base.py | 0 | download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8 | STRING |
| HIGH | …ternal/common/utils/cloud_filesystem/gcs_filesystem.py | 0 | download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8 | STRING |
| HIGH | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 0 | download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8 | STRING |
| HIGH | …rnal/common/utils/cloud_filesystem/azure_filesystem.py | 0 | download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8 | STRING |
| HIGH | python/ray/llm/_internal/common/utils/cloud_utils.py | 0 | list the immediate subfolders in a cloud directory. args: folder_uri: uri of the directory (s3://, gs://, abfss://, or a | STRING |
| HIGH | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 0 | list the immediate subfolders in a cloud directory. args: folder_uri: uri of the directory (s3://, gs://, abfss://, or a | STRING |
| HIGH | …ay/llm/_internal/common/utils/cloud_filesystem/base.py | 0 | list the immediate subfolders in a cloud directory. args: folder_uri: uri of the directory (s3://, gs://, abfss://, or a | STRING |
| HIGH | python/ray/llm/_internal/common/utils/cloud_utils.py | 0 | download files from cloud storage to a local directory. args: path: local directory where files will be downloaded bucke | STRING |
| HIGH | …ternal/common/utils/cloud_filesystem/gcs_filesystem.py | 0 | download files from cloud storage to a local directory. args: path: local directory where files will be downloaded bucke | STRING |
| HIGH | …rnal/common/utils/cloud_filesystem/azure_filesystem.py | 0 | download files from cloud storage to a local directory. args: path: local directory where files will be downloaded bucke | STRING |
| HIGH | …ay/llm/_internal/common/utils/cloud_filesystem/base.py | 0 | download files from cloud storage to a local directory. args: path: local directory where files will be downloaded bucke | STRING |
| HIGH | python/ray/llm/_internal/common/utils/cloud_utils.py | 0 | upload files to cloud storage. args: local_path: the local path of the files to upload. bucket_uri: the bucket uri to up | STRING |
| HIGH | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 0 | upload files to cloud storage. args: local_path: the local path of the files to upload. bucket_uri: the bucket uri to up | STRING |
| HIGH | …ay/llm/_internal/common/utils/cloud_filesystem/base.py | 0 | upload files to cloud storage. args: local_path: the local path of the files to upload. bucket_uri: the bucket uri to up | STRING |
| HIGH | …llm/_internal/common/observability/logging/__init__.py | 0 | get a structured logger inherited from the ray serve logger. loggers by default are logging to stdout, and are expected | STRING |
| HIGH | …/llm/_internal/batch/observability/logging/__init__.py | 0 | get a structured logger inherited from the ray serve logger. loggers by default are logging to stdout, and are expected | STRING |
| HIGH | …/llm/_internal/serve/observability/logging/__init__.py | 0 | get a structured logger inherited from the ray serve logger. loggers by default are logging to stdout, and are expected | STRING |
| HIGH | …ay/llm/_internal/common/observability/logging/setup.py | 0 | configures stdlib root logger to make sure stdlib loggers (created as `logging.getlogger(...)`) are using ray's `jsonfor | STRING |
| HIGH | …ray/llm/_internal/batch/observability/logging/setup.py | 0 | configures stdlib root logger to make sure stdlib loggers (created as `logging.getlogger(...)`) are using ray's `jsonfor | STRING |
| HIGH | …ray/llm/_internal/serve/observability/logging/setup.py | 0 | configures stdlib root logger to make sure stdlib loggers (created as `logging.getlogger(...)`) are using ray's `jsonfor | STRING |
| HIGH | …/ray/llm/_internal/batch/stages/sglang_engine_stage.py | 0 | the required input keys of the stage and their descriptions. | STRING |
| HIGH | …/ray/llm/_internal/batch/stages/chat_template_stage.py | 0 | the required input keys of the stage and their descriptions. | STRING |
| HIGH | …llm/_internal/batch/stages/prepare_multimodal_stage.py | 0 | the required input keys of the stage and their descriptions. | STRING |
| HIGH | …n/ray/llm/_internal/batch/stages/http_request_stage.py | 0 | the required input keys of the stage and their descriptions. | STRING |
| HIGH | …on/ray/llm/_internal/batch/stages/vllm_engine_stage.py | 0 | the required input keys of the stage and their descriptions. | STRING |
| HIGH | python/ray/llm/_internal/batch/stages/tokenize_stage.py | 0 | the required input keys of the stage and their descriptions. | STRING |
| HIGH | python/ray/llm/_internal/batch/stages/base.py | 0 | the required input keys of the stage and their descriptions. | STRING |
| HIGH | …/ray/llm/_internal/batch/stages/sglang_engine_stage.py | 0 | the optional input keys of the stage and their descriptions. | STRING |
| HIGH | …on/ray/llm/_internal/batch/stages/vllm_engine_stage.py | 0 | the optional input keys of the stage and their descriptions. | STRING |
| HIGH | python/ray/llm/_internal/batch/stages/base.py | 0 | the optional input keys of the stage and their descriptions. | STRING |
| HIGH | …ay/llm/_internal/batch/processor/sglang_engine_proc.py | 0 | construct a processor that runs a serve deployment. args: config: the configuration for the processor. preprocess: an op | STRING |
| HIGH | …/ray/llm/_internal/batch/processor/vllm_engine_proc.py | 0 | construct a processor that runs a serve deployment. args: config: the configuration for the processor. preprocess: an op | STRING |
| HIGH | …ray/llm/_internal/batch/processor/http_request_proc.py | 0 | construct a processor that runs a serve deployment. args: config: the configuration for the processor. preprocess: an op | STRING |
| HIGH | …llm/_internal/batch/processor/serve_deployment_proc.py | 0 | construct a processor that runs a serve deployment. args: config: the configuration for the processor. preprocess: an op | STRING |
| HIGH | python/ray/llm/_internal/serve/core/protocol.py | 0 | check the health of the engine. does not return anything. raise error when the engine is dead and needs to be restarted. | STRING |
| HIGH | …thon/ray/llm/_internal/serve/core/server/llm_server.py | 0 | check the health of the engine. does not return anything. raise error when the engine is dead and needs to be restarted. | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 0 | check the health of the engine. does not return anything. raise error when the engine is dead and needs to be restarted. | STRING |
| HIGH | python/ray/llm/_internal/serve/core/protocol.py | 0 | check whether the vllm engine is currently sleeping. returns: true if the engine is sleeping, false otherwise. | STRING |
| HIGH | …thon/ray/llm/_internal/serve/core/server/llm_server.py | 0 | check whether the vllm engine is currently sleeping. returns: true if the engine is sleeping, false otherwise. | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 0 | check whether the vllm engine is currently sleeping. returns: true if the engine is sleeping, false otherwise. | STRING |
| HIGH | …on/ray/llm/_internal/serve/engines/vllm/vllm_engine.py | 0 | check whether the vllm engine is currently sleeping. returns: true if the engine is sleeping, false otherwise. | STRING |
| HIGH | python/ray/llm/_internal/serve/core/protocol.py | 0 | check whether the vllm engine is currently paused. returns: true if the engine is paused, false otherwise. | STRING |
| HIGH | …thon/ray/llm/_internal/serve/core/server/llm_server.py | 0 | check whether the vllm engine is currently paused. returns: true if the engine is paused, false otherwise. | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 0 | check whether the vllm engine is currently paused. returns: true if the engine is paused, false otherwise. | STRING |
| HIGH | …on/ray/llm/_internal/serve/engines/vllm/vllm_engine.py | 0 | check whether the vllm engine is currently paused. returns: true if the engine is paused, false otherwise. | STRING |
| HIGH | …thon/ray/llm/_internal/serve/core/server/llm_server.py | 0 | execute a collective rpc call on all vllm workers. this is used for rlhf workflows where a trainer needs to execute meth | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 0 | execute a collective rpc call on all vllm workers. this is used for rlhf workflows where a trainer needs to execute meth | STRING |
| HIGH | …on/ray/llm/_internal/serve/engines/vllm/vllm_engine.py | 0 | execute a collective rpc call on all vllm workers. this is used for rlhf workflows where a trainer needs to execute meth | STRING |
| HIGH | python/ray/llm/tests/conftest.py | 0 | {% if messages[0]['role'] == 'system' %} {% set offset = 1 %} {% else %} {% set offset = 0 %} {% endif %} {{ bos_token } | STRING |
| HIGH | …llm/tests/batch/gpu/processor/test_vllm_engine_proc.py | 0 | {% if messages[0]['role'] == 'system' %} {% set offset = 1 %} {% else %} {% set offset = 0 %} {% endif %} {{ bos_token } | STRING |
| HIGH | release/llm_tests/batch/test_batch_sglang.py | 0 | {% if messages[0]['role'] == 'system' %} {% set offset = 1 %} {% else %} {% set offset = 0 %} {% endif %} {{ bos_token } | STRING |
| HIGH | python/ray/util/collective/collective.py | 0 | returns the ip address and a free port on this node. | STRING |
| 246 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/ray/util/timer.py | 37 | self.push(time_delta) | CODE |
| HIGH | python/ray/util/actor_pool.py | 500 | pool.push(a2) | STRING |
| HIGH | python/ray/util/dask/tests/test_dask_scheduler.py | 94 | assert sorted_with_pb.equals(sorted_without_pb) | CODE |
| HIGH⚡ | python/ray/tests/test_actor_pool.py | 263 | pool.push(a1) | CODE |
| HIGH⚡ | python/ray/tests/test_actor_pool.py | 264 | pool.push(a2) | CODE |
| HIGH⚡ | python/ray/tests/test_actor_pool.py | 271 | pool.push(a3) | CODE |
| HIGH | python/ray/tests/accelerators/test_neuron.py | 50 | b'"connected_to":null,"nc_count":2,' | CODE |
| HIGH⚡ | python/ray/tests/accelerators/test_neuron.py | 68 | b'"connected_to":null,"nc_count":2,' | CODE |
| HIGH⚡ | python/ray/tests/accelerators/test_neuron.py | 70 | b'{"neuron_device":1,"bdf":"00:1f.0","connected_to":null,' | CODE |
| HIGH | python/ray/tests/modin/modin_test_utils.py | 90 | and df1.columns.equals(df2.columns) | CODE |
| HIGH | python/ray/_private/thirdparty/tabulate/tabulate.py | 1941 | | spam || align="right"| 41.9999 | STRING |
| HIGH | python/ray/_private/thirdparty/tabulate/tabulate.py | 1943 | | eggs || align="right"| 451 | STRING |
| HIGH | python/ray/dashboard/modules/job/sdk.py | 485 | ... entrypoint="echo hi && sleep 5 && echo hi2") | STRING |
| HIGH | …on/ray/dashboard/modules/job/tests/test_job_manager.py | 1480 | entrypoint=f"{cmd} & {cmd} && wait && echo 'done'" | CODE |
| HIGH⚡ | …ay/dashboard/modules/job/tests/test_cli_integration.py | 187 | cmd = "sleep 1 && echo hello && sleep 1 && echo hello" | CODE |
| HIGH⚡ | …ay/dashboard/modules/job/tests/test_cli_integration.py | 197 | cmd = "echo hello && sleep 1000" | CODE |
| HIGH | …ay/dashboard/modules/job/tests/test_cli_integration.py | 258 | cmd = "echo hello && sleep 1000" | CODE |
| HIGH | …thon/ray/dashboard/modules/job/tests/test_job_agent.py | 189 | "python script.py && python -c 'import pip_install_test'" | STRING |
| HIGH | …ay/dashboard/modules/job/tests/test_http_job_server.py | 285 | "python script.py && python -c 'import pip_install_test'" | STRING |
| HIGH | …ay/dashboard/modules/job/tests/test_http_job_server.py | 507 | job_id = client.submit_job(entrypoint="sleep 300 && echo hello") | STRING |
| HIGH | python/ray/train/_internal/state/schema.py | 144 | "If null, the Train run has not ended yet.", | CODE |
| HIGH | python/ray/train/tests/test_state.py | 53 | "end_time_ms": null, | CODE |
| HIGH | python/ray/train/v2/_internal/state/schema.py | 257 | "If null, the attempt is still ongoing.", | CODE |
| HIGH | python/ray/train/v2/_internal/state/schema.py | 498 | "If null, the run is still in progress.", | CODE |
| HIGH | python/ray/autoscaler/launch_and_verify_cluster.py | 133 | f'pip3 uninstall -y ray && pip3 install -U "ray[default] @ {wheel_url}"' | CODE |
| HIGH | python/ray/autoscaler/_private/command_runner.py | 940 | "cat /proc/meminfo || true", with_output=True | CODE |
| HIGH | python/ray/autoscaler/_private/commands.py | 1149 | cmd = "tmux attach || tmux new" | CODE |
| HIGH | …thon/ray/autoscaler/_private/subprocess_output_util.py | 165 | # (-o UserKnownHostsFile=/dev/null), | COMMENT |
| HIGH | …thon/ray/autoscaler/_private/subprocess_output_util.py | 341 | (redirected to /dev/null), unless verbose logging | STRING |
| HIGH | …y/autoscaler/_private/fake_multi_node/node_provider.py | 150 | "((sudo apt update && sudo apt install -y openssh-server && " | CODE |
| HIGH | python/ray/serve/deployment.py | 271 | raise ValueError("`max_ongoing_requests` must be non-null, got None.") | CODE |
| HIGH | python/ray/serve/api.py | 634 | raise ValueError("`max_ongoing_requests` must be non-null, got None.") | CODE |
| HIGH | python/ray/serve/schema.py | 361 | "If null, the deployment won't autoscale its number of " | CODE |
| HIGH | python/ray/serve/schema.py | 778 | "If null, serve fallbacks to autoscaling policy in each deployment. " | CODE |
| HIGH | python/ray/serve/tests/test_task_processor.py | 847 | # Send an integer, for which len() is undefined, causing a TypeError | COMMENT |
| HIGH | python/ray/serve/tests/unit/test_controller.py | 201 | """When target capacity becomes null, scale up/down behavior must stop.""" | STRING |
| HIGH | python/ray/serve/tests/unit/test_controller.py | 230 | """When target capacity goes null -> non-null, scale down must start.""" | STRING |
| HIGH | python/ray/data/aggregate.py | 1390 | - If ignore_nulls=True, zero-factory returns null, therefore encoding empty | STRING |
| HIGH | python/ray/data/aggregate.py | 1430 | # If accumulator container is not null, finalize. | COMMENT |
| HIGH | python/ray/data/expressions.py | 71 | IS_NULL: Check if value is null | STRING |
| HIGH | python/ray/data/dataset.py | 3423 | ``False`` and any value is null, then the output is ``None``. | STRING |
| HIGH | python/ray/data/dataset.py | 3467 | ``False`` and any value is null, then the output is ``None``. | STRING |
| HIGH | python/ray/data/dataset.py | 3511 | ``False`` and any value is null, then the output is ``None``. | STRING |
| HIGH | python/ray/data/dataset.py | 3555 | ``False`` and any value is null, then the output is ``None``. | STRING |
| HIGH | python/ray/data/dataset.py | 3614 | ``False`` and any value is null, then the output is ``None``. | STRING |
| HIGH | python/ray/data/_internal/util.py | 1437 | return self._fs.equals(other) | CODE |
| HIGH | …thon/ray/data/_internal/datasource/parquet_datasink.py | 347 | if output_schema and not table.schema.equals(output_schema): | CODE |
| HIGH | …thon/ray/data/_internal/datasource/iceberg_datasink.py | 932 | if not final_reconciled_schema.equals(table_schema): | CODE |
| HIGH | python/ray/data/_internal/tensor_extensions/pandas.py | 290 | >>> read_df.equals(df) # doctest: +SKIP | STRING |
| HIGH | python/ray/data/_internal/tensor_extensions/pandas.py | 712 | >>> read_df.equals(df) # doctest: +SKIP | STRING |
| HIGH | …thon/ray/data/_internal/arrow_ops/transform_pyarrow.py | 462 | # All arrays are null, so the inferred type is null. | COMMENT |
| HIGH | …thon/ray/data/_internal/arrow_ops/transform_pyarrow.py | 469 | # If the type is null, we need to cast the array to the inferred type. | COMMENT |
| HIGH | …thon/ray/data/_internal/arrow_ops/transform_pyarrow.py | 649 | if block.schema.equals(schema): | CODE |
| HIGH | …thon/ray/data/_internal/arrow_ops/transform_pyarrow.py | 761 | [pa.nulls(c.length(), type=value_type)] | CODE |
| HIGH | …thon/ray/data/_internal/arrow_ops/transform_pyarrow.py | 1163 | return np.full(array.length(), np.nan, dtype=np.float32) | CODE |
| HIGH | python/ray/data/_internal/gpu_shuffle/hash_aggregate.py | 1264 | elif not current_dtype.equals(observed_arrow_dtype): | CODE |
| HIGH | …y/data/_internal/execution/streaming_executor_state.py | 294 | # If output split idx is null, fallback to the first queue | COMMENT |
| HIGH | …nal/logical/operators/tests/test_read_files_logical.py | 149 | assert actual.equals(expected.to_pyarrow()) | CODE |
| HIGH | python/ray/data/datasource/partitioning.py | 206 | with partition `"bar"`. If the base directory is undefined, then `"foo.csv"` would | STRING |
| HIGH | python/ray/data/datasource/partitioning.py | 337 | # checks validity/not-null, not the boolean value). | COMMENT |
| 176 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/setup.py | 484 | CODE | |
| LOW | python/setup.py | 729 | CODE | |
| LOW | python/setup.py | 83 | CODE | |
| LOW | python/ray/exceptions.py | 324 | CODE | |
| LOW | python/ray/runtime_env/runtime_env.py | 97 | CODE | |
| LOW | python/ray/experimental/channel/cpu_communicator.py | 69 | CODE | |
| LOW | python/ray/experimental/channel/common.py | 357 | CODE | |
| LOW | python/ray/experimental/channel/common.py | 456 | CODE | |
| LOW | python/ray/experimental/rdt/rdt_manager.py | 308 | CODE | |
| LOW | python/ray/experimental/rdt/rdt_manager.py | 548 | CODE | |
| LOW | python/ray/experimental/rdt/rdt_manager.py | 687 | CODE | |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 269 | CODE | |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 363 | CODE | |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 475 | CODE | |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 622 | CODE | |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 648 | CODE | |
| LOW | python/ray/experimental/rdt/nixl_memory_pool.py | 207 | CODE | |
| LOW | python/ray/llm/_internal/common/utils/cloud_utils.py | 82 | CODE | |
| LOW | python/ray/llm/_internal/common/utils/cloud_utils.py | 147 | CODE | |
| LOW | python/ray/llm/_internal/common/utils/download_utils.py | 226 | CODE | |
| LOW | python/ray/llm/_internal/common/utils/download_utils.py | 122 | CODE | |
| LOW | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 230 | CODE | |
| LOW | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 351 | CODE | |
| LOW | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 29 | CODE | |
| LOW | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 285 | CODE | |
| LOW | …llm/_internal/batch/stages/prepare_multimodal_stage.py | 42 | CODE | |
| LOW | …n/ray/llm/_internal/batch/stages/http_request_stage.py | 64 | CODE | |
| LOW | …on/ray/llm/_internal/batch/stages/vllm_engine_stage.py | 119 | CODE | |
| LOW | …on/ray/llm/_internal/batch/stages/vllm_engine_stage.py | 252 | CODE | |
| LOW | …on/ray/llm/_internal/batch/stages/vllm_engine_stage.py | 407 | CODE | |
| LOW | python/ray/llm/_internal/serve/benchmark/models.py | 134 | CODE | |
| LOW | python/ray/llm/_internal/serve/benchmark/interactive.py | 405 | CODE | |
| LOW | python/ray/llm/_internal/serve/benchmark/interactive.py | 475 | CODE | |
| LOW | python/ray/llm/_internal/serve/benchmark/interactive.py | 521 | CODE | |
| LOW | python/ray/llm/_internal/serve/benchmark/runners.py | 471 | CODE | |
| LOW | python/ray/llm/_internal/serve/benchmark/runners.py | 689 | CODE | |
| LOW | …rnal/serve/serving_patterns/data_parallel/dp_server.py | 244 | CODE | |
| LOW | …nal/serve/serving_patterns/prefill_decode/pd_server.py | 342 | CODE | |
| LOW | python/ray/llm/_internal/serve/core/ingress/ingress.py | 432 | CODE | |
| LOW | python/ray/llm/_internal/serve/core/ingress/builder.py | 172 | CODE | |
| LOW | python/ray/llm/_internal/serve/core/ingress/utils.py | 30 | CODE | |
| LOW | python/ray/llm/_internal/serve/utils/server_utils.py | 160 | CODE | |
| LOW | python/ray/llm/_internal/serve/utils/batcher.py | 50 | CODE | |
| LOW | …on/ray/llm/_internal/serve/engines/vllm/vllm_models.py | 267 | CODE | |
| LOW | …e/routing_policies/prefix_aware/prefix_aware_router.py | 208 | CODE | |
| LOW | …nal/serve/routing_policies/prefix_aware/prefix_tree.py | 253 | CODE | |
| LOW | …nal/serve/routing_policies/prefix_aware/prefix_tree.py | 376 | CODE | |
| LOW | …nal/serve/routing_policies/prefix_aware/prefix_tree.py | 591 | CODE | |
| LOW | …loyments/routers/kv/test_request_lifecycle_tracking.py | 742 | CODE | |
| LOW | python/ray/util/rpdb.py | 355 | CODE | |
| LOW | python/ray/util/iter.py | 401 | CODE | |
| LOW | python/ray/util/iter.py | 514 | CODE | |
| LOW | python/ray/util/iter.py | 557 | CODE | |
| LOW | python/ray/util/iter.py | 853 | CODE | |
| LOW | python/ray/util/iter.py | 1043 | CODE | |
| LOW | python/ray/util/iter.py | 1103 | CODE | |
| LOW | python/ray/util/iter.py | 439 | CODE | |
| LOW | python/ray/util/iter.py | 527 | CODE | |
| LOW | python/ray/util/iter.py | 594 | CODE | |
| LOW | python/ray/util/iter.py | 1071 | CODE | |
| 1148 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | python/ray/client_builder.py | 78 | elif ray._private.worker.global_worker.node.is_head(): | CODE |
| CRITICAL | python/ray/experimental/locations.py | 40 | return ray._private.worker.global_worker.core_worker.get_object_locations( | CODE |
| CRITICAL | python/ray/_common/tests/test_usage_stats.py | 1090 | ray.worker.global_worker.gcs_client.cluster_id.hex(), | CODE |
| CRITICAL | python/ray/tests/test_job.py | 215 | from_worker = ray._private.worker.global_worker.core_worker.get_job_config() | STRING |
| CRITICAL | python/ray/tests/test_client_proxy.py | 173 | assert ray.util.client.ray.worker.log_client.log_thread.is_alive() | CODE |
| CRITICAL⚡ | python/ray/tests/test_advanced_7.py | 176 | assert not ray._private.worker.global_worker.core_worker.object_exists(x_id) | CODE |
| CRITICAL⚡ | python/ray/tests/test_advanced_7.py | 178 | assert ray._private.worker.global_worker.core_worker.object_exists(x_id) | CODE |
| CRITICAL⚡ | python/ray/tests/test_advanced_7.py | 182 | assert not ray._private.worker.global_worker.core_worker.object_exists(x_id) | CODE |
| CRITICAL⚡ | python/ray/tests/test_advanced_7.py | 185 | assert ray._private.worker.global_worker.core_worker.object_exists(x_id) | CODE |
| CRITICAL | python/ray/tests/test_advanced_7.py | 215 | assert ray._private.worker.global_worker.core_worker.object_exists( | CODE |
| CRITICAL | python/ray/tests/test_advanced_7.py | 253 | inlined = ray._private.worker.global_worker.core_worker.object_exists( | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting_standalone.py | 37 | lambda: ray._private.worker.global_worker.core_worker.object_exists(obj) | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting_standalone.py | 41 | lambda: not ray._private.worker.global_worker.core_worker.object_exists(obj) | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting_standalone.py | 325 | actual = ray._private.worker.global_worker.core_worker.get_all_reference_counts() | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting_standalone.py | 336 | len(ray._private.worker.global_worker.core_worker.get_all_reference_counts()) | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting_standalone.py | 345 | len(ray._private.worker.global_worker.core_worker.get_all_reference_counts()) | CODE |
| CRITICAL | python/ray/tests/test_runtime_env_working_dir.py | 683 | ray._private.worker.global_worker.core_worker.get_job_config().py_driver_sys_path | CODE |
| CRITICAL | python/ray/tests/test_state_api_log.py | 1078 | # log_dir = ray._private.worker.global_worker.node.get_logs_dir_path() | COMMENT |
| CRITICAL | python/ray/tests/test_state_api_log.py | 1113 | log_dir = ray._private.worker.global_worker.node.get_logs_dir_path() | CODE |
| CRITICAL | python/ray/tests/test_state_api_log.py | 1337 | log_dir = ray._private.worker.global_worker.node.get_logs_dir_path() | CODE |
| CRITICAL | python/ray/tests/test_state_api_log.py | 1612 | log_dir = ray._private.worker.global_worker.node.get_logs_dir_path() | CODE |
| CRITICAL | python/ray/tests/test_advanced_3.py | 173 | assert not ray._private.worker.global_worker.core_worker.object_exists(x_id) | CODE |
| CRITICAL | python/ray/tests/test_advanced_3.py | 418 | assert not ray._private.worker.global_worker.core_worker.object_exists( | STRING |
| CRITICAL | python/ray/tests/test_advanced.py | 306 | worker_id = ray._private.worker.global_worker.core_worker.get_worker_id().hex() | CODE |
| CRITICAL | python/ray/tests/test_advanced_8.py | 585 | job_config = ray._private.worker.global_worker.core_worker.get_job_config() | STRING |
| CRITICAL | python/ray/tests/test_advanced_8.py | 593 | job_config = ray._private.worker.global_worker.core_worker.get_job_config() | STRING |
| CRITICAL⚡ | python/ray/tests/test_memory_pressure.py | 91 | return ray._private.worker.global_worker.core_worker.get_worker_id().hex() | CODE |
| CRITICAL⚡ | python/ray/tests/test_memory_pressure.py | 94 | return ray._private.worker.global_worker.core_worker.get_actor_id().hex() | CODE |
| CRITICAL | python/ray/tests/test_generators.py | 354 | ray._private.worker.global_worker.core_worker.get_all_reference_counts() | CODE |
| CRITICAL | python/ray/tests/test_basic_2.py | 461 | assert not ray._private.worker.global_worker.core_worker.object_exists(obj_ref) | CODE |
| CRITICAL | python/ray/tests/test_basic_2.py | 478 | assert not ray._private.worker.global_worker.core_worker.object_exists(obj_ref) | CODE |
| CRITICAL | python/ray/tests/test_basic_2.py | 481 | assert ray._private.worker.global_worker.core_worker.object_exists(obj_ref) | CODE |
| CRITICAL | python/ray/tests/test_basic_2.py | 759 | + ray._private.worker.global_worker.current_job_id.hex().encode() | STRING |
| CRITICAL | python/ray/tests/test_basic_2.py | 763 | assert ray._private.worker.global_worker.gcs_client.internal_kv_exists( | STRING |
| CRITICAL | python/ray/tests/test_basic_2.py | 774 | + ray._private.worker.global_worker.current_job_id.hex().encode() | STRING |
| CRITICAL | python/ray/tests/test_basic_2.py | 778 | assert ray._private.worker.global_worker.gcs_client.internal_kv_exists( | STRING |
| CRITICAL | python/ray/tests/test_output.py | 228 | log_dir = ray._private.worker.global_worker.node.get_logs_dir_path() | CODE |
| CRITICAL | python/ray/tests/test_advanced_9.py | 121 | job_id = ray._private.worker.global_worker.current_job_id.hex().encode() | CODE |
| CRITICAL | python/ray/tests/test_advanced_9.py | 145 | job_id = ray._private.worker.global_worker.current_job_id.hex().encode() | CODE |
| CRITICAL | python/ray/tests/test_advanced_9.py | 158 | job_id = ray._private.worker.global_worker.current_job_id.hex().encode() | CODE |
| CRITICAL | python/ray/tests/test_streaming_generator_regression.py | 48 | ray._private.worker.global_worker.core_worker.reset_event_loop_executor( | CODE |
| CRITICAL | python/ray/tests/test_advanced_4.py | 214 | job_id = ray._private.worker.global_worker.current_job_id.hex().encode() | CODE |
| CRITICAL | python/ray/tests/test_advanced_4.py | 238 | job_id = ray._private.worker.global_worker.current_job_id.hex().encode() | CODE |
| CRITICAL | python/ray/tests/test_advanced_4.py | 251 | job_id = ray._private.worker.global_worker.current_job_id.hex().encode() | CODE |
| CRITICAL | python/ray/tests/test_reference_counting_2.py | 62 | lambda: ray._private.worker.global_worker.core_worker.object_exists(obj), | CODE |
| CRITICAL | python/ray/tests/test_reference_counting_2.py | 67 | lambda: not ray._private.worker.global_worker.core_worker.object_exists( | CODE |
| CRITICAL | python/ray/tests/test_serialization.py | 654 | assert ray._private.worker.global_worker.current_job_id.is_nil() | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting.py | 57 | lambda: ray._private.worker.global_worker.core_worker.object_exists(obj) | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting.py | 61 | lambda: not ray._private.worker.global_worker.core_worker.object_exists( | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting.py | 69 | actual = ray._private.worker.global_worker.core_worker.get_all_reference_counts() | CODE |
| CRITICAL | python/ray/tests/test_reference_counting.py | 315 | return not ray._private.worker.global_worker.core_worker.object_exists( | CODE |
| CRITICAL | python/ray/tests/aws/utils/helpers.py | 48 | return ray.autoscaler._private.aws.config.bootstrap_aws(config) | CODE |
| CRITICAL | python/ray/tests/rdt/test_rdt_nixl.py | 304 | lambda: ray._private.worker.global_worker.rdt_manager.get_rdt_metadata(obj_id) | CODE |
| CRITICAL | python/ray/tests/rdt/test_rdt_gloo.py | 849 | return ray._private.worker.global_worker.rdt_manager.rdt_store.get_num_objects() | CODE |
| CRITICAL | python/ray/tests/spark/test_basic.py | 192 | ray.util.spark.cluster_init._active_ray_cluster.shutdown() | CODE |
| CRITICAL | python/ray/tests/spark/test_basic.py | 400 | ray.util.spark.cluster_init._global_ray_cluster_cancel_event.set() | CODE |
| CRITICAL | python/ray/tests/spark/test_databricks_hook.py | 83 | ray.util.spark.cluster_init._active_ray_cluster.shutdown() | CODE |
| CRITICAL | python/ray/_private/serialization.py | 337 | ray._private.worker.global_worker.core_worker.add_object_ref_reference( | CODE |
| CRITICAL | …/ray/dashboard/modules/reporter/tests/test_reporter.py | 1481 | ray._private.worker.global_worker.node.get_session_dir_path() | CODE |
| CRITICAL | …on/ray/dashboard/modules/job/tests/test_job_manager.py | 897 | "job_config=ray._private.worker.global_worker.core_worker.get_job_config();" | CODE |
| 43 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/setup.py | 23 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/client_builder.py | 23 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/runtime_context.py | 13 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/__init__.py | 9 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/__init__.py | 175 | __all__ = [ | CODE |
| LOW | python/ray/remote_function.py | 33 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/cross_language.py | 9 | __all__ = [ | CODE |
| LOW | python/ray/cluster_utils.py | 20 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/exceptions.py | 23 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/actor.py | 66 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/job_config.py | 83 | def set_metadata(self, key: str, value: str) -> None: | CODE |
| LOW | python/ray/job_config.py | 161 | def set_ray_namespace(self, ray_namespace: str) -> None: | CODE |
| LOW | python/ray/job_config.py | 172 | def set_default_actor_lifetime(self, default_actor_lifetime: str) -> None: | CODE |
| LOW | python/ray/runtime_env/__init__.py | 3 | __all__ = [ | CODE |
| LOW | python/ray/runtime_env/runtime_env.py | 25 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/queue.py | 13 | __all__ = ["Empty", "Full", "Queue"] | CODE |
| LOW | python/ray/experimental/__init__.py | 18 | __all__ = [ | CODE |
| LOW | python/ray/experimental/tqdm_ray.py | 23 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/tqdm_ray.py | 216 | def update_offset(self, pos_offset: int) -> None: | CODE |
| LOW | python/ray/experimental/tqdm_ray.py | 246 | def update_bar(self, state: ProgressBarState) -> None: | CODE |
| LOW | python/ray/experimental/tqdm_ray.py | 267 | def update_offset(self, offset: int) -> None: | CODE |
| LOW | python/ray/experimental/collective/__init__.py | 13 | __all__ = [ | CODE |
| LOW | python/ray/experimental/collective/operations.py | 22 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/multiprocessing/__init__.py | 5 | __all__ = ["Pool", "TimeoutError"] | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 19 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/channel/torch_tensor_type.py | 14 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/channel/torch_tensor_type.py | 173 | def set_communicator_id(self, group_id: str) -> None: | CODE |
| LOW | python/ray/experimental/channel/__init__.py | 26 | __all__ = [ | CODE |
| LOW | python/ray/experimental/channel/nccl_group.py | 18 | logger = logging.getLogger(__name__) | CODE |
| LOW | …thon/ray/experimental/channel/serialization_context.py | 37 | def set_target_device(self, device: Device) -> None: | CODE |
| LOW | …thon/ray/experimental/channel/serialization_context.py | 40 | def set_data(self, channel_id: str, value: Any, num_readers: int) -> None: | CODE |
| LOW⚡ | …thon/ray/experimental/channel/serialization_context.py | 74 | def set_use_external_transport(self, use_external_transport: bool) -> None: | CODE |
| LOW | python/ray/experimental/channel/common.py | 116 | def set_communicator_id(self, group_id: str) -> None: | CODE |
| LOW | …perimental/channel/torch_tensor_accelerator_channel.py | 34 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/rdt/util.py | 340 | def set_nixl_cuda_stream(stream: Optional["torch.cuda.Stream"]) -> None: | CODE |
| LOW | python/ray/experimental/rdt/__init__.py | 20 | __all__ = [ | CODE |
| LOW | python/ray/experimental/rdt/rdt_manager.py | 53 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 27 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 173 | def set_cuda_stream(self, stream: Optional["torch.cuda.Stream"]) -> None: | CODE |
| LOW | python/ray/experimental/rdt/nixl_memory_pool.py | 9 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ray/llm/_internal/common/callbacks/cloud_downloader.py | 9 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/llm/_internal/common/callbacks/base.py | 11 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ray/llm/_internal/common/patches/vllm/tokenize_once.py | 24 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/llm/_internal/common/utils/cloud_utils.py | 443 | def _update_cache(self, key: str, value: Any) -> None: | CODE |
| LOW | python/ray/llm/_internal/common/utils/import_utils.py | 7 | logger = logging.getLogger(__name__) | CODE |
| LOW | …lm/_internal/common/utils/cloud_filesystem/__init__.py | 23 | __all__ = [ | CODE |
| LOW | python/ray/llm/_internal/batch/__init__.py | 8 | __all__ = [ | CODE |
| LOW | python/ray/llm/_internal/batch/utils.py | 10 | logger = logging.getLogger(__name__) | CODE |
| LOW | …/ray/llm/_internal/batch/stages/sglang_engine_stage.py | 19 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/llm/_internal/batch/stages/__init__.py | 92 | __all__ = [ | CODE |
| LOW | …on/ray/llm/_internal/batch/stages/vllm_engine_stage.py | 48 | logger = logging.getLogger(__name__) | CODE |
| LOW | …y/llm/_internal/batch/stages/serve_deployment_stage.py | 19 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/llm/_internal/batch/stages/base.py | 10 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ay/llm/_internal/batch/processor/sglang_engine_proc.py | 45 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/llm/_internal/batch/processor/__init__.py | 86 | __all__ = [ | CODE |
| LOW | …/ray/llm/_internal/batch/processor/vllm_engine_proc.py | 49 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/llm/_internal/batch/processor/base.py | 17 | logger = logging.getLogger(__name__) | CODE |
| LOW | …thon/ray/llm/_internal/batch/observability/__init__.py | 23 | __all__ = ["setup_observability"] | CODE |
| LOW | …_internal/batch/observability/usage_telemetry/usage.py | 65 | def _update_record_tag_func(self, record_tag_func: Callable) -> None: | CODE |
| LOW | …/llm/_internal/batch/observability/logging/__init__.py | 7 | def _setup_logger(logger_name: str) -> None: | CODE |
| 994 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/util/state/common.py | 1268 | # Step 2: Create the tree structure based on ownership | STRING |
| LOW⚡ | python/ray/dag/vis_utils.py | 94 | # Step 0: check dependencies and init graph | COMMENT |
| LOW⚡ | python/ray/dag/vis_utils.py | 100 | # Step 1: generate unique name for each node in dag | COMMENT |
| LOW⚡ | python/ray/dag/vis_utils.py | 107 | # Step 2: create graph with all the edges | COMMENT |
| LOW⚡ | python/ray/dag/compiled_dag_node.py | 2037 | # Step 1: Build a graph of _DAGOperationGraphNode | STRING |
| LOW⚡ | python/ray/dag/compiled_dag_node.py | 2042 | # Step 2: Generate an execution schedule for each actor using topological sort | STRING |
| LOW⚡ | python/ray/dag/compiled_dag_node.py | 2045 | # Step 3: Overlap GPU communication for the execution schedule if configured | STRING |
| LOW | python/ray/dag/compiled_dag_node.py | 1798 | # Step 1: populate `arg_to_consumers` and perform some validation. | STRING |
| LOW | python/ray/dag/compiled_dag_node.py | 1818 | # Step 2: create cached channels if needed | STRING |
| LOW | python/ray/dag/compiled_dag_node.py | 1837 | # Step 3: create executable tasks for the actor | STRING |
| LOW | …ion-tests/invalid-config-fail/ray-project/project.yaml | 12 | # NOTE: The following is invalid because you can't have both dockerfile | COMMENT |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 48 | # Step 1: Convert uint8 numpy array back to torch tensor | COMMENT |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 51 | # Step 2: Restore original dtype | COMMENT |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 65 | # Step 3: Reshape and reinterpret bytes as target dtype | COMMENT |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 68 | # Step 4: Move to target device | COMMENT |
| LOW⚡ | …driver_scripts/check_code_search_path_is_propagated.py | 22 | # Step 1: Print the statement indicating that the code_search_path have been | COMMENT |
| LOW⚡ | …driver_scripts/check_code_search_path_is_propagated.py | 25 | # Step 2: Print the whole runtime_env to validate that it's been passed | COMMENT |
| LOW⚡ | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1040 | # Step 4: Scale - should succeed | COMMENT |
| LOW⚡ | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1043 | # Step 5: Disable external_scaler_enabled again | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1001 | # Step 1: Deploy with external_scaler_enabled=False | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1012 | # Step 2: Try to scale - should fail | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1029 | # Step 3: Enable external_scaler_enabled | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1056 | # Step 6: Try to scale again - should fail | COMMENT |
| LOW⚡ | …in/v2/_internal/execution/checkpoint/report_handler.py | 48 | # Step 1: Assert that the worker group has been started and not shut down. | COMMENT |
| LOW⚡ | …in/v2/_internal/execution/checkpoint/report_handler.py | 56 | # Step 2: Update training_reports_queues with poll_results. | COMMENT |
| LOW | …in/v2/_internal/execution/checkpoint/report_handler.py | 68 | # Step 3: Consolidate a list of checkpoints to single checkpoint. | COMMENT |
| LOW | …in/v2/_internal/execution/checkpoint/report_handler.py | 93 | # Step 4: Invoke all dependent `ReportCallback`s. | COMMENT |
| LOW⚡ | …n/ray/autoscaler/_private/resource_demand_scheduler.py | 216 | # Step 1: Calculate current cluster resources and node type counts | COMMENT |
| LOW⚡ | …n/ray/autoscaler/_private/resource_demand_scheduler.py | 225 | # Step 2: add nodes to add to satisfy min_workers for each type | COMMENT |
| LOW | …n/ray/autoscaler/_private/resource_demand_scheduler.py | 240 | # Step 3: get resource demands of placement groups and return the | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_logging.py | 369 | # Step 1: Get current file end position | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_logging.py | 372 | # Step 2: Make HTTP call | COMMENT |
| LOW | python/ray/serve/tests/test_logging.py | 401 | # Step 3: Verify HTTP response matches new log lines | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1190 | # Step 4: Change the max replicas to 2 | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1200 | # Step 5: Make sure it is the same replica (lightweight change). | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1205 | # Step 6: Make sure initial_replicas overrides previous replicas | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1217 | # Step 7: Make sure original replica is still running (lightweight change) | COMMENT |
| LOW | python/ray/serve/tests/test_autoscaling_policy.py | 1131 | # Step 1: Prepare the script in a zip file so it can be submitted via REST API. | COMMENT |
| LOW | python/ray/serve/tests/test_autoscaling_policy.py | 1152 | # Step 2: Deploy it with max_replicas=1 | COMMENT |
| LOW | python/ray/serve/tests/test_autoscaling_policy.py | 1176 | # Step 3: Verify that it can scale from 0 to 1. | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 837 | # Step 1: Saturate the replica — 2/2 slots occupied. | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 844 | # Step 2: Kill the CQ. It restarts with in_flight=0. | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 860 | # Step 3: Send a non-blocking request. The stale CQ issues a token, | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 865 | # Step 4: The CQ should have learned — in_flight > 0 because the | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 873 | # Step 5: Release the blockers so all requests complete. | COMMENT |
| LOW | python/ray/serve/tests/test_capacity_queue_router.py | 632 | # Step 1: Occupy 3 of 5 slots with blocking requests. | COMMENT |
| LOW | python/ray/serve/tests/test_capacity_queue_router.py | 647 | # Step 2: Kill the queue. It restarts with in_flight=0. | COMMENT |
| LOW | python/ray/serve/tests/unit/test_deployment_state.py | 3937 | # Step 1: Create some deployment info with actors in running state | COMMENT |
| LOW | python/ray/data/dataset.py | 7795 | # NOTE: This method expected to have executor fully shutdown upon returning | COMMENT |
| LOW | python/ray/data/_internal/planner/plan_udf_map_op.py | 845 | # NOTE: This method is nested to support Python 3.9 where we only can | COMMENT |
| LOW⚡ | …thon/ray/data/_internal/block_batching/iter_batches.py | 251 | # Step 1: Prefetch logical batches locally. | COMMENT |
| LOW⚡ | …thon/ray/data/_internal/block_batching/iter_batches.py | 254 | # Step 2: Resolve the blocks. | COMMENT |
| LOW⚡ | …thon/ray/data/_internal/block_batching/iter_batches.py | 257 | # Step 3: Batch and shuffle the resolved blocks. | COMMENT |
| LOW⚡ | …thon/ray/data/_internal/block_batching/iter_batches.py | 260 | # Step 4: Format and collate the batches in a threadpool. | COMMENT |
| LOW | …thon/ray/data/_internal/block_batching/iter_batches.py | 271 | # Step 6: Finalize the batches (e.g., move to GPU). | COMMENT |
| LOW | …ay/data/_internal/logical/rules/projection_pushdown.py | 424 | # Step 1: Iteratively fuse with upstream Project operations | COMMENT |
| LOW⚡ | …ay/data/_internal/logical/rules/projection_pushdown.py | 443 | # Step 2: Push projection into the data source if supported | COMMENT |
| LOW⚡ | python/ray/data/tests/test_tensor.py | 1024 | # Step 2: Switch context to native format | COMMENT |
| LOW⚡ | python/ray/data/tests/test_tensor.py | 1027 | # Step 3: Read data back - note that reading preserves original format | COMMENT |
| LOW⚡ | python/ray/data/tests/test_tensor.py | 1066 | # Step 5: Write to different path | COMMENT |
| 385 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | python/requirements/ml/rllib-test-requirements.txt | 16 | # For tests on PettingZoo's multi-agent envs. | COMMENT |
| MEDIUM⚡ | …nal/serve/serving_patterns/prefill_decode/pd_server.py | 75 | # those two routes at its own ``chat`` / ``completions`` (which orchestrate | COMMENT |
| MEDIUM⚡ | …ray/serve/tests/unit/test_controller_direct_ingress.py | 151 | # Deployment State Manager for dependency injection | COMMENT |
| MEDIUM | …ray/serve/tests/unit/test_controller_direct_ingress.py | 54 | # Application State Manager for dependency injection | COMMENT |
| MEDIUM⚡ | …ray/data/tests/datasource/test_turbopuffer_datasink.py | 471 | # 7. End-to-end write orchestration | COMMENT |
| MEDIUM | rllib/connectors/connector_v2.py | 862 | # Single-agent/multi-agent cases. | COMMENT |
| MEDIUM | rllib/connectors/common/batch_individual_items.py | 32 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | rllib/connectors/common/batch_individual_items.py | 43 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …tors/common/add_observations_from_episodes_to_batch.py | 29 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …tors/common/add_observations_from_episodes_to_batch.py | 40 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …onnectors/common/add_time_dim_to_batch_and_zero_pad.py | 38 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …onnectors/common/add_time_dim_to_batch_and_zero_pad.py | 49 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | rllib/connectors/common/module_to_agent_unmapping.py | 40 | # This Connector should only be used in a multi-agent setting. | COMMENT |
| MEDIUM | rllib/connectors/common/agent_to_module_mapping.py | 30 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | rllib/connectors/common/agent_to_module_mapping.py | 41 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …connectors/common/add_states_from_episodes_to_batch.py | 35 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …connectors/common/add_states_from_episodes_to_batch.py | 46 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM⚡ | rllib/connectors/common/flatten_observations.py | 220 | # Multi-agent example: Use the connector with a multi-agent observation space. | STRING |
| MEDIUM⚡ | rllib/connectors/common/flatten_observations.py | 234 | # Create a multi-agent observation space with agent IDs as keys. | STRING |
| MEDIUM⚡ | rllib/connectors/common/flatten_observations.py | 240 | # Create a multi-agent episode with observations for both agents. | STRING |
| MEDIUM | rllib/connectors/common/flatten_observations.py | 259 | # Construct the connector for multi-agent, flattening only agent_1's observations. | STRING |
| MEDIUM | rllib/connectors/common/flatten_observations.py | 440 | # In the multi-agent case, we need to use the specific agent's | COMMENT |
| MEDIUM | rllib/connectors/common/flatten_observations.py | 441 | # space struct, not the multi-agent observation space dict. | COMMENT |
| MEDIUM | rllib/connectors/common/flatten_observations.py | 476 | # In the multi-agent case, we need to use the specific agent's | COMMENT |
| MEDIUM | rllib/connectors/common/flatten_observations.py | 477 | # space struct, not the multi-agent observation space dict. | COMMENT |
| MEDIUM | rllib/connectors/common/numpy_to_tensor.py | 38 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | rllib/connectors/common/numpy_to_tensor.py | 49 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …rs/learner/add_columns_from_episodes_to_train_batch.py | 26 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …nectors/learner/add_one_ts_to_episodes_and_truncate.py | 115 | # TODO (sven): Same situation as in TODO below, but for multi-agent episode. | COMMENT |
| MEDIUM | …onnectors/module_to_env/listify_data_for_vector_env.py | 27 | ModuleToAgentUnmapping, # only in multi-agent setups! | STRING |
| MEDIUM | …onnectors/module_to_env/listify_data_for_vector_env.py | 61 | # Multi-agent case: Create lists of multi-agent dicts under each column. | COMMENT |
| MEDIUM | …connectors/module_to_env/normalize_and_clip_actions.py | 33 | ModuleToAgentUnmapping, # only in multi-agent setups! | STRING |
| MEDIUM | …onnectors/module_to_env/unbatch_to_individual_items.py | 28 | ModuleToAgentUnmapping, # only in multi-agent setups! | STRING |
| MEDIUM | …onnectors/module_to_env/unbatch_to_individual_items.py | 61 | # Keys are always tuples to resemble multi-agent keys, which | COMMENT |
| MEDIUM | …module_to_env/remove_single_ts_time_rank_from_batch.py | 27 | ModuleToAgentUnmapping, # only in multi-agent setups! | STRING |
| MEDIUM | rllib/connectors/module_to_env/get_actions.py | 26 | ModuleToAgentUnmapping, # only in multi-agent setups! | STRING |
| MEDIUM | …/connectors/env_to_module/prev_actions_prev_rewards.py | 102 | # f"thus far (or, for multi-agent, on Dict spaces mapping AgentIDs to " | COMMENT |
| MEDIUM | …ectors/env_to_module/write_observations_to_episodes.py | 24 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …ectors/env_to_module/write_observations_to_episodes.py | 112 | # Note that the following loop works with multi-agent as well as with | COMMENT |
| MEDIUM | …ectors/env_to_module/write_observations_to_episodes.py | 116 | # `data`, either in a list directly under the "obs" key OR for multi-agent: | COMMENT |
| MEDIUM | …b/connectors/env_to_module/observation_preprocessor.py | 162 | # TODO (sven): Implement set_observations API for multi-agent episodes. | COMMENT |
| MEDIUM | rllib/core/testing/testing_learner.py | 46 | # TODO (Kourosh): Make this more multi-agent for example with policy ids | COMMENT |
| MEDIUM | rllib/core/learner/differentiable_learner_config.py | 124 | # If multi-agent -> Map from AgentID-based data to ModuleID based data. | COMMENT |
| MEDIUM⚡ | rllib/algorithms/algorithm_config.py | 4652 | # If the module is single-agent convert it to multi-agent spec | COMMENT |
| MEDIUM⚡ | rllib/algorithms/algorithm_config.py | 4654 | # The default RLModuleSpec (might be multi-agent or single-agent). | COMMENT |
| MEDIUM⚡ | rllib/algorithms/algorithm_config.py | 4656 | # The currently configured RLModuleSpec (might be multi-agent or single-agent). | COMMENT |
| MEDIUM⚡ | rllib/algorithms/algorithm_config.py | 4677 | # Algorithm is currently setup as a multi-agent one. | COMMENT |
| MEDIUM⚡ | rllib/algorithms/algorithm_config.py | 4683 | # Default is single-agent but the user has provided a multi-agent spec | COMMENT |
| MEDIUM⚡ | rllib/algorithms/algorithm_config.py | 4684 | # so the use-case is multi-agent. | COMMENT |
| MEDIUM⚡ | rllib/algorithms/algorithm_config.py | 4703 | # We need to infer the multi-agent class from `current_rl_module_spec` | COMMENT |
| MEDIUM⚡ | rllib/algorithms/algorithm_config.py | 4713 | # Default is multi-agent and user wants to override it -> Don't use the | COMMENT |
| MEDIUM⚡ | rllib/algorithms/algorithm_config.py | 4717 | # to reuse for all modules in this multi-agent default setup. | COMMENT |
| MEDIUM | rllib/algorithms/algorithm_config.py | 142 | # The default agent ID to module ID mapping function to use in the multi-agent | COMMENT |
| MEDIUM | rllib/algorithms/algorithm_config.py | 460 | # TODO (sven): Prepare multi-agent setup for logging each agent's and each | COMMENT |
| MEDIUM | rllib/algorithms/algorithm_config.py | 800 | # Set our multi-agent settings. | COMMENT |
| MEDIUM | rllib/algorithms/algorithm_config.py | 1116 | # If multi-agent -> Map from AgentID-based data to ModuleID based data. | COMMENT |
| MEDIUM | rllib/algorithms/algorithm_config.py | 1224 | # If multi-agent -> Map from ModuleID-based data to AgentID based data. | COMMENT |
| MEDIUM | rllib/algorithms/algorithm_config.py | 1247 | # for single-agent and multi-agent dicts for multi-agent. | COMMENT |
| MEDIUM | rllib/algorithms/algorithm_config.py | 1309 | # If multi-agent -> Map from AgentID-based data to ModuleID based data. | COMMENT |
| MEDIUM⚡ | rllib/algorithms/utils.py | 66 | # which IDs the submodules have (to figure out, whether its multi-agent or | COMMENT |
| 84 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/exceptions.py | 582 | # Check if RAY_AUTH_MODE is set to token and add a heads-up if not | COMMENT |
| LOW | python/ray/actor.py | 740 | # Check if decorator is called without parentheses (args[0] would be the function) | COMMENT |
| LOW | python/ray/experimental/rdt/rdt_manager.py | 758 | # Check if a warning should be triggered for this object: | COMMENT |
| LOW | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 56 | # Check if anonymous@ prefix exists | COMMENT |
| LOW | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 51 | # Check if the first part ends with "anonymous" | COMMENT |
| LOW⚡ | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 236 | # Check if file exists | COMMENT |
| LOW⚡ | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 241 | # Read file | COMMENT |
| LOW | python/ray/llm/_internal/serve/utils/registry.py | 109 | # Check if registered | STRING |
| LOW | …nal/serve/routing_policies/prefix_aware/prefix_tree.py | 416 | # Check if any available tenants match this node | COMMENT |
| LOW | python/ray/util/tpu.py | 684 | # Check if user explicitly requested a slice name for this slice | COMMENT |
| LOW | python/ray/util/client_connect.py | 34 | # Check if Ray is already connected (any type of connection) | COMMENT |
| LOW | python/ray/util/collective/collective.py | 236 | # Check if backend is registered and available | COMMENT |
| LOW | …sts/single_node_cpu_tests/test_gloo_group_isolation.py | 26 | # Check if the group is initialized correctly | COMMENT |
| LOW | python/ray/util/multiprocessing/pool.py | 259 | # Check if any of the available IDs are done. The timeout is required | COMMENT |
| LOW | python/ray/util/client/common.py | 291 | # Check if supplied parameters match the function signature. Same case | COMMENT |
| LOW | python/ray/util/client/server/server.py | 76 | # Check if response already cached | COMMENT |
| LOW | python/ray/_common/usage/usage_lib.py | 822 | # Check if we're on Kubernetes | COMMENT |
| LOW | python/ray/_common/usage/usage_lib.py | 824 | # Check if we're using KubeRay >= 0.4.0. | COMMENT |
| LOW | python/ray/tests/conftest.py | 386 | # Check if th redis has started successfully and is listening on the port. | COMMENT |
| LOW | python/ray/tests/conftest.py | 1212 | # Set scope to "class" to force this to run before start_cluster, whose scope | COMMENT |
| LOW | python/ray/tests/test_logging.py | 317 | # Check if the backup count is respected. | COMMENT |
| LOW | python/ray/tests/test_logging.py | 423 | # Check if the backup count is respected. | COMMENT |
| LOW | python/ray/tests/test_object_spilling_3.py | 386 | # Iterate over the data on the worker nodes from the head node. | COMMENT |
| LOW | python/ray/tests/test_runtime_env_plugin.py | 628 | # Set scope to "class" to force this to run before start_cluster, whose scope | COMMENT |
| LOW | python/ray/tests/test_runtime_env_working_dir.py | 38 | # Set scope to "module" to force this to run before start_cluster, whose scope | COMMENT |
| LOW⚡ | python/ray/tests/test_runtime_env_agent.py | 109 | # Check if agent register is OK. | COMMENT |
| LOW | python/ray/tests/test_scheduling.py | 734 | # Check if task2 starts within 1 second (indicating the bug) | COMMENT |
| LOW | python/ray/tests/test_runtime_env_failure.py | 20 | # Set scope to "class" to force this to run before start_cluster, whose scope | COMMENT |
| LOW | python/ray/tests/test_coordinator_server.py | 375 | # Check if now we can create more clusters/nodes. | COMMENT |
| LOW | python/ray/tests/test_client.py | 86 | # Set num_cpus to zero to ensure that both tasks can always be scheduled | COMMENT |
| LOW | python/ray/tests/test_cli.py | 1569 | # Check if ray.serve is available (it's an optional dependency) | COMMENT |
| LOW | python/ray/tests/test_runtime_env_working_dir_3.py | 34 | # Set scope to "class" to force this to run before start_cluster, whose scope | COMMENT |
| LOW⚡ | python/ray/tests/vsphere/test_cluster_operator.py | 654 | # Check if status is not available | COMMENT |
| LOW⚡ | python/ray/tests/vsphere/test_cluster_operator.py | 658 | # Check if ingress in unavailable | COMMENT |
| LOW | python/ray/air/tests/test_integration_mlflow.py | 113 | # Check if client recognizes already existing experiment. | COMMENT |
| LOW | python/ray/air/tests/test_integration_mlflow.py | 195 | # Check if run is created with proper tags. | COMMENT |
| LOW | python/ray/air/tests/test_integration_mlflow.py | 237 | # Check if params are logged at the end. | COMMENT |
| LOW | python/ray/air/integrations/wandb.py | 133 | # Check if we are in a train session and if we are not the rank 0 worker | COMMENT |
| LOW | python/ray/air/integrations/wandb.py | 350 | # Check if user is already logged into wandb. | COMMENT |
| LOW | python/ray/air/execution/resources/request.py | 75 | # Check if the head bundle is empty (no resources defined or all resources | COMMENT |
| LOW | python/ray/_private/function_manager.py | 562 | # Check if the actor class already exists in the cache. | COMMENT |
| LOW | python/ray/_private/inspect_util.py | 14 | # Check if function or method, respectively | COMMENT |
| LOW | python/ray/_private/node.py | 1594 | # Write the file BEFORE the internal_kv_put below so the two never | COMMENT |
| LOW | python/ray/_private/serialization.py | 220 | # Check if this is an RDT ObjectRef being serialized inside a collection | COMMENT |
| LOW | python/ray/_private/serialization.py | 440 | # Check if the object should be returned as raw bytes. | COMMENT |
| LOW | python/ray/_private/runtime_env/uv_runtime_env_hook.py | 268 | # Check if the requirements.txt file is in the working_dir | COMMENT |
| LOW | python/ray/_private/runtime_env/uv_runtime_env_hook.py | 282 | # Check if the pyproject.toml file is in the working_dir | COMMENT |
| LOW | python/ray/_private/accelerators/tpu.py | 407 | # Check if z coordinates are present. | COMMENT |
| LOW | …y/_private/authentication/http_token_authentication.py | 92 | # Check if user provided their own Authorization header (case-insensitive) | COMMENT |
| LOW | …/_private/authentication/authentication_token_setup.py | 79 | # Check if you enabled token authentication. | COMMENT |
| LOW | …/_private/thirdparty/pathspec/patterns/gitwildmatch.py | 268 | # Set i to one past the closing braket. | COMMENT |
| LOW | python/ray/_private/thirdparty/tabulate/tabulate.py | 2090 | # Check if pretty is the format being used and override the defaults so it | COMMENT |
| LOW | python/ray/dashboard/http_server_head.py | 206 | # Check if token authentication is enabled | COMMENT |
| LOW | python/ray/dashboard/http_server_head.py | 246 | # Check if the connection is secure (HTTPS) | COMMENT |
| LOW | python/ray/dashboard/event_loop_monitor.py | 57 | # Set RAY_DASHBOARD_AGENT_LOOP_DUMP_SIGNAL to another signal name, or to an | COMMENT |
| LOW | python/ray/dashboard/tests/test_dashboard.py | 113 | # Check if agent register is OK. | COMMENT |
| LOW | python/ray/dashboard/modules/metrics/metrics_head.py | 155 | # Check if the required Grafana services are running. | COMMENT |
| LOW | python/ray/dashboard/modules/reporter/gpu_providers.py | 182 | # Check if MIG mode is enabled on this GPU | COMMENT |
| LOW | python/ray/dashboard/modules/reporter/gpu_providers.py | 543 | # Check if we should disable GPU check entirely | COMMENT |
| LOW | python/ray/dashboard/modules/job/cli.py | 567 | # Set no_format to True because the logs may have unescaped "{" and "}" | COMMENT |
| 186 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/runtime_context.py | 527 | CODE | |
| LOW | python/ray/actor.py | 612 | CODE | |
| LOW | python/ray/actor.py | 1079 | CODE | |
| LOW | python/ray/actor.py | 2486 | CODE | |
| LOW | python/ray/job_config.py | 48 | CODE | |
| LOW | python/ray/runtime_env/runtime_env.py | 324 | CODE | |
| LOW | python/ray/experimental/shuffle.py | 231 | CODE | |
| LOW | …/ray/llm/_internal/batch/stages/sglang_engine_stage.py | 78 | CODE | |
| LOW | python/ray/util/tpu.py | 982 | CODE | |
| LOW | python/ray/util/tpu.py | 555 | CODE | |
| LOW | python/ray/util/client_connect.py | 22 | CODE | |
| LOW | python/ray/util/dask/scheduler_utils.py | 242 | CODE | |
| LOW | python/ray/util/state/api.py | 1180 | CODE | |
| LOW | python/ray/util/state/state_cli.py | 885 | CODE | |
| LOW | python/ray/util/client/__init__.py | 122 | CODE | |
| LOW | python/ray/util/spark/cluster_init.py | 1222 | CODE | |
| LOW | python/ray/util/spark/cluster_init.py | 1392 | CODE | |
| LOW | python/ray/_common/usage/usage_lib.py | 883 | CODE | |
| LOW | python/ray/_common/usage/usage_lib.py | 950 | CODE | |
| LOW | python/ray/_common/usage/usage_lib.py | 971 | CODE | |
| LOW | python/ray/_common/observability/platform_events.py | 13 | CODE | |
| LOW | python/ray/tests/test_state_api.py | 256 | CODE | |
| LOW | python/ray/tests/test_resource_metrics.py | 18 | CODE | |
| LOW | python/ray/tests/test_core_worker_fault_tolerance.py | 125 | CODE | |
| LOW | python/ray/tests/test_nccl_channel.py | 85 | CODE | |
| LOW | python/ray/tests/test_metrics_agent_2.py | 49 | CODE | |
| LOW | python/ray/tests/horovod/horovod_example.py | 40 | CODE | |
| LOW | python/ray/tests/kuberay/utils.py | 310 | CODE | |
| LOW | python/ray/air/tests/_test_experiment_restore_run.py | 158 | CODE | |
| LOW | python/ray/air/integrations/mlflow.py | 33 | CODE | |
| LOW | python/ray/air/integrations/wandb.py | 593 | CODE | |
| LOW | python/ray/_private/worker.py | 1438 | CODE | |
| LOW | python/ray/_private/worker.py | 2480 | CODE | |
| LOW | python/ray/_private/worker.py | 3751 | CODE | |
| LOW | python/ray/_private/test_utils.py | 188 | CODE | |
| LOW | python/ray/_private/services.py | 883 | CODE | |
| LOW | python/ray/_private/services.py | 1523 | CODE | |
| LOW | python/ray/_private/services.py | 1610 | CODE | |
| LOW | python/ray/_private/services.py | 2338 | CODE | |
| LOW | python/ray/_private/services.py | 2421 | CODE | |
| LOW | python/ray/_private/parameter.py | 129 | CODE | |
| LOW | python/ray/_private/thirdparty/pynvml/pynvml.py | 2854 | CODE | |
| LOW | python/ray/_private/thirdparty/pynvml/pynvml.py | 5957 | CODE | |
| LOW | python/ray/_private/thirdparty/pynvml/pynvml.py | 5962 | CODE | |
| LOW | python/ray/_private/thirdparty/tabulate/tabulate.py | 1556 | CODE | |
| LOW | …ard/modules/platform_events/tests/test_k8s_provider.py | 22 | CODE | |
| LOW | python/ray/dashboard/modules/job/sdk.py | 133 | CODE | |
| LOW | python/ray/dashboard/modules/job/job_manager.py | 465 | CODE | |
| LOW | python/ray/dashboard/modules/log/log_manager.py | 344 | CODE | |
| LOW | python/ray/tune/progress_reporter.py | 806 | CODE | |
| LOW | python/ray/tune/progress_reporter.py | 939 | CODE | |
| LOW | python/ray/tune/progress_reporter.py | 177 | CODE | |
| LOW | python/ray/tune/progress_reporter.py | 502 | CODE | |
| LOW | python/ray/tune/progress_reporter.py | 675 | CODE | |
| LOW | python/ray/tune/tune.py | 267 | CODE | |
| LOW | python/ray/tune/tune.py | 1069 | CODE | |
| LOW | python/ray/tune/resources.py | 40 | CODE | |
| LOW | python/ray/tune/result_grid.py | 300 | CODE | |
| LOW | python/ray/tune/impl/tuner_internal.py | 99 | CODE | |
| LOW | python/ray/tune/experimental/output.py | 296 | CODE | |
| 256 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/util/state/common.py | 1268 | # Step 2: Create the tree structure based on ownership | STRING |
| LOW⚡ | python/ray/dag/vis_utils.py | 94 | # Step 0: check dependencies and init graph | COMMENT |
| LOW⚡ | python/ray/dag/vis_utils.py | 100 | # Step 1: generate unique name for each node in dag | COMMENT |
| LOW⚡ | python/ray/dag/vis_utils.py | 107 | # Step 2: create graph with all the edges | COMMENT |
| LOW⚡ | python/ray/dag/compiled_dag_node.py | 2037 | # Step 1: Build a graph of _DAGOperationGraphNode | STRING |
| LOW⚡ | python/ray/dag/compiled_dag_node.py | 2042 | # Step 2: Generate an execution schedule for each actor using topological sort | STRING |
| LOW⚡ | python/ray/dag/compiled_dag_node.py | 2045 | # Step 3: Overlap GPU communication for the execution schedule if configured | STRING |
| LOW | python/ray/dag/compiled_dag_node.py | 1798 | # Step 1: populate `arg_to_consumers` and perform some validation. | STRING |
| LOW | python/ray/dag/compiled_dag_node.py | 1818 | # Step 2: create cached channels if needed | STRING |
| LOW | python/ray/dag/compiled_dag_node.py | 1837 | # Step 3: create executable tasks for the actor | STRING |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 48 | # Step 1: Convert uint8 numpy array back to torch tensor | COMMENT |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 51 | # Step 2: Restore original dtype | COMMENT |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 65 | # Step 3: Reshape and reinterpret bytes as target dtype | COMMENT |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 68 | # Step 4: Move to target device | COMMENT |
| LOW⚡ | …driver_scripts/check_code_search_path_is_propagated.py | 22 | # Step 1: Print the statement indicating that the code_search_path have been | COMMENT |
| LOW⚡ | …driver_scripts/check_code_search_path_is_propagated.py | 25 | # Step 2: Print the whole runtime_env to validate that it's been passed | COMMENT |
| LOW⚡ | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1040 | # Step 4: Scale - should succeed | COMMENT |
| LOW⚡ | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1043 | # Step 5: Disable external_scaler_enabled again | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1001 | # Step 1: Deploy with external_scaler_enabled=False | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1012 | # Step 2: Try to scale - should fail | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1029 | # Step 3: Enable external_scaler_enabled | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1056 | # Step 6: Try to scale again - should fail | COMMENT |
| LOW⚡ | …in/v2/_internal/execution/checkpoint/report_handler.py | 48 | # Step 1: Assert that the worker group has been started and not shut down. | COMMENT |
| LOW⚡ | …in/v2/_internal/execution/checkpoint/report_handler.py | 56 | # Step 2: Update training_reports_queues with poll_results. | COMMENT |
| LOW | …in/v2/_internal/execution/checkpoint/report_handler.py | 68 | # Step 3: Consolidate a list of checkpoints to single checkpoint. | COMMENT |
| LOW | …in/v2/_internal/execution/checkpoint/report_handler.py | 93 | # Step 4: Invoke all dependent `ReportCallback`s. | COMMENT |
| LOW⚡ | …n/ray/autoscaler/_private/resource_demand_scheduler.py | 216 | # Step 1: Calculate current cluster resources and node type counts | COMMENT |
| LOW⚡ | …n/ray/autoscaler/_private/resource_demand_scheduler.py | 225 | # Step 2: add nodes to add to satisfy min_workers for each type | COMMENT |
| LOW | …n/ray/autoscaler/_private/resource_demand_scheduler.py | 240 | # Step 3: get resource demands of placement groups and return the | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_logging.py | 369 | # Step 1: Get current file end position | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_logging.py | 372 | # Step 2: Make HTTP call | COMMENT |
| LOW | python/ray/serve/tests/test_logging.py | 401 | # Step 3: Verify HTTP response matches new log lines | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1190 | # Step 4: Change the max replicas to 2 | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1200 | # Step 5: Make sure it is the same replica (lightweight change). | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1205 | # Step 6: Make sure initial_replicas overrides previous replicas | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1217 | # Step 7: Make sure original replica is still running (lightweight change) | COMMENT |
| LOW | python/ray/serve/tests/test_autoscaling_policy.py | 1131 | # Step 1: Prepare the script in a zip file so it can be submitted via REST API. | COMMENT |
| LOW | python/ray/serve/tests/test_autoscaling_policy.py | 1152 | # Step 2: Deploy it with max_replicas=1 | COMMENT |
| LOW | python/ray/serve/tests/test_autoscaling_policy.py | 1176 | # Step 3: Verify that it can scale from 0 to 1. | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 837 | # Step 1: Saturate the replica — 2/2 slots occupied. | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 844 | # Step 2: Kill the CQ. It restarts with in_flight=0. | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 860 | # Step 3: Send a non-blocking request. The stale CQ issues a token, | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 865 | # Step 4: The CQ should have learned — in_flight > 0 because the | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 873 | # Step 5: Release the blockers so all requests complete. | COMMENT |
| LOW | python/ray/serve/tests/test_capacity_queue_router.py | 632 | # Step 1: Occupy 3 of 5 slots with blocking requests. | COMMENT |
| LOW | python/ray/serve/tests/test_capacity_queue_router.py | 647 | # Step 2: Kill the queue. It restarts with in_flight=0. | COMMENT |
| LOW | python/ray/serve/tests/unit/test_deployment_state.py | 3937 | # Step 1: Create some deployment info with actors in running state | COMMENT |
| LOW⚡ | …thon/ray/data/_internal/block_batching/iter_batches.py | 251 | # Step 1: Prefetch logical batches locally. | COMMENT |
| LOW⚡ | …thon/ray/data/_internal/block_batching/iter_batches.py | 254 | # Step 2: Resolve the blocks. | COMMENT |
| LOW⚡ | …thon/ray/data/_internal/block_batching/iter_batches.py | 257 | # Step 3: Batch and shuffle the resolved blocks. | COMMENT |
| LOW⚡ | …thon/ray/data/_internal/block_batching/iter_batches.py | 260 | # Step 4: Format and collate the batches in a threadpool. | COMMENT |
| LOW | …thon/ray/data/_internal/block_batching/iter_batches.py | 271 | # Step 6: Finalize the batches (e.g., move to GPU). | COMMENT |
| LOW | …ay/data/_internal/logical/rules/projection_pushdown.py | 424 | # Step 1: Iteratively fuse with upstream Project operations | COMMENT |
| LOW⚡ | …ay/data/_internal/logical/rules/projection_pushdown.py | 443 | # Step 2: Push projection into the data source if supported | COMMENT |
| LOW⚡ | python/ray/data/tests/test_tensor.py | 1024 | # Step 2: Switch context to native format | COMMENT |
| LOW⚡ | python/ray/data/tests/test_tensor.py | 1027 | # Step 3: Read data back - note that reading preserves original format | COMMENT |
| LOW⚡ | python/ray/data/tests/test_tensor.py | 1066 | # Step 5: Write to different path | COMMENT |
| LOW⚡ | python/ray/data/tests/test_tensor.py | 1070 | # Step 6: Read again and verify native format is preserved | COMMENT |
| LOW | python/ray/data/tests/test_tensor.py | 995 | # Step 1: Write data using V1 or V2 format | COMMENT |
| LOW | python/ray/data/tests/test_tensor.py | 1044 | # Step 4: Apply a transformation that recreates tensor arrays in native format | COMMENT |
| 65 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | build-docker.sh | 36 | # It also can facilitate cleanup. | COMMENT |
| MEDIUM | python/ray/actor.py | 2722 | """This is defined in order to make pickling work. | STRING |
| MEDIUM | python/ray/actor.py | 2771 | """This is defined in order to make pickling work. | STRING |
| LOW | python/ray/llm/_internal/common/utils/download_utils.py | 108 | # and we can just return the model_dir. | COMMENT |
| LOW | python/ray/llm/_internal/serve/utils/server_utils.py | 127 | # This also works for normal exceptions (we will just return everything from | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/utils/server_utils.py | 188 | # TODO make this more robust | COMMENT |
| LOW | python/ray/llm/tests/common/cloud/test_s3_filesystem.py | 248 | # This should not raise, just return without downloading | COMMENT |
| LOW | python/ray/dag/input_node.py | 119 | # If user only passed in one value, for simplicity we just return it. | COMMENT |
| LOW | python/ray/tests/test_actor_resources.py | 449 | # can't just return them from the tasks, because the tasks don't return | COMMENT |
| MEDIUM | python/ray/tests/test_dataclient_disconnect.py | 61 | # robust mechanism if they fail with code changes or become flaky. | COMMENT |
| MEDIUM | python/ray/tests/conftest_docker.py | 16 | # setup is a little intricate, as it uses docker-in-docker. | COMMENT |
| MEDIUM | python/ray/tests/test_resource_demand_scheduler.py | 2115 | # TODO (Alex): We should find a more robust way of simulating a node | COMMENT |
| MEDIUM | python/ray/tests/test_resource_demand_scheduler.py | 2228 | # testPlacementGroupScaling for more comprehensive tests. | COMMENT |
| LOW | python/ray/tests/test_cli_patterns/test_no_head.yaml | 78 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| LOW | python/ray/tests/test_cli_patterns/test_no_workers.yaml | 79 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| LOW | python/ray/_private/worker.py | 2148 | # should simply set "global_worker" to equal "None" or something like that. | COMMENT |
| MEDIUM | python/ray/_private/services.py | 360 | # TODO(ekl): Find a robust solution for locating Redis. | COMMENT |
| LOW | python/ray/_private/runtime_env/working_dir.py | 63 | # working_dir is already a URI -- just pass it through. | COMMENT |
| MEDIUM | python/ray/_private/runtime_env/uv_runtime_env_hook.py | 448 | # We purposefully modify sys.argv here to make sure the hook is robust | COMMENT |
| MEDIUM | python/ray/dashboard/tests/test_event_loop_monitor.py | 19 | # harness (they still show on stderr). Attach a handler to the module logger | COMMENT |
| LOW | …n/ray/dashboard/modules/reporter/tests/test_healthz.py | 19 | # It'll either timeout or just return an error | COMMENT |
| LOW | python/ray/dashboard/modules/job/job_manager.py | 383 | in #24546 for GPU detection and just use the user's resource | STRING |
| LOW | python/ray/dashboard/modules/node/node_head.py | 348 | # TODO(rickyx): we should just return structure data rather than strings. | COMMENT |
| MEDIUM | python/ray/dashboard/modules/node/datacenter.py | 163 | # with a more robust mapping in a future update. | COMMENT |
| MEDIUM | python/ray/dashboard/modules/node/datacenter.py | 245 | # This will be addressed with a more robust mapping in a future update. | COMMENT |
| LOW | python/ray/tune/search/optuna/optuna_search.py | 384 | # If storage is not provided, just set self._storage to None | COMMENT |
| LOW | python/ray/tune/experiment/trial.py | 487 | # been set and therefore would not be empty. We can just return it. | COMMENT |
| LOW | python/ray/tune/experiment/trial.py | 492 | # 3. In the worst case where we have nothing, we just set the | COMMENT |
| MEDIUM | python/ray/tune/schedulers/pb2.py | 131 | # add diagonal ** we would ideally make this something more robust... | COMMENT |
| MEDIUM | python/ray/train/v2/_internal/util.py | 248 | # changes. Figure out a more robust way to exclude these frames. | COMMENT |
| LOW | …ternal/execution/controller/placement_group_cleaner.py | 48 | # Thread already running, just return True | COMMENT |
| LOW | python/ray/autoscaler/vsphere/defaults.yaml | 86 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| LOW | python/ray/autoscaler/vsphere/example-full.yaml | 89 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| LOW | python/ray/autoscaler/aliyun/defaults.yaml | 104 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| LOW | python/ray/autoscaler/aliyun/example-full.yaml | 110 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| LOW | python/ray/autoscaler/aliyun/example-linux.yaml | 113 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| LOW | python/ray/autoscaler/azure/defaults.yaml | 110 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| LOW | python/ray/autoscaler/azure/example-full.yaml | 134 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| LOW | python/ray/autoscaler/gcp/defaults.yaml | 112 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| LOW | python/ray/autoscaler/gcp/example-full.yaml | 135 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| MEDIUM | python/ray/autoscaler/_private/legacy_info_string.py | 6 | """This file provides legacy support for the old info string in order to | STRING |
| MEDIUM | python/ray/autoscaler/_private/cli_logger.py | 218 | """More robust check for interactive terminal/tty.""" | STRING |
| LOW | python/ray/autoscaler/_private/vsphere/node_provider.py | 71 | # Currently vSphere VMs do not show an internal IP. So we just return the | COMMENT |
| LOW | python/ray/autoscaler/local/example-full.yaml | 81 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| LOW | python/ray/autoscaler/v2/utils.py | 292 | # No affinity constraints, just add to the combined requests. | COMMENT |
| LOW⚡ | python/ray/autoscaler/v2/instance_manager/config.py | 412 | # either extending the current ray-schema.json, or just use another | COMMENT |
| LOW | …on/ray/autoscaler/v2/instance_manager/ray_installer.py | 91 | # since the updater could hide exceptions and just set the status tag | COMMENT |
| MEDIUM | python/ray/autoscaler/v2/tests/test_reconciler.py | 1127 | # Probably better to have a more comprehensive mocker for instance | COMMENT |
| LOW | python/ray/autoscaler/aws/defaults.yaml | 102 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| MEDIUM | …hon/ray/autoscaler/aws/example-network-interfaces.yaml | 104 | # in the same subnet. This allows your EFA interfaces to leverage their | COMMENT |
| LOW | python/ray/autoscaler/aws/example-full.yaml | 132 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| LOW | python/ray/autoscaler/aws/example-ml.yaml | 101 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| LOW | python/ray/serve/batching.py | 529 | # all requests have been cancelled, simply return and wait for | COMMENT |
| LOW | python/ray/serve/tests/test_autoscaling_policy.py | 440 | # Instant processing - just return | COMMENT |
| MEDIUM | python/ray/serve/_private/controller.py | 904 | """Returns comprehensive health metrics for the controller. | STRING |
| MEDIUM | python/ray/serve/_private/haproxy.py | 1157 | # Use -x socket transfer for seamless reloads if optimization is enabled | COMMENT |
| MEDIUM | python/ray/data/aggregate.py | 472 | # to be robust and not flaky | STRING |
| MEDIUM | python/ray/data/_internal/logging.py | 69 | # To facilitate debugging, Ray Data writes debug logs to a file. However, if Ray Data | COMMENT |
| MEDIUM | …on/ray/data/_internal/datasource/parquet_datasource.py | 773 | # method in order to leverage pyarrow's ParquetDataset abstraction, | COMMENT |
| MEDIUM | python/ray/data/_internal/tensor_extensions/arrow.py | 1701 | # same as a.ctypes.data, but robust for views | COMMENT |
| 59 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/setup.py | 26 | # When the bazel version is updated, make sure to update it | COMMENT |
| LOW | python/ray/llm/_internal/serve/utils/batcher.py | 87 | # If the stream task is done, make sure to exit the read task | COMMENT |
| LOW⚡ | python/ray/util/serialization.py | 40 | # make sure to keep the API consistent. | COMMENT |
| LOW | python/ray/_common/utils.py | 403 | # Don't forget to strip() the newline: | COMMENT |
| LOW | python/ray/tests/test_reference_counting_standalone.py | 464 | # make sure to only del the last ref to let ref count go to 0 after actor B's raylet starts pulling that object. | COMMENT |
| LOW⚡ | python/ray/tests/test_placement_group_5.py | 376 | # So we should make sure to wait until actor is scheduled. | COMMENT |
| MEDIUM | python/ray/tests/test_cli_patterns/test_no_head.yaml | 55 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/tests/test_cli_patterns/test_no_head.yaml | 56 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/tests/test_cli_patterns/test_no_head.yaml | 104 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | python/ray/tests/test_cli_patterns/test_no_workers.yaml | 56 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/tests/test_cli_patterns/test_no_workers.yaml | 57 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/tests/test_cli_patterns/test_no_workers.yaml | 105 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | python/ray/_private/node.py | 1006 | # This should work for most cases, especitally | COMMENT |
| MEDIUM | …/client/public/speedscope-1.5.3/speedscope.75eb7d8e.js | 9 | "use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.__DO_NOT_USE__ActionTypes=exports.compose=ex | CODE |
| MEDIUM | python/ray/train/base_trainer.py | 325 | # Define some dummy inputs for demonstration purposes | STRING |
| LOW | python/ray/train/tests/test_checkpoint.py | 40 | # the pyarrow.fs.MockFileSystem, so we must make sure to return | COMMENT |
| MEDIUM | python/ray/autoscaler/vsphere/defaults.yaml | 37 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/vsphere/defaults.yaml | 38 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/vsphere/example-minimal.yaml | 15 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/vsphere/example-minimal.yaml | 16 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/vsphere/example-full.yaml | 37 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/vsphere/example-full.yaml | 38 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/aliyun/defaults.yaml | 39 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/aliyun/defaults.yaml | 40 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/aliyun/example-full.yaml | 47 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/aliyun/example-full.yaml | 48 | # If you do so, make sure to also set "key_name". | COMMENT |
| MEDIUM | python/ray/autoscaler/aliyun/example-linux.yaml | 46 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/aliyun/example-linux.yaml | 47 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/azure/defaults.yaml | 135 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | python/ray/autoscaler/azure/example-full.yaml | 166 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | python/ray/autoscaler/gcp/defaults.yaml | 32 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/gcp/defaults.yaml | 33 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/gcp/defaults.yaml | 135 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | python/ray/autoscaler/gcp/example-full.yaml | 47 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/gcp/example-full.yaml | 48 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/gcp/example-full.yaml | 161 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | python/ray/autoscaler/gcp/example-gpu-docker.yaml | 41 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/gcp/example-gpu-docker.yaml | 42 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/_private/cli_logger_demoall.py | 4 | # function for demonstration purposes. Primarily useful for tuning color and | COMMENT |
| LOW | python/ray/autoscaler/_private/autoscaler.py | 498 | # Sort based on last used to make sure to keep min_workers that | COMMENT |
| LOW | python/ray/autoscaler/_private/vsphere/node_provider.py | 96 | # make sure to mark newly created nodes as ready | COMMENT |
| LOW | python/ray/autoscaler/_private/gcp/config.py | 575 | # We need to make sure to _create_ the file with the right | COMMENT |
| LOW | python/ray/autoscaler/_private/aws/config.py | 410 | # We need to make sure to _create_ the file with the right | COMMENT |
| MEDIUM | python/ray/autoscaler/local/example-full.yaml | 115 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | …on/ray/autoscaler/local/example-minimal-automatic.yaml | 31 | # If Ray is not already installed on your cluster, you can use setup | COMMENT |
| MEDIUM | python/ray/autoscaler/local/example-minimal-manual.yaml | 18 | # If Ray is not already installed on your cluster, you can use setup | COMMENT |
| MEDIUM | python/ray/autoscaler/aws/defaults.yaml | 37 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/aws/defaults.yaml | 38 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/aws/example-full.yaml | 52 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/aws/example-full.yaml | 53 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/aws/example-full.yaml | 158 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | python/ray/autoscaler/aws/example-ml.yaml | 57 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/aws/example-ml.yaml | 58 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/aws/example-ml.yaml | 116 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | python/ray/autoscaler/aws/example-gpu-docker.yaml | 38 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/aws/example-gpu-docker.yaml | 39 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| LOW | …on/ray/data/_internal/datasource/parquet_datasource.py | 886 | # If include_paths is True, make sure to include the path column in the projection | COMMENT |
| LOW | …hon/ray/data/_internal/execution/streaming_executor.py | 515 | # ray.wait() overhead, so make sure to allow multiple dispatch per call for | COMMENT |
| MEDIUM | …ta/_internal/execution/interfaces/physical_operator.py | 547 | Here's a simple example of implementing a basic "Map" operator: | STRING |
| LOW | python/ray/data/tests/datasource/test_mongo.py | 15 | # To run tests locally, make sure you install mongodb-org and have mongod | COMMENT |
| 20 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …/tests/batch/gpu/stages/test_serve_deployment_stage.py | 192 | CODE | |
| MEDIUM | …/tests/batch/gpu/stages/test_serve_deployment_stage.py | 231 | CODE | |
| MEDIUM | …/tests/batch/gpu/stages/test_serve_deployment_stage.py | 350 | CODE | |
| MEDIUM | …/tests/batch/gpu/stages/test_serve_deployment_stage.py | 387 | CODE | |
| MEDIUM | …thon/ray/llm/tests/batch/cpu/stages/test_stage_base.py | 242 | CODE | |
| MEDIUM | …ts/prefill_decode_disagg/test_prefill_decode_disagg.py | 698 | CODE | |
| MEDIUM | python/ray/dag/tests/experimental/actor_defs.py | 78 | CODE | |
| MEDIUM | python/ray/tests/test_basic.py | 1176 | CODE | |
| MEDIUM | python/ray/tests/test_runtime_env_working_dir.py | 347 | CODE | |
| MEDIUM | …hon/ray/tests/test_streaming_generator_backpressure.py | 1439 | CODE | |
| MEDIUM | python/ray/tests/test_baseexceptionandgroup.py | 69 | CODE | |
| MEDIUM | python/ray/tests/test_gcs_fault_tolerance.py | 457 | CODE | |
| MEDIUM | python/ray/tests/test_generators.py | 883 | CODE | |
| MEDIUM | python/ray/tests/test_generators.py | 907 | CODE | |
| MEDIUM | python/ray/tests/test_generators.py | 932 | CODE | |
| MEDIUM | python/ray/tests/test_streaming_generator.py | 286 | CODE | |
| MEDIUM | python/ray/tests/test_streaming_generator.py | 682 | CODE | |
| MEDIUM | python/ray/tests/test_streaming_generator.py | 686 | CODE | |
| MEDIUM | python/ray/serve/tests/test_grpc.py | 1229 | CODE | |
| MEDIUM | python/ray/serve/tests/test_grpc.py | 1271 | CODE | |
| MEDIUM | python/ray/serve/tests/test_fastapi.py | 421 | CODE | |
| MEDIUM | python/ray/serve/_private/local_testing_mode.py | 392 | CODE | |
| MEDIUM | python/ray/data/tests/test_map.py | 207 | CODE | |
| MEDIUM | rllib/core/learner/tests/test_learner_group.py | 162 | CODE | |
| MEDIUM | rllib/core/learner/tests/test_learner_group.py | 164 | CODE | |
| MEDIUM | …ray-observability/doc_code/ray-distributed-debugger.py | 24 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/ray/tune/tests/tutorial.py | 26 | # In this example, we don't change the model architecture | COMMENT |
| HIGH | python/ray/tune/tests/test_logger.py | 300 | # In this example, this is `self.test_dir`. | COMMENT |
| HIGH⚡ | doc/source/cluster/kubernetes/k8s-ecosystem/ingress.md | 47 | # 3. In this example, you need to select public subnets (subnets that "Auto-assign public IPv4 address" is Yes on AWS | COMMENT |
| HIGH | …urce/train/examples/jax/intro_to_jax_trainer/README.md | 612 | # In this example, we use 2 GPUs. | COMMENT |
| HIGH | …al/pytorch_tutorials_hyperparameter_tuning_tutorial.py | 87 | # In this example, we can specify | COMMENT |
| HIGH | …al/pytorch_tutorials_hyperparameter_tuning_tutorial.py | 369 | # In this example, the ``l1`` and ``l2`` parameters | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …thon/ray/experimental/channel/serialization_context.py | 155 | "placeholder", | CODE |
| LOW | python/ray/llm/examples/sglang/query_example.py | 13 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW⚡ | python/ray/tests/chaos/streaming_llm.py | 53 | words = "Lorem ipsum dolor sit amet".split() | CODE |
| LOW⚡ | python/ray/tests/chaos/streaming_llm.py | 53 | words = "Lorem ipsum dolor sit amet".split() | CODE |
| LOW | python/ray/air/tests/test_experiment_restore.py | 82 | csv_file = str(tmp_path / "dummy_data.csv") | CODE |
| LOW | python/ray/air/tests/_test_experiment_restore_run.py | 106 | trainable = tune.with_parameters(trainable, data={"dummy_data": [1, 2, 3]}) | CODE |
| LOW | …/train/v2/tests/test_async_checkpointing_validation.py | 494 | .build_checkpoint_path_from_name("placeholder") | CODE |
| LOW | python/ray/serve/llm/__init__.py | 233 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | STRING |
| LOW | python/ray/serve/llm/__init__.py | 322 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | STRING |
| LOW | python/ray/serve/_private/test_utils.py | 699 | actor_options={"name": "placeholder"}, | CODE |
| LOW | python/ray/data/tests/test_with_column.py | 205 | "expected_first": "John Doe", | CODE |
| LOW | release/llm_tests/serve/test_utils.py | 199 | os.environ["OPENAI_API_KEY"] = api_token or "fake-key" | CODE |
| LOW | release/llm_tests/serve/test_utils.py | 251 | return OpenAI(base_url=f"{server_url}/v1", api_key="fake-key") | CODE |
| LOW | release/llm_tests/serve/test_llm_serve_sglang.py | 71 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | release/llm_tests/serve/test_llm_serve_sglang.py | 355 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | release/llm_tests/serve/test_llm_serve_sglang.py | 425 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | release/llm_tests/serve/test_llm_serve_sglang.py | 490 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | release/llm_tests/serve/test_llm_serve_sglang.py | 559 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW⚡ | release/llm_tests/serve/test_llm_serve_sleep_wakeup.py | 203 | client = OpenAI(base_url=f"{BASE_URL}/v1", api_key="fake-key") | CODE |
| LOW⚡ | release/llm_tests/serve/test_llm_serve_pause_resume.py | 113 | client = OpenAI(base_url=f"{BASE_URL}/v1", api_key="fake-key") | CODE |
| LOW⚡ | release/llm_tests/serve/test_llm_serve_rlhf.py | 129 | client = OpenAI(base_url=f"{BASE_URL}/v1", api_key="fake-key") | CODE |
| LOW | release/ray_release/tests/test_glue.py | 256 | self.command_runner_return["get_last_logs_ex"] = "Lorem ipsum" | CODE |
| LOW | …/doc_code/serve/transcription/transcription_example.py | 85 | client = openai.OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | …urce/llm/doc_code/serve/sglang/sglang_query_example.py | 4 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | doc/source/serve/llm/quick-start.md | 87 | -H "Authorization: Bearer fake-key" \ | CODE |
| LOW | doc/source/serve/llm/quick-start.md | 102 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | doc/source/serve/llm/user-guides/multi-lora.md | 124 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | …ource/serve/llm/user-guides/data-parallel-attention.md | 101 | -H "Authorization: Bearer fake-key" \ | CODE |
| LOW | …ource/serve/llm/user-guides/data-parallel-attention.md | 119 | api_key="fake-key" | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 53 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 72 | -H "Authorization: Bearer fake-key" \ | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 110 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 132 | -H "Authorization: Bearer fake-key" \ | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 185 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 230 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 317 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | doc/source/serve/doc_code/fake_email_creator.yaml | 23 | image: shrekrisanyscale/serve-fake-email-example:example | CODE |
| LOW | doc/source/serve/doc_code/fake_email_creator.yaml | 49 | image: shrekrisanyscale/serve-fake-email-example:example | CODE |
| LOW | doc/source/serve/production-guide/docker.md | 104 | A pre-built version of this image is available at [shrekrisanyscale/serve-fake-email-example](https://hub.docker.com/r/s | CODE |
| LOW | doc/source/serve/tutorials/serve-deepseek.md | 114 | -H "Authorization: Bearer fake-key" \ | CODE |
| LOW | doc/source/serve/tutorials/serve-deepseek.md | 136 | -H "Authorization: Bearer fake-key" \ | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …/cpu/deployments/llm/multiplex/test_multiplex_utils.py | 147 | def test_function(x, y): | CODE |
| LOW | python/ray/util/dask/scheduler_utils.py | 122 | def execute_task(key, task_info, dumps, loads, get_id, pack_exception): | CODE |
| LOW | python/ray/tests/test_basic.py | 979 | def test_function(fn, remote_fn): | STRING |
| LOW | python/ray/tests/test_basic.py | 1007 | def test_function(fn, remote_fn): | STRING |
| LOW | python/ray/tests/test_basic.py | 1064 | def test_function(fn, remote_fn): | STRING |
| LOW | python/ray/tests/test_args.py | 18 | def test_function(fn, remote_fn): | CODE |
| LOW | python/ray/tests/test_args.py | 50 | def test_function(fn, remote_fn): | CODE |
| LOW | python/ray/tests/test_task_metrics.py | 128 | def my_function(): | CODE |
| LOW⚡ | python/ray/tests/chaos/streaming_llm.py | 45 | async def handle_request(self, prompt: str) -> StreamingResponse: | CODE |
| LOW | python/ray/tune/tests/test_api.py | 640 | def run_task(config): | CODE |
| LOW | python/ray/serve/tests/test_handle_1.py | 363 | async def handle_request(self, request: str): | CODE |
| LOW | python/ray/serve/tests/test_handle_1.py | 406 | async def handle_request(self, request: str): | CODE |
| LOW | python/ray/serve/tests/test_handle_1.py | 439 | async def handle_request(self, request: str): | CODE |
| LOW | python/ray/serve/tests/test_handle_1.py | 477 | async def handle_request(self, request: str): | CODE |
| LOW | python/ray/serve/tests/test_handle_1.py | 527 | async def handle_request(self, request: str): | CODE |
| LOW | python/ray/serve/tests/test_task_processor.py | 612 | def process_data(self, payload): | CODE |
| LOW | python/ray/serve/tests/test_task_processor.py | 681 | def process_data(self, data): | CODE |
| LOW | python/ray/serve/tests/test_actor_replica_wrapper.py | 110 | async def handle_request( | CODE |
| LOW⚡ | …on/ray/serve/tests/typing_files/check_handle_typing.py | 129 | def my_method(self, x: int) -> str: | CODE |
| LOW | python/ray/serve/_private/tracing_utils.py | 176 | def my_function(obj): | STRING |
| LOW | python/ray/serve/_private/replica.py | 1620 | async def handle_request( | CODE |
| LOW | python/ray/serve/_private/replica.py | 3308 | async def handle_request( | CODE |
| LOW | …ve_tests/workloads/multi_deployment_1k_noop_replica.py | 98 | async def handle_request(self, body: bytes, depth: int): | CODE |
| LOW | rllib/utils/actor_manager.py | 225 | def do_something(self): | STRING |
| LOW | doc/source/ray-core/doc_code/tasks.py | 16 | def my_function(): | CODE |
| LOW | doc/source/ray-core/doc_code/tasks.py | 115 | def my_function(): | CODE |
| LOW | doc/source/ray-core/doc_code/actor_checkpointing.py | 15 | def execute_task(self, crash=False): | CODE |
| LOW | doc/source/serve/doc_code/streaming_tutorial.py | 39 | def handle_request(self, prompt: str) -> StreamingResponse: | CODE |
| LOW | doc/source/serve/doc_code/streaming_tutorial.py | 126 | async def handle_request(self, ws: WebSocket) -> None: | CODE |
| LOW | doc/source/serve/doc_code/streaming_tutorial.py | 267 | async def handle_request(self, prompt: str) -> StreamingResponse: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/ray/data/dataset.py | 5891 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | python/ray/data/dataset.py | 5891 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | python/ray/data/dataset.py | 5902 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | python/ray/data/dataset.py | 5902 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | …/ray/data/_internal/datasource/turbopuffer_datasink.py | 101 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | …/ray/data/_internal/datasource/turbopuffer_datasink.py | 101 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | …/ray/data/_internal/datasource/turbopuffer_datasink.py | 114 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | …/ray/data/_internal/datasource/turbopuffer_datasink.py | 114 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | …/ray/data/_internal/datasource/turbopuffer_datasink.py | 127 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | …/ray/data/_internal/datasource/turbopuffer_datasink.py | 127 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | doc/source/serve/tutorials/video-analysis/README.md | 94 | PEXELS_API_KEY = os.environ.get("PEXELS_API_KEY") # Or set directly: "your-api-key" | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/serve/_private/constants.py | 137 | # Example usage: | COMMENT |
| LOW | rllib/utils/tests/run_memory_leak_tests.py | 6 | # Example usage: | COMMENT |
| LOW | doc/source/cluster/doc_code/slurm-launch.py | 2 | # Usage: | COMMENT |
| LOW | src/ray/util/shared_lru.h | 20 | // Example usage: | COMMENT |
| LOW | src/ray/util/thread_checker.h | 17 | // Example usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/train/__init__.py | 113 | # TODO: consider implementing these in v1 and raising ImportError instead. | COMMENT |
| LOW | …ray/serve/tests/test_deployment_scheduler_downscale.py | 159 | # TODO: Add test for downscale placement group fallback_strategy when it's added to deployment options. | COMMENT |