Repository Analysis

ray-project/ray

Ray is an AI compute engine. Ray consists of a core distributed runtime and a set of AI Libraries for accelerating ML workloads.

22.0 Moderate AI signal View on GitHub

Analysis Overview

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).

22.0
Adjusted Score
22.0
Raw Score
100%
Time Factor
2026-08-01
Last Push
43.4K
Stars
Python
Language
1.6M
Lines of Code
7.5K
Files
27.0K
Pattern Hits
2026-08-02
Scan Date
0.15
HC Hit Rate

What These Metrics Mean

Adjusted Score
Primary synthetic code indicator. Raw score normalised per 1,000 lines of code and multiplied by the temporal discount factor. This is the definitive comparative metric — use it to rank repositories by AI authorship density.
Raw Score
The unmodified sum of all severity-weighted, context-multiplied pattern match scores before temporal discounting. Reflects the absolute signal strength independent of when the repository was last active.
Time Factor
The temporal discount multiplier (0–100%) applied to the raw score. Repositories last updated before ChatGPT's launch (Nov 2022) receive a 5% factor. Full signal is only assigned to repositories active in the post-adoption era (Jan 2024+).
Pattern Hits
Total count of individual pattern matches across all files and categories. A high hit count with a low score may indicate a very large codebase with isolated AI snippets; a low count with a high score indicates dense, concentrated AI signatures.
HC Hit Rate
High+Critical pattern hits per file, averaged across the repository. This orthogonal signal catches repositories where a few files are densely packed with high-severity AI tells — a strong indicator even when the normalised score appears moderate due to codebase size.
Lines of Code / Files
Total lines and files analysed. The scanner examines 94 file extensions. These denominators are used to normalise the score, enabling fair comparison between repositories of vastly different sizes.

Score History

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.

Severity Breakdown

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.

CRITICAL 103HIGH 985MEDIUM 1998LOW 23956

Directory Score Breakdown

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.

Pattern Findings

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.

Hyper-Verbose Identifiers13737 hits · 12825 pts
SeverityFileLineSnippetContext
LOWpython/setup.py423def is_native_windows_or_msys():CODE
LOWpython/setup.py429def is_invalid_windows_platform():CODE
LOWpython/setup.py484def replace_symlinks_with_junctions():CODE
LOWpython/ray/client_builder.py345def _get_builder_from_address(address: Optional[str]) -> ClientBuilder:CODE
LOWpython/ray/runtime_context.py461 def was_current_actor_reconstructed(self):CODE
LOWpython/ray/runtime_context.py475 def current_placement_group_id(self):CODE
LOWpython/ray/runtime_context.py493 def should_capture_child_tasks_in_placement_group(self):CODE
LOWpython/ray/cross_language.py124def _get_function_descriptor_for_actor_method(CODE
LOWpython/ray/cluster_utils.py402 def remaining_processes_alive(self):CODE
LOWpython/ray/exceptions.py121def _is_hidden_internal_frame(line: str, extra_markers: Sequence[str] = ()) -> bool:CODE
LOWpython/ray/exceptions.py207 def make_dual_exception_instance(self) -> "RayTaskError":CODE
LOWpython/ray/exceptions.py221 def _make_normal_dual_exception_instance(self) -> "RayTaskError":CODE
LOWpython/ray/exceptions.py255 def _make_exceptiongroup_dual_exception_instance(self) -> "RayTaskError":CODE
LOWpython/ray/actor.py1690 def _ray_from_function_descriptor(CODE
LOWpython/ray/job_config.py172 def set_default_actor_lifetime(self, default_actor_lifetime: str) -> None:CODE
LOWpython/ray/job_config.py256 def _runtime_env_has_working_dir(self):CODE
LOWpython/ray/job_config.py259 def _get_serialized_runtime_env(self) -> str:CODE
LOWpython/ray/job_config.py263 def _get_proto_runtime_env_config(self) -> str:CODE
LOWpython/ray/runtime_env/runtime_env.py97 def parse_and_validate_runtime_env_config(CODE
LOWpython/ray/runtime_env/runtime_env.py124 def build_proto_runtime_env_config(self) -> ProtoRuntimeEnvConfig:CODE
LOWpython/ray/experimental/shuffle.py286 def output_writer_non_streaming(CODE
LOWpython/ray/experimental/internal_kv.py16def internal_kv_get_gcs_client():CODE
LOWpython/ray/experimental/locations.py45def get_local_object_locations(CODE
LOWpython/ray/experimental/tqdm_ray.py316 def _process_state_update_locked(self, state: ProgressBarState) -> None:CODE
LOWpython/ray/experimental/tqdm_ray.py378 def _get_or_allocate_bar_group(self, state: ProgressBarState):CODE
LOWpython/ray/experimental/collective/conftest.py201def mock_do_destroy_nccl_group(self, group_id: str) -> None:CODE
LOWpython/ray/experimental/collective/conftest.py231def check_nccl_group_teardown(CODE
LOWpython/ray/experimental/collective/collective.py39 def remove_remote_communicator(self, name: str):CODE
LOWpython/ray/experimental/collective/collective.py134 def _do_init_collective_group(self, rank: int):CODE
LOWpython/ray/experimental/collective/collective.py182 def _do_destroy_collective_group(self):CODE
LOWpython/ray/experimental/collective/collective.py200def destroy_all_collective_groups():CODE
LOWpython/ray/experimental/channel/accelerator_context.py222def register_accelerator_context(CODE
LOWpython/ray/experimental/channel/accelerator_context.py236def is_accelerator_context_registered():CODE
LOW…thon/ray/experimental/channel/shared_memory_channel.py335 def ensure_registered_as_writer(self) -> None:CODE
LOW…thon/ray/experimental/channel/shared_memory_channel.py357 def ensure_registered_as_reader(self) -> None:CODE
LOW…thon/ray/experimental/channel/shared_memory_channel.py369 def _deserialize_reader_channel(CODE
LOW…thon/ray/experimental/channel/shared_memory_channel.py410 def _resize_channel_if_needed(self, serialized_value: str, timeout_ms: int):CODE
LOW…thon/ray/experimental/channel/shared_memory_channel.py584 def ensure_registered_as_writer(self):CODE
LOW…thon/ray/experimental/channel/shared_memory_channel.py591 def ensure_registered_as_reader(self):CODE
LOW…thon/ray/experimental/channel/shared_memory_channel.py760 def ensure_registered_as_writer(self) -> None:CODE
LOW…thon/ray/experimental/channel/shared_memory_channel.py767 def ensure_registered_as_reader(self) -> None:CODE
LOWpython/ray/experimental/channel/torch_tensor_type.py117 def register_custom_serializer(self) -> None:CODE
LOW…thon/ray/experimental/channel/intra_process_channel.py38 def ensure_registered_as_writer(self) -> None:CODE
LOW…thon/ray/experimental/channel/intra_process_channel.py41 def ensure_registered_as_reader(self) -> None:CODE
LOWpython/ray/experimental/channel/cached_channel.py38 def ensure_registered_as_writer(self) -> None:CODE
LOWpython/ray/experimental/channel/cached_channel.py42 def ensure_registered_as_reader(self) -> None:CODE
LOW…thon/ray/experimental/channel/serialization_context.py74 def set_use_external_transport(self, use_external_transport: bool) -> None:CODE
LOW…thon/ray/experimental/channel/serialization_context.py81 def reset_out_of_band_tensors(CODE
LOW…thon/ray/experimental/channel/serialization_context.py113 def serialize_to_numpy_or_scalar(CODE
LOW…thon/ray/experimental/channel/serialization_context.py170 def deserialize_from_numpy_or_scalar(CODE
LOWpython/ray/experimental/channel/common.py35def retry_and_check_interpreter_exit(f: Callable[[], None]) -> bool:CODE
LOWpython/ray/experimental/channel/common.py68 def register_custom_serializer(self) -> None:CODE
LOWpython/ray/experimental/channel/common.py201 def ensure_registered_as_writer(self):CODE
LOWpython/ray/experimental/channel/common.py207 def ensure_registered_as_reader(self):CODE
LOWpython/ray/experimental/channel/common.py324 def _consume_leftover_channels_if_needed(CODE
LOWpython/ray/experimental/channel/utils.py17def split_readers_by_locality(CODE
LOWpython/ray/experimental/channel/utils.py46def split_actors_by_node_locality(CODE
LOW…perimental/channel/torch_tensor_accelerator_channel.py167 def ensure_registered_as_writer(self):CODE
LOW…perimental/channel/torch_tensor_accelerator_channel.py174 def ensure_registered_as_reader(self):CODE
LOW…perimental/channel/torch_tensor_accelerator_channel.py463 def ensure_registered_as_writer(self):CODE
13677 more matches not shown…
Decorative Section Separators777 hits · 2724 pts
SeverityFileLineSnippetContext
MEDIUMpython/requirements/ml/rllib-test-requirements.txt6# ---------------------COMMENT
MEDIUMpython/ray/experimental/raysort/main.py27# ------------------------------------------------------------COMMENT
MEDIUMpython/ray/experimental/raysort/main.py29# ------------------------------------------------------------COMMENT
MEDIUMpython/ray/experimental/raysort/main.py126# ------------------------------------------------------------COMMENT
MEDIUMpython/ray/experimental/raysort/main.py128# ------------------------------------------------------------COMMENT
MEDIUMpython/ray/experimental/raysort/main.py179# ------------------------------------------------------------COMMENT
MEDIUMpython/ray/experimental/raysort/main.py181# ------------------------------------------------------------COMMENT
MEDIUMpython/ray/experimental/raysort/main.py399# ------------------------------------------------------------COMMENT
MEDIUMpython/ray/experimental/raysort/main.py401# ------------------------------------------------------------COMMENT
MEDIUMpython/ray/experimental/raysort/main.py440# ------------------------------------------------------------COMMENT
MEDIUMpython/ray/experimental/raysort/main.py442# ------------------------------------------------------------COMMENT
MEDIUM…y/llm/_internal/batch/benchmark/benchmark_processor.py416# -----------------------------------------------------------------------------COMMENT
MEDIUM…y/llm/_internal/batch/benchmark/benchmark_processor.py418# -----------------------------------------------------------------------------COMMENT
MEDIUM…y/llm/_internal/batch/benchmark/benchmark_processor.py508# -----------------------------------------------------------------------------COMMENT
MEDIUM…y/llm/_internal/batch/benchmark/benchmark_processor.py510# -----------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/interactive.py47# ---------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/interactive.py49# ---------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/interactive.py57# ---------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/interactive.py59# ---------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/interactive.py799# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/interactive.py801# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/interactive.py87# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/interactive.py89# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/interactive.py166# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/interactive.py168# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/interactive.py400# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/interactive.py402# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/interactive.py737# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/interactive.py739# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py63# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py65# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py545 # --------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py547 # --------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py550 # --------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py552 # --------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py763 # --------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py765 # --------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py771 # --------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py773 # --------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py37# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py39# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py257# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py259# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py278# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py280# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py466# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py468# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py522 # --------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py524 # --------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py616 # --------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py618 # --------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py686 # --------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py688 # --------------------------------------------------------------------------COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py823# ============================================================================COMMENT
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py825# ============================================================================COMMENT
MEDIUM…ernal/serve/serving_patterns/prefill_decode/builder.py45# ---------------------------------------------------------------------------COMMENT
MEDIUM…ernal/serve/serving_patterns/prefill_decode/builder.py48# ---------------------------------------------------------------------------COMMENT
MEDIUM…ernal/serve/serving_patterns/prefill_decode/builder.py72# ---------------------------------------------------------------------------COMMENT
MEDIUM…ernal/serve/serving_patterns/prefill_decode/builder.py74# ---------------------------------------------------------------------------COMMENT
MEDIUM…ernal/serve/serving_patterns/prefill_decode/builder.py217# ---------------------------------------------------------------------------COMMENT
717 more matches not shown…
Unused Imports2518 hits · 2336 pts
SeverityFileLineSnippetContext
LOWpython/ray/__init__.py87CODE
LOWpython/ray/__init__.py87CODE
LOWpython/ray/__init__.py87CODE
LOWpython/ray/__init__.py87CODE
LOWpython/ray/__init__.py87CODE
LOWpython/ray/__init__.py87CODE
LOWpython/ray/__init__.py87CODE
LOWpython/ray/__init__.py87CODE
LOWpython/ray/__init__.py87CODE
LOWpython/ray/__init__.py87CODE
LOWpython/ray/__init__.py87CODE
LOWpython/ray/__init__.py87CODE
LOWpython/ray/__init__.py87CODE
LOWpython/ray/__init__.py87CODE
LOWpython/ray/__init__.py87CODE
LOWpython/ray/__init__.py108CODE
LOWpython/ray/__init__.py108CODE
LOWpython/ray/__init__.py108CODE
LOWpython/ray/__init__.py108CODE
LOWpython/ray/__init__.py114CODE
LOWpython/ray/__init__.py114CODE
LOWpython/ray/__init__.py114CODE
LOWpython/ray/__init__.py114CODE
LOWpython/ray/__init__.py114CODE
LOWpython/ray/__init__.py114CODE
LOWpython/ray/__init__.py114CODE
LOWpython/ray/__init__.py114CODE
LOWpython/ray/__init__.py114CODE
LOWpython/ray/__init__.py114CODE
LOWpython/ray/__init__.py114CODE
LOWpython/ray/__init__.py114CODE
LOWpython/ray/__init__.py114CODE
LOWpython/ray/__init__.py114CODE
LOWpython/ray/__init__.py114CODE
LOWpython/ray/__init__.py132CODE
LOWpython/ray/__init__.py137CODE
LOWpython/ray/__init__.py140CODE
LOWpython/ray/__init__.py140CODE
LOWpython/ray/__init__.py141CODE
LOWpython/ray/__init__.py142CODE
LOWpython/ray/__init__.py143CODE
LOWpython/ray/__init__.py147CODE
LOWpython/ray/__init__.py147CODE
LOWpython/ray/__init__.py283CODE
LOWpython/ray/__init__.py284CODE
LOWpython/ray/__init__.py285CODE
LOWpython/ray/cross_language.py1CODE
LOWpython/ray/cross_language.py1CODE
LOWpython/ray/cross_language.py1CODE
LOWpython/ray/runtime_env/__init__.py1CODE
LOWpython/ray/runtime_env/__init__.py1CODE
LOWpython/ray/experimental/queue.py3CODE
LOWpython/ray/experimental/queue.py3CODE
LOWpython/ray/experimental/queue.py3CODE
LOWpython/ray/experimental/__init__.py1CODE
LOWpython/ray/experimental/__init__.py2CODE
LOWpython/ray/experimental/__init__.py2CODE
LOWpython/ray/experimental/__init__.py3CODE
LOWpython/ray/experimental/__init__.py3CODE
LOWpython/ray/experimental/__init__.py3CODE
2458 more matches not shown…
Over-Commented Block2797 hits · 2312 pts
SeverityFileLineSnippetContext
LOW.readthedocs.yaml1# .readthedocs.yamlCOMMENT
LOW.readthedocs.yaml21 # Code sources (python/ray/, rllib/) are intentionally not matched, so aCOMMENT
LOW.readthedocs.yaml61 # config value differs between the environment that produced the cache andCOMMENT
LOWpython/requirements_compiled_py3.14.txt1--extra-index-url https://download.pytorch.org/whl/cpuCOMMENT
LOWpython/requirements_compiled_py3.14.txt21 # tensorflow-metadataCOMMENT
LOWpython/requirements_compiled_py3.14.txt41aioboto3==12.1.0COMMENT
LOWpython/requirements_compiled_py3.14.txt61 # delta-sharingCOMMENT
LOWpython/requirements_compiled_py3.14.txt81alembic==1.18.4COMMENT
LOWpython/requirements_compiled_py3.14.txt101 # httpxCOMMENT
LOWpython/requirements_compiled_py3.14.txt121 # viaCOMMENT
LOWpython/requirements_compiled_py3.14.txt141 # via -r python/requirements/py313/test-requirements.txtCOMMENT
LOWpython/requirements_compiled_py3.14.txt161 # via cfn-lintCOMMENT
LOWpython/requirements_compiled_py3.14.txt181 # azure-mgmt-coreCOMMENT
LOWpython/requirements_compiled_py3.14.txt201 # via -r python/requirements/py313/test-requirements.txtCOMMENT
LOWpython/requirements_compiled_py3.14.txt221 # viaCOMMENT
LOWpython/requirements_compiled_py3.14.txt241 # glomCOMMENT
LOWpython/requirements_compiled_py3.14.txt261 # aws-xray-sdkCOMMENT
LOWpython/requirements_compiled_py3.14.txt281celery==5.6.3COMMENT
LOWpython/requirements_compiled_py3.14.txt301 # moocoreCOMMENT
LOWpython/requirements_compiled_py3.14.txt321 # click-didyoumeanCOMMENT
LOWpython/requirements_compiled_py3.14.txt341click-plugins==1.1.1.2COMMENT
LOWpython/requirements_compiled_py3.14.txt361 # nevergradCOMMENT
LOWpython/requirements_compiled_py3.14.txt381 # ipykernelCOMMENT
LOWpython/requirements_compiled_py3.14.txt401 # via gsutilCOMMENT
LOWpython/requirements_compiled_py3.14.txt421 # -r python/requirements.txtCOMMENT
LOWpython/requirements_compiled_py3.14.txt441 # evaluateCOMMENT
LOWpython/requirements_compiled_py3.14.txt461 # via delta-sharingCOMMENT
LOWpython/requirements_compiled_py3.14.txt481 # -r python/requirements/ml/py313/data-requirements.txtCOMMENT
LOWpython/requirements_compiled_py3.14.txt501 # mlflowCOMMENT
LOWpython/requirements_compiled_py3.14.txt521 # array-recordCOMMENT
LOWpython/requirements_compiled_py3.14.txt541 # -r python/requirements/py313/test-requirements.txtCOMMENT
LOWpython/requirements_compiled_py3.14.txt561filelock==3.29.0COMMENT
LOWpython/requirements_compiled_py3.14.txt581 # viaCOMMENT
LOWpython/requirements_compiled_py3.14.txt601fsspec==2023.12.1COMMENT
LOWpython/requirements_compiled_py3.14.txt621fugue==0.9.7COMMENT
LOWpython/requirements_compiled_py3.14.txt641 # mujocoCOMMENT
LOWpython/requirements_compiled_py3.14.txt661 # gcs-oauth2-boto-pluginCOMMENT
LOWpython/requirements_compiled_py3.14.txt681 # -r python/requirements/ml/py313/data-test-requirements.txtCOMMENT
LOWpython/requirements_compiled_py3.14.txt701 # google-cloud-bigqueryCOMMENT
LOWpython/requirements_compiled_py3.14.txt721 # grapheneCOMMENT
LOWpython/requirements_compiled_py3.14.txt741 # opentelemetry-exporter-otlp-proto-grpcCOMMENT
LOWpython/requirements_compiled_py3.14.txt761 # shimmyCOMMENT
LOWpython/requirements_compiled_py3.14.txt781 # -r python/requirements/ml/py313/tune-test-requirements.txtCOMMENT
LOWpython/requirements_compiled_py3.14.txt801 # gradio-clientCOMMENT
LOWpython/requirements_compiled_py3.14.txt821 # via azure-cli-coreCOMMENT
LOWpython/requirements_compiled_py3.14.txt841 # moviepyCOMMENT
LOWpython/requirements_compiled_py3.14.txt861 # prophetCOMMENT
LOWpython/requirements_compiled_py3.14.txt881 # viaCOMMENT
LOWpython/requirements_compiled_py3.14.txt901 # via ipythonCOMMENT
LOWpython/requirements_compiled_py3.14.txt921 # torch-geometricCOMMENT
LOWpython/requirements_compiled_py3.14.txt941jsonpath-ng==1.8.0COMMENT
LOWpython/requirements_compiled_py3.14.txt961jsonschema-path==0.3.4COMMENT
LOWpython/requirements_compiled_py3.14.txt981 # nbconvertCOMMENT
LOWpython/requirements_compiled_py3.14.txt1001jupyterlab-server==2.28.0COMMENT
LOWpython/requirements_compiled_py3.14.txt1021kubernetes==24.2.0COMMENT
LOWpython/requirements_compiled_py3.14.txt1041 # lightningCOMMENT
LOWpython/requirements_compiled_py3.14.txt1061 # -r python/requirements/py313/test-requirements.txtCOMMENT
LOWpython/requirements_compiled_py3.14.txt1081 # richCOMMENT
LOWpython/requirements_compiled_py3.14.txt1101mdit-py-plugins==0.3.5COMMENT
LOWpython/requirements_compiled_py3.14.txt1121 # viaCOMMENT
2737 more matches not shown…
Self-Referential Comments799 hits · 2305 pts
SeverityFileLineSnippetContext
MEDIUMpython/setup.py716 # Create the target directory if it doesn't already exist.COMMENT
MEDIUMpython/ray/cluster_utils.py172 # Create a new global state accessor for fetching GCS table.COMMENT
MEDIUMpython/ray/actor.py1284 # Create an instance without __init__ called.COMMENT
MEDIUMpython/ray/runtime_env/runtime_env.py160 """This class is used to define a runtime environment for a job, task,STRING
MEDIUMpython/ray/experimental/shuffle.py42 """This class is used to stream shuffle map outputs to the object store.STRING
MEDIUM…thon/ray/experimental/channel/shared_memory_channel.py720 # Create a local channel for the writer and the local readers.COMMENT
MEDIUMpython/ray/experimental/channel/common.py36 """This function is only useful when f contains channel read/write.STRING
MEDIUM…perimental/channel/torch_tensor_accelerator_channel.py136 # Create a CPU channel to send non-tensor data.COMMENT
MEDIUMpython/ray/experimental/rdt/cuda_ipc_transport.py77 # Create an interprocess-shareable CUDA event so that the receiverCOMMENT
MEDIUMpython/ray/llm/_internal/common/utils/cloud_utils.py530 # Create a single cache instance for this functionCOMMENT
MEDIUMpython/ray/llm/_internal/common/utils/download_utils.py278 # Create the torch cache kernels directory if it doesn't exist.COMMENT
MEDIUM…al/common/utils/cloud_filesystem/pyarrow_filesystem.py145 # Create the adlfs filesystemCOMMENT
MEDIUM…/ray/llm/_internal/batch/stages/sglang_engine_stage.py264 # Create an LLM engine.COMMENT
MEDIUMpython/ray/llm/_internal/serve/core/ingress/ingress.py210 # Create a new class that inherits from the original to avoid modifying itCOMMENT
MEDIUMpython/ray/llm/_internal/serve/core/ingress/utils.py118 # Create a new generator that yields the peeked item firstCOMMENT
MEDIUMpython/ray/llm/_internal/serve/utils/registry.py74 # Create a loader callable that imports on demandCOMMENT
MEDIUMpython/ray/llm/_internal/serve/utils/registry.py100 # Create a registry for a component categorySTRING
MEDIUMpython/ray/llm/_internal/serve/utils/registry.py151 # Create a loader callable (handles both direct values and string paths)COMMENT
MEDIUM…_internal/serve/observability/usage_telemetry/usage.py83 """This method is only used in tests to record the telemetry tags to a differentSTRING
MEDIUM…_internal/serve/observability/usage_telemetry/usage.py88 """This method is only used in tests to clean up the models list."""STRING
MEDIUMpython/ray/llm/tests/conftest.py244 # Create a vLLM serve deploymentSTRING
MEDIUMpython/ray/llm/tests/common/cloud/test_s3_filesystem.py344 # Create a test fileCOMMENT
MEDIUMpython/ray/llm/tests/common/cloud/test_s3_filesystem.py365 # Create a test fileCOMMENT
MEDIUM…y/llm/tests/batch/gpu/stages/test_vllm_engine_stage.py27 # Create a mock instance that will be returned by the wrapper classCOMMENT
MEDIUM…/tests/batch/gpu/stages/test_serve_deployment_stage.py69 # Create a mock response that will be returned directlyCOMMENT
MEDIUM…llm/tests/batch/gpu/stages/test_sglang_engine_stage.py23 # Create a mock instance that will be returned by the wrapper classCOMMENT
MEDIUM…llm/tests/batch/gpu/stages/test_sglang_engine_stage.py90 # Create a mock SGLang outputCOMMENT
MEDIUM…llm/tests/batch/gpu/stages/test_sglang_engine_stage.py265 # Create a task type that doesn't exist in the prepare_llm_request methodCOMMENT
MEDIUM…/llm/tests/batch/cpu/stages/test_http_request_stage.py99 # Create a fake sessionCOMMENT
MEDIUMpython/ray/llm/tests/serve/conftest.py124 # Create a mock audio file for testingCOMMENT
MEDIUMpython/ray/llm/tests/serve/conftest.py129 # Create a simple mock audio file (WAV format)COMMENT
MEDIUM…llm/tests/serve/cpu/deployments/routers/test_router.py501 # Create a mock deployment handle that captures raw_request_infoCOMMENT
MEDIUM…llm/tests/serve/cpu/deployments/routers/test_router.py537 # Create a mock FastAPI requestCOMMENT
MEDIUM…e/cpu/deployments/routers/test_make_fastapi_ingress.py29 # Create the ingress class - should not raiseCOMMENT
MEDIUM…llm/tests/serve/cpu/deployments/llm/test_llm_server.py328 # Create a server with a mocked engineCOMMENT
MEDIUM…llm/tests/serve/cpu/deployments/llm/test_llm_server.py351 # Create a server with a mocked engineCOMMENT
MEDIUM…llm/tests/serve/cpu/deployments/llm/test_llm_server.py374 # Create a server with a mocked engineCOMMENT
MEDIUM…llm/tests/serve/cpu/deployments/llm/test_llm_server.py397 # Create a server with a mocked engineCOMMENT
MEDIUM…llm/tests/serve/cpu/deployments/llm/test_llm_server.py428 # Create a chat completion requestCOMMENT
MEDIUM…loyments/llm/vllm/kv_transfer_backends/test_factory.py40 # Create a Serve deployment that will run in a different process than theCOMMENT
MEDIUM…/cpu/deployments/llm/multiplex/test_multiplex_utils.py32 # Create a mock that raises ValueError twice then succeedsCOMMENT
MEDIUM…/cpu/deployments/llm/multiplex/test_multiplex_utils.py52 # Create a mock that always raises ValueErrorCOMMENT
MEDIUM…/cpu/deployments/llm/multiplex/test_multiplex_utils.py74 # Create a mock that raises TypeErrorCOMMENT
MEDIUM…/cpu/deployments/llm/multiplex/test_multiplex_utils.py96 # Create a mock that always raises ValueErrorCOMMENT
MEDIUM…/cpu/deployments/llm/multiplex/test_multiplex_utils.py121 # Create a mock that always raises ValueErrorCOMMENT
MEDIUM…/cpu/deployments/llm/multiplex/test_multiplex_utils.py146 # Define a function with docstring and nameCOMMENT
MEDIUM…pu/deployments/llm/multiplex/test_lora_model_loader.py56 # Create a simple mock for sync_modelCOMMENT
MEDIUM…pu/deployments/llm/multiplex/test_lora_model_loader.py93 # Create a mock for sync_files_with_lock that tracks calls and fails initiallyCOMMENT
MEDIUM…pu/deployments/llm/multiplex/test_lora_model_loader.py140 # Create a mock for sync_files_with_lock that tracks calls and fails initiallyCOMMENT
MEDIUM…lm/tests/serve/cpu/deployments/utils/test_broadcast.py11# Define a simple deployment for testingCOMMENT
MEDIUMpython/ray/util/tracing/setup_tempo_tracing.py1# This file is intended for examples exporting traces to a local OTLP listenerCOMMENT
MEDIUM…ective/collective_group/torch_gloo_collective_group.py106 # Create a subgroup for this logical group. For the default group, use WORLD.COMMENT
MEDIUMpython/ray/util/state/state_cli.py253 # Create a table.STRING
MEDIUMpython/ray/util/state/state_cli.py296 # Create a table per callsite.STRING
MEDIUMpython/ray/util/state/state_cli.py453 # Create the State API server and put it into contextSTRING
MEDIUMpython/ray/util/state/state_cli.py604 # Create the State API server and put it into contextSTRING
MEDIUMpython/ray/_common/tests/test_usage_stats.py1551 # Create a mock response based on the URL.COMMENT
MEDIUMpython/ray/_common/tests/test_signature.py95 # Create a mock Cython function missing required attributesCOMMENT
MEDIUMpython/ray/_common/observability/__init__.py1"""This module provides the Python API for emitting internal Ray eventsSTRING
MEDIUMpython/ray/dag/compiled_dag_node.py1660 # Create an output channel for each output of the current node.STRING
739 more matches not shown…
Docstring Block Structure426 hits · 1995 pts
SeverityFileLineSnippetContext
HIGHpython/ray/remote_function.py203Configures and overrides the task invocation parameters. The arguments are the same as those that can be passedSTRING
HIGHpython/ray/cluster_utils.py352Waits for correct number of nodes to be registered. This will wait until the number of live nodes in the clientSTRING
HIGHpython/ray/actor.py948Convenience method for executing an actor method call with options. Same arguments as func._remote(), but returSTRING
HIGHpython/ray/actor.py1732Configures and overrides the actor instantiation parameters. The arguments are the same as those that can be paSTRING
HIGHpython/ray/actor.py2611Handle dynamic attribute access for actor methods. This method is called when accessing attributes that don't eSTRING
HIGHpython/ray/actor.py2844Run a closure remotely on this actor instance. Provides a standard way to execute an arbitrary callable on STRING
HIGHpython/ray/job_config.py269Generates a JobConfig object from json. Examples: .. testcode:: from ray.job_confiSTRING
HIGHpython/ray/experimental/locations.py10Lookup the locations for a list of objects. It returns a dict maps from an object to its location. The dict excludeSTRING
HIGHpython/ray/experimental/locations.py48Lookup the locations for a list of objects *from the local core worker*. No RPCs are made in this method. It reSTRING
HIGHpython/ray/experimental/rdt/tensor_transport_manager.py224Wait for a previously initiated fetch to complete and return the tensors. The default implementation returns thSTRING
HIGHpython/ray/experimental/rdt/rdt_manager.py877 Fetch and get RDT objects for a list of object IDs, pipelining async fetches. This is used in the ray.STRING
HIGHpython/ray/experimental/rdt/nixl_tensor_transport.py478Waits for a previously initiated fetch to complete and returns the tensors. Args: fetch_request: ThSTRING
HIGHpython/ray/experimental/rdt/nixl_memory_pool.py107Allocate pool blocks for unique storages, copy data in, and return pool-backed tensor views for each input tensoSTRING
HIGHpython/ray/llm/_internal/common/utils/cloud_utils.py148Get the appropriate provider-specific filesystem class based on URI. Args: bucket_uri: URI of the cSTRING
HIGHpython/ray/llm/_internal/common/utils/import_utils.py11Try 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.py45Parse S3 URI into bucket and key. Args: uri: S3 URI (e.g., s3://bucket/path/to/object or s3://anonySTRING
HIGH…al/common/utils/cloud_filesystem/pyarrow_filesystem.py81Create an Azure filesystem for Azure Blob Storage or ABFSS. Args: object_uri: Azure URI (azure://coSTRING
HIGHpython/ray/llm/_internal/batch/benchmark/dataset.py45 Sample prompts from the loaded dataset. Args: num_requests: The number of prompts to samplSTRING
HIGHpython/ray/llm/_internal/batch/stages/base.py107A stage UDF wrapper that processes the input and output columns before and after the UDF. The expected STRING
HIGHpython/ray/llm/_internal/batch/processor/base.py93Return a normalized dict of worker pool parameters from `self.concurrency`. Behavior: - If `concurrencySTRING
HIGH…rnal/serve/serving_patterns/data_parallel/dp_server.py72Retrieve the DP master info for gang_id, polling until available. Args: gang_id: The ID of the gangSTRING
HIGHpython/ray/llm/_internal/serve/core/ingress/ingress.py177 Create a Ray Serve ingress deployment from a class and endpoint mapping. Args: cls: The class to conveSTRING
HIGHpython/ray/llm/_internal/serve/core/engine/protocol.py59Run a ChatCompletion with the engine. To implement this method, you need to take a openAI compatible chat requeSTRING
HIGHpython/ray/llm/_internal/serve/core/engine/protocol.py88Run a Completion with the engine. Similar to chat, this method is an async generator, so it yields chunks STRING
HIGHpython/ray/llm/_internal/serve/core/engine/protocol.py149Run a Transcription with the engine. Similar to chat and completion, this method is an async generator, STRING
HIGHpython/ray/llm/_internal/serve/core/engine/protocol.py181Tokenize the input text. This method tokenizes the input prompt or chat messages and returns the token STRING
HIGHpython/ray/llm/_internal/serve/core/engine/protocol.py205Detokenize the input token IDs. This method converts token IDs back into text. Args: requeSTRING
HIGHpython/ray/llm/_internal/serve/utils/registry.py52Create a loader callable for a value. Handles both direct objects/classes and string paths for lazy loading. ASTRING
HIGHpython/ray/llm/_internal/serve/utils/registry.py126Register a component. Args: name: The name to register under value: The component to reSTRING
HIGHpython/ray/llm/_internal/serve/utils/registry.py176Get a registered component. Args: name: The name of the component Returns: TheSTRING
HIGH…lm/_internal/serve/engines/vllm/kv_transfer/factory.py57Get the connector backend class by name. For registered connectors, returns the registered backend class. STRING
HIGH…_internal/serve/routing_policies/kv_aware/tokenizer.py121Tokenize a request ``payload`` into prompt token IDs. Args: payload: The request body, already parsSTRING
HIGH…rnal/serve/routing_policies/kv_aware/vllm/tokenizer.py121Tokenize a request ``payload`` into prompt token IDs. Args: payload: The request body, already parsSTRING
HIGH…e/routing_policies/prefix_aware/prefix_aware_router.py135Extracts the text content from a pending request for prefix matching. Searches through request arguments for eiSTRING
HIGHpython/ray/util/queue.py156Gets an item from the queue. If block is True and the queue is empty, blocks until the queue is no longSTRING
HIGHpython/ray/util/queue.py193Gets an item from the queue. There is no guarantee of order if multiple consumers get from the same empSTRING
HIGHpython/ray/util/queue.py261Gets items from the queue and returns them in a list in order. Args: num_items: Number of iSTRING
HIGHpython/ray/util/iter.py86Create a parallel iterator from a list of iterables. An iterable can be a conatiner (list, str, tuple, set, etc.), STRING
HIGHpython/ray/util/iter.py233Remotely transform the iterator. This is advanced version of for_each that allows you to apply arbitrary STRING
HIGHpython/ray/util/iter.py266Remotely apply fn to each item in this iterator. If `max_concurrency` == 1 then `fn` will be executed serially STRING
HIGHpython/ray/util/iter.py310Remotely filter items from this iterator. Args: fn: returns False for items to drop from the iteratSTRING
HIGHpython/ray/util/iter.py327Remotely batch together items in this iterator. Args: n: Number of items to batch together. STRING
HIGHpython/ray/util/iter.py367Remotely shuffle items of each shard independently Args: shuffle_buffer_size: The algorithm fills aSTRING
HIGHpython/ray/util/iter.py404Returns a new ParallelIterator instance with num_partitions shards. The new iterator contains the same data in STRING
HIGHpython/ray/util/iter.py558Returns a local iterable for asynchronous iteration. New items will be fetched from the shards asynchronously aSTRING
HIGHpython/ray/util/placement_group.py142Asynchronously creates a PlacementGroup. Args: bundles: A list of bundles which represent the rSTRING
HIGHpython/ray/util/tpu.py42Extracts the version from the accelerator type. Args: accelerator_type: The full accelerator type string (eSTRING
HIGHpython/ray/util/tpu.py997Run a remote function on every host in a TPU slice. Dispatches one task per host in the slice, pinning each task toSTRING
HIGHpython/ray/util/tpu.py2166Asynchronously creates a PlacementGroup for a TPU subslice. A subslice placement group reserves a contiguous subsetSTRING
HIGHpython/ray/util/actor_pool.py255Returns the next pending result in order. This returns the next result produced by submit(), blocking for up toSTRING
HIGHpython/ray/util/actor_pool.py330Returns any of the next pending results. This returns some result produced by submit(), blocking for up to STRING
HIGHpython/ray/util/annotations.py34Annotation for documenting public APIs. Public APIs are classes and methods exposed to end users of Ray. If ``STRING
HIGHpython/ray/util/annotations.py108Annotation for documenting developer APIs. Developer APIs are lower-level methods explicitly exposed to advanced RaSTRING
HIGHpython/ray/util/annotations.py168Annotation for documenting a deprecated API. Deprecated APIs may be removed in future releases of Ray. Args: STRING
HIGHpython/ray/util/dask/scheduler_utils.py48Start state from a dask. Args: dsk: A dask dictionary specifying a workflow. cache: Temporary storaSTRING
HIGHpython/ray/util/dask/scheduler_utils.py196Get nested index from collection. Args: ind: Index or nested list of indices. coll: Collection to iSTRING
HIGHpython/ray/util/state/state_manager.py79Apply the network error handling logic to each APIs, such as retry or exception policies. Args: STRING
HIGHpython/ray/util/state/api.py263Get resources states by id Args: resource: Resource names, i.e. 'workers', 'actors', 'nodes', STRING
HIGHpython/ray/util/state/api.py476List resources states Args: resource: Resource names, i.e. 'jobs', 'actors', 'nodes', STRING
HIGHpython/ray/util/state/api.py525Summarize resources states Args: resource: Resource names, see `SummaryResource` foSTRING
366 more matches not shown…
Excessive Try-Catch Wrapping1485 hits · 1594 pts
SeverityFileLineSnippetContext
LOWpython/ray/client_builder.py367 except Exception as e:CODE
MEDIUMpython/ray/setup-dev.py146 print("Error: --skip and --allow cannot be used together.")CODE
LOWpython/ray/exceptions.py51 except Exception:CODE
LOWpython/ray/exceptions.py314 except Exception as e:CODE
LOWpython/ray/exceptions.py834 except Exception:CODE
LOWpython/ray/actor.py1646 except Exception as e:CODE
MEDIUMpython/ray/actor.py1643def __init__(self, *args, **kwargs):CODE
LOWpython/ray/experimental/shuffle.py319 except Exception:CODE
LOWpython/ray/experimental/compiled_dag_ref.py139 except Exception as execution_error:CODE
LOWpython/ray/experimental/compiled_dag_ref.py145 except Exception:CODE
LOWpython/ray/experimental/rdt/cuda_ipc_transport.py181 except Exception as e:CODE
LOWpython/ray/experimental/rdt/rdt_manager.py330 except Exception as e:CODE
LOWpython/ray/experimental/rdt/nixl_tensor_transport.py69 except Exception:CODE
LOWpython/ray/experimental/rdt/nixl_tensor_transport.py462 except Exception:CODE
LOWpython/ray/experimental/rdt/nixl_tensor_transport.py525 except Exception:CODE
LOWpython/ray/experimental/rdt/nixl_tensor_transport.py682 except Exception as e:CODE
LOWpython/ray/experimental/rdt/nixl_tensor_transport.py756 except Exception:CODE
LOWpython/ray/experimental/rdt/rdt_store.py88 except Exception as e:CODE
LOWpython/ray/experimental/rdt/nixl_memory_pool.py196 except Exception:CODE
LOWpython/ray/experimental/rdt/nixl_memory_pool.py203 except Exception as cleanup_err:CODE
LOWpython/ray/llm/_internal/common/callbacks/base.py109 except Exception as e:CODE
LOWpython/ray/llm/_internal/common/callbacks/base.py131 except Exception as e:CODE
LOW…ray/llm/_internal/common/patches/vllm/tokenize_once.py87 except Exception as e: # pragma: no cover - defensiveCODE
LOWpython/ray/llm/_internal/common/utils/cloud_utils.py286 except Exception as e:CODE
LOWpython/ray/llm/_internal/common/utils/cloud_utils.py336 except Exception as e:CODE
LOWpython/ray/llm/_internal/common/utils/lora_utils.py127 except Exception as e:CODE
LOW…nternal/common/utils/cloud_filesystem/s3_filesystem.py126 except Exception as e:CODE
LOW…nternal/common/utils/cloud_filesystem/s3_filesystem.py165 except Exception as e:CODE
LOW…nternal/common/utils/cloud_filesystem/s3_filesystem.py225 except Exception as e:CODE
LOW…nternal/common/utils/cloud_filesystem/s3_filesystem.py346 except Exception as e:CODE
LOW…nternal/common/utils/cloud_filesystem/s3_filesystem.py395 except Exception as e:CODE
LOW…al/common/utils/cloud_filesystem/pyarrow_filesystem.py248 except Exception as e:CODE
LOW…al/common/utils/cloud_filesystem/pyarrow_filesystem.py280 except Exception as e:CODE
LOW…al/common/utils/cloud_filesystem/pyarrow_filesystem.py358 except Exception as e:CODE
LOW…al/common/utils/cloud_filesystem/pyarrow_filesystem.py362 except Exception as e:CODE
LOW…al/common/utils/cloud_filesystem/pyarrow_filesystem.py387 except Exception as e:CODE
LOWpython/ray/llm/_internal/batch/benchmark/dataset.py138 except Exception as e:CODE
LOW…y/llm/_internal/batch/benchmark/benchmark_processor.py322 except Exception as e:CODE
MEDIUM…y/llm/_internal/batch/benchmark/benchmark_processor.py323 print(f"Error checking app status: {e}")CODE
LOW…on/ray/llm/_internal/batch/stages/vllm_engine_stage.py784 except Exception as e:CODE
LOW…y/llm/_internal/batch/stages/serve_deployment_stage.py183 except Exception as e:CODE
LOW…ay/llm/_internal/batch/processor/sglang_engine_proc.py236 except Exception as e:CODE
LOW…/ray/llm/_internal/batch/processor/vllm_engine_proc.py315 except Exception:CODE
LOW…_internal/batch/observability/usage_telemetry/usage.py142 except Exception:CODE
LOW…_internal/batch/observability/usage_telemetry/usage.py156 except Exception:CODE
LOWpython/ray/llm/_internal/serve/benchmark/interactive.py809 except Exception as e:CODE
LOWpython/ray/llm/_internal/serve/benchmark/interactive.py378 except Exception as e:CODE
LOWpython/ray/llm/_internal/serve/benchmark/interactive.py517 except Exception as e:CODE
LOWpython/ray/llm/_internal/serve/benchmark/interactive.py578 except Exception as e:CODE
LOWpython/ray/llm/_internal/serve/benchmark/interactive.py822 except Exception as e:CODE
MEDIUMpython/ray/llm/_internal/serve/benchmark/runners.py45def emit(self, record):CODE
LOWpython/ray/llm/_internal/serve/benchmark/runners.py50 except Exception:CODE
LOWpython/ray/llm/_internal/serve/benchmark/runners.py357 except Exception as e:CODE
LOWpython/ray/llm/_internal/serve/benchmark/runners.py645 except Exception as e:CODE
LOWpython/ray/llm/_internal/serve/benchmark/runners.py913 except Exception as e:CODE
LOWpython/ray/llm/_internal/serve/benchmark/runners.py929 except Exception as e:CODE
LOW…rnal/serve/serving_patterns/data_parallel/dp_server.py59 except Exception:CODE
LOW…nal/serve/serving_patterns/prefill_decode/pd_server.py425 except Exception as exc: # pragma: no cover - defensiveCODE
LOW…nal/serve/serving_patterns/prefill_decode/pd_server.py526 except Exception as exc:CODE
LOW…hon/ray/llm/_internal/serve/core/ingress/middleware.py115 except Exception as e:CODE
1425 more matches not shown…
Cross-File Repetition306 hits · 1530 pts
SeverityFileLineSnippetContext
HIGHpython/ray/experimental/channel/cpu_communicator.py0return the given actor's rank in the group. args: actor: the actor handle to look up. returns: the rank of ``actor`` witSTRING
HIGHpython/ray/experimental/channel/nccl_group.py0return the given actor's rank in the group. args: actor: the actor handle to look up. returns: the rank of ``actor`` witSTRING
HIGHpython/ray/experimental/channel/communicator.py0return the given actor's rank in the group. args: actor: the actor handle to look up. returns: the rank of ``actor`` witSTRING
HIGHpython/ray/llm/_internal/common/models.py0take a blocking function, and run it on in an executor thread. this function prevents the blocking function from blockinSTRING
HIGHpython/ray/llm/_internal/serve/utils/server_utils.py0take a blocking function, and run it on in an executor thread. this function prevents the blocking function from blockinSTRING
HIGHrelease/llm_tests/serve/probes/util.py0take a blocking function, and run it on in an executor thread. this function prevents the blocking function from blockinSTRING
HIGHpython/ray/llm/_internal/common/utils/cloud_utils.py0download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8STRING
HIGH…al/common/utils/cloud_filesystem/pyarrow_filesystem.py0download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8STRING
HIGH…ay/llm/_internal/common/utils/cloud_filesystem/base.py0download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8STRING
HIGH…ternal/common/utils/cloud_filesystem/gcs_filesystem.py0download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8STRING
HIGH…nternal/common/utils/cloud_filesystem/s3_filesystem.py0download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8STRING
HIGH…rnal/common/utils/cloud_filesystem/azure_filesystem.py0download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8STRING
HIGHpython/ray/llm/_internal/common/utils/cloud_utils.py0list the immediate subfolders in a cloud directory. args: folder_uri: uri of the directory (s3://, gs://, abfss://, or aSTRING
HIGH…al/common/utils/cloud_filesystem/pyarrow_filesystem.py0list the immediate subfolders in a cloud directory. args: folder_uri: uri of the directory (s3://, gs://, abfss://, or aSTRING
HIGH…ay/llm/_internal/common/utils/cloud_filesystem/base.py0list the immediate subfolders in a cloud directory. args: folder_uri: uri of the directory (s3://, gs://, abfss://, or aSTRING
HIGHpython/ray/llm/_internal/common/utils/cloud_utils.py0download files from cloud storage to a local directory. args: path: local directory where files will be downloaded buckeSTRING
HIGH…ternal/common/utils/cloud_filesystem/gcs_filesystem.py0download files from cloud storage to a local directory. args: path: local directory where files will be downloaded buckeSTRING
HIGH…rnal/common/utils/cloud_filesystem/azure_filesystem.py0download files from cloud storage to a local directory. args: path: local directory where files will be downloaded buckeSTRING
HIGH…ay/llm/_internal/common/utils/cloud_filesystem/base.py0download files from cloud storage to a local directory. args: path: local directory where files will be downloaded buckeSTRING
HIGHpython/ray/llm/_internal/common/utils/cloud_utils.py0upload files to cloud storage. args: local_path: the local path of the files to upload. bucket_uri: the bucket uri to upSTRING
HIGH…al/common/utils/cloud_filesystem/pyarrow_filesystem.py0upload files to cloud storage. args: local_path: the local path of the files to upload. bucket_uri: the bucket uri to upSTRING
HIGH…ay/llm/_internal/common/utils/cloud_filesystem/base.py0upload files to cloud storage. args: local_path: the local path of the files to upload. bucket_uri: the bucket uri to upSTRING
HIGH…llm/_internal/common/observability/logging/__init__.py0get 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__.py0get 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__.py0get 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.py0configures stdlib root logger to make sure stdlib loggers (created as `logging.getlogger(...)`) are using ray's `jsonforSTRING
HIGH…ray/llm/_internal/batch/observability/logging/setup.py0configures stdlib root logger to make sure stdlib loggers (created as `logging.getlogger(...)`) are using ray's `jsonforSTRING
HIGH…ray/llm/_internal/serve/observability/logging/setup.py0configures stdlib root logger to make sure stdlib loggers (created as `logging.getlogger(...)`) are using ray's `jsonforSTRING
HIGH…/ray/llm/_internal/batch/stages/sglang_engine_stage.py0the required input keys of the stage and their descriptions.STRING
HIGH…/ray/llm/_internal/batch/stages/chat_template_stage.py0the required input keys of the stage and their descriptions.STRING
HIGH…llm/_internal/batch/stages/prepare_multimodal_stage.py0the required input keys of the stage and their descriptions.STRING
HIGH…n/ray/llm/_internal/batch/stages/http_request_stage.py0the required input keys of the stage and their descriptions.STRING
HIGH…on/ray/llm/_internal/batch/stages/vllm_engine_stage.py0the required input keys of the stage and their descriptions.STRING
HIGHpython/ray/llm/_internal/batch/stages/tokenize_stage.py0the required input keys of the stage and their descriptions.STRING
HIGHpython/ray/llm/_internal/batch/stages/base.py0the required input keys of the stage and their descriptions.STRING
HIGH…/ray/llm/_internal/batch/stages/sglang_engine_stage.py0the optional input keys of the stage and their descriptions.STRING
HIGH…on/ray/llm/_internal/batch/stages/vllm_engine_stage.py0the optional input keys of the stage and their descriptions.STRING
HIGHpython/ray/llm/_internal/batch/stages/base.py0the optional input keys of the stage and their descriptions.STRING
HIGH…ay/llm/_internal/batch/processor/sglang_engine_proc.py0construct a processor that runs a serve deployment. args: config: the configuration for the processor. preprocess: an opSTRING
HIGH…/ray/llm/_internal/batch/processor/vllm_engine_proc.py0construct a processor that runs a serve deployment. args: config: the configuration for the processor. preprocess: an opSTRING
HIGH…ray/llm/_internal/batch/processor/http_request_proc.py0construct a processor that runs a serve deployment. args: config: the configuration for the processor. preprocess: an opSTRING
HIGH…llm/_internal/batch/processor/serve_deployment_proc.py0construct a processor that runs a serve deployment. args: config: the configuration for the processor. preprocess: an opSTRING
HIGHpython/ray/llm/_internal/serve/core/protocol.py0check 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.py0check the health of the engine. does not return anything. raise error when the engine is dead and needs to be restarted.STRING
HIGHpython/ray/llm/_internal/serve/core/engine/protocol.py0check the health of the engine. does not return anything. raise error when the engine is dead and needs to be restarted.STRING
HIGHpython/ray/llm/_internal/serve/core/protocol.py0check 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.py0check whether the vllm engine is currently sleeping. returns: true if the engine is sleeping, false otherwise.STRING
HIGHpython/ray/llm/_internal/serve/core/engine/protocol.py0check 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.py0check whether the vllm engine is currently sleeping. returns: true if the engine is sleeping, false otherwise.STRING
HIGHpython/ray/llm/_internal/serve/core/protocol.py0check 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.py0check whether the vllm engine is currently paused. returns: true if the engine is paused, false otherwise.STRING
HIGHpython/ray/llm/_internal/serve/core/engine/protocol.py0check 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.py0check 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.py0execute a collective rpc call on all vllm workers. this is used for rlhf workflows where a trainer needs to execute methSTRING
HIGHpython/ray/llm/_internal/serve/core/engine/protocol.py0execute a collective rpc call on all vllm workers. this is used for rlhf workflows where a trainer needs to execute methSTRING
HIGH…on/ray/llm/_internal/serve/engines/vllm/vllm_engine.py0execute a collective rpc call on all vllm workers. this is used for rlhf workflows where a trainer needs to execute methSTRING
HIGHpython/ray/llm/tests/conftest.py0{% 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.py0{% if messages[0]['role'] == 'system' %} {% set offset = 1 %} {% else %} {% set offset = 0 %} {% endif %} {{ bos_token }STRING
HIGHrelease/llm_tests/batch/test_batch_sglang.py0{% if messages[0]['role'] == 'system' %} {% set offset = 1 %} {% else %} {% set offset = 0 %} {% endif %} {{ bos_token }STRING
HIGHpython/ray/util/collective/collective.py0returns the ip address and a free port on this node.STRING
246 more matches not shown…
Cross-Language Confusion236 hits · 1236 pts
SeverityFileLineSnippetContext
HIGHpython/ray/util/timer.py37 self.push(time_delta)CODE
HIGHpython/ray/util/actor_pool.py500 pool.push(a2)STRING
HIGHpython/ray/util/dask/tests/test_dask_scheduler.py94 assert sorted_with_pb.equals(sorted_without_pb)CODE
HIGHpython/ray/tests/test_actor_pool.py263 pool.push(a1)CODE
HIGHpython/ray/tests/test_actor_pool.py264 pool.push(a2)CODE
HIGHpython/ray/tests/test_actor_pool.py271 pool.push(a3)CODE
HIGHpython/ray/tests/accelerators/test_neuron.py50 b'"connected_to":null,"nc_count":2,'CODE
HIGHpython/ray/tests/accelerators/test_neuron.py68 b'"connected_to":null,"nc_count":2,'CODE
HIGHpython/ray/tests/accelerators/test_neuron.py70 b'{"neuron_device":1,"bdf":"00:1f.0","connected_to":null,'CODE
HIGHpython/ray/tests/modin/modin_test_utils.py90 and df1.columns.equals(df2.columns)CODE
HIGHpython/ray/_private/thirdparty/tabulate/tabulate.py1941 | spam || align="right"| 41.9999STRING
HIGHpython/ray/_private/thirdparty/tabulate/tabulate.py1943 | eggs || align="right"| 451STRING
HIGHpython/ray/dashboard/modules/job/sdk.py485 ... entrypoint="echo hi && sleep 5 && echo hi2")STRING
HIGH…on/ray/dashboard/modules/job/tests/test_job_manager.py1480 entrypoint=f"{cmd} & {cmd} && wait && echo 'done'"CODE
HIGH…ay/dashboard/modules/job/tests/test_cli_integration.py187 cmd = "sleep 1 && echo hello && sleep 1 && echo hello"CODE
HIGH…ay/dashboard/modules/job/tests/test_cli_integration.py197 cmd = "echo hello && sleep 1000"CODE
HIGH…ay/dashboard/modules/job/tests/test_cli_integration.py258 cmd = "echo hello && sleep 1000"CODE
HIGH…thon/ray/dashboard/modules/job/tests/test_job_agent.py189 "python script.py && python -c 'import pip_install_test'"STRING
HIGH…ay/dashboard/modules/job/tests/test_http_job_server.py285 "python script.py && python -c 'import pip_install_test'"STRING
HIGH…ay/dashboard/modules/job/tests/test_http_job_server.py507 job_id = client.submit_job(entrypoint="sleep 300 && echo hello")STRING
HIGHpython/ray/train/_internal/state/schema.py144 "If null, the Train run has not ended yet.",CODE
HIGHpython/ray/train/tests/test_state.py53 "end_time_ms": null,CODE
HIGHpython/ray/train/v2/_internal/state/schema.py257 "If null, the attempt is still ongoing.",CODE
HIGHpython/ray/train/v2/_internal/state/schema.py498 "If null, the run is still in progress.",CODE
HIGHpython/ray/autoscaler/launch_and_verify_cluster.py133 f'pip3 uninstall -y ray && pip3 install -U "ray[default] @ {wheel_url}"'CODE
HIGHpython/ray/autoscaler/_private/command_runner.py940 "cat /proc/meminfo || true", with_output=TrueCODE
HIGHpython/ray/autoscaler/_private/commands.py1149 cmd = "tmux attach || tmux new"CODE
HIGH…thon/ray/autoscaler/_private/subprocess_output_util.py165 # (-o UserKnownHostsFile=/dev/null),COMMENT
HIGH…thon/ray/autoscaler/_private/subprocess_output_util.py341 (redirected to /dev/null), unless verbose loggingSTRING
HIGH…y/autoscaler/_private/fake_multi_node/node_provider.py150 "((sudo apt update && sudo apt install -y openssh-server && "CODE
HIGHpython/ray/serve/deployment.py271 raise ValueError("`max_ongoing_requests` must be non-null, got None.")CODE
HIGHpython/ray/serve/api.py634 raise ValueError("`max_ongoing_requests` must be non-null, got None.")CODE
HIGHpython/ray/serve/schema.py361 "If null, the deployment won't autoscale its number of "CODE
HIGHpython/ray/serve/schema.py778 "If null, serve fallbacks to autoscaling policy in each deployment. "CODE
HIGHpython/ray/serve/tests/test_task_processor.py847 # Send an integer, for which len() is undefined, causing a TypeErrorCOMMENT
HIGHpython/ray/serve/tests/unit/test_controller.py201 """When target capacity becomes null, scale up/down behavior must stop."""STRING
HIGHpython/ray/serve/tests/unit/test_controller.py230 """When target capacity goes null -> non-null, scale down must start."""STRING
HIGHpython/ray/data/aggregate.py1390 - If ignore_nulls=True, zero-factory returns null, therefore encoding emptySTRING
HIGHpython/ray/data/aggregate.py1430 # If accumulator container is not null, finalize.COMMENT
HIGHpython/ray/data/expressions.py71 IS_NULL: Check if value is nullSTRING
HIGHpython/ray/data/dataset.py3423 ``False`` and any value is null, then the output is ``None``.STRING
HIGHpython/ray/data/dataset.py3467 ``False`` and any value is null, then the output is ``None``.STRING
HIGHpython/ray/data/dataset.py3511 ``False`` and any value is null, then the output is ``None``.STRING
HIGHpython/ray/data/dataset.py3555 ``False`` and any value is null, then the output is ``None``.STRING
HIGHpython/ray/data/dataset.py3614 ``False`` and any value is null, then the output is ``None``.STRING
HIGHpython/ray/data/_internal/util.py1437 return self._fs.equals(other)CODE
HIGH…thon/ray/data/_internal/datasource/parquet_datasink.py347 if output_schema and not table.schema.equals(output_schema):CODE
HIGH…thon/ray/data/_internal/datasource/iceberg_datasink.py932 if not final_reconciled_schema.equals(table_schema):CODE
HIGHpython/ray/data/_internal/tensor_extensions/pandas.py290 >>> read_df.equals(df) # doctest: +SKIPSTRING
HIGHpython/ray/data/_internal/tensor_extensions/pandas.py712 >>> read_df.equals(df) # doctest: +SKIPSTRING
HIGH…thon/ray/data/_internal/arrow_ops/transform_pyarrow.py462 # All arrays are null, so the inferred type is null.COMMENT
HIGH…thon/ray/data/_internal/arrow_ops/transform_pyarrow.py469 # 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.py649 if block.schema.equals(schema):CODE
HIGH…thon/ray/data/_internal/arrow_ops/transform_pyarrow.py761 [pa.nulls(c.length(), type=value_type)]CODE
HIGH…thon/ray/data/_internal/arrow_ops/transform_pyarrow.py1163 return np.full(array.length(), np.nan, dtype=np.float32)CODE
HIGHpython/ray/data/_internal/gpu_shuffle/hash_aggregate.py1264 elif not current_dtype.equals(observed_arrow_dtype):CODE
HIGH…y/data/_internal/execution/streaming_executor_state.py294 # If output split idx is null, fallback to the first queueCOMMENT
HIGH…nal/logical/operators/tests/test_read_files_logical.py149 assert actual.equals(expected.to_pyarrow())CODE
HIGHpython/ray/data/datasource/partitioning.py206 with partition `"bar"`. If the base directory is undefined, then `"foo.csv"` wouldSTRING
HIGHpython/ray/data/datasource/partitioning.py337 # checks validity/not-null, not the boolean value).COMMENT
176 more matches not shown…
Deep Nesting1208 hits · 1073 pts
SeverityFileLineSnippetContext
LOWpython/setup.py484CODE
LOWpython/setup.py729CODE
LOWpython/setup.py83CODE
LOWpython/ray/exceptions.py324CODE
LOWpython/ray/runtime_env/runtime_env.py97CODE
LOWpython/ray/experimental/channel/cpu_communicator.py69CODE
LOWpython/ray/experimental/channel/common.py357CODE
LOWpython/ray/experimental/channel/common.py456CODE
LOWpython/ray/experimental/rdt/rdt_manager.py308CODE
LOWpython/ray/experimental/rdt/rdt_manager.py548CODE
LOWpython/ray/experimental/rdt/rdt_manager.py687CODE
LOWpython/ray/experimental/rdt/nixl_tensor_transport.py269CODE
LOWpython/ray/experimental/rdt/nixl_tensor_transport.py363CODE
LOWpython/ray/experimental/rdt/nixl_tensor_transport.py475CODE
LOWpython/ray/experimental/rdt/nixl_tensor_transport.py622CODE
LOWpython/ray/experimental/rdt/nixl_tensor_transport.py648CODE
LOWpython/ray/experimental/rdt/nixl_memory_pool.py207CODE
LOWpython/ray/llm/_internal/common/utils/cloud_utils.py82CODE
LOWpython/ray/llm/_internal/common/utils/cloud_utils.py147CODE
LOWpython/ray/llm/_internal/common/utils/download_utils.py226CODE
LOWpython/ray/llm/_internal/common/utils/download_utils.py122CODE
LOW…nternal/common/utils/cloud_filesystem/s3_filesystem.py230CODE
LOW…nternal/common/utils/cloud_filesystem/s3_filesystem.py351CODE
LOW…al/common/utils/cloud_filesystem/pyarrow_filesystem.py29CODE
LOW…al/common/utils/cloud_filesystem/pyarrow_filesystem.py285CODE
LOW…llm/_internal/batch/stages/prepare_multimodal_stage.py42CODE
LOW…n/ray/llm/_internal/batch/stages/http_request_stage.py64CODE
LOW…on/ray/llm/_internal/batch/stages/vllm_engine_stage.py119CODE
LOW…on/ray/llm/_internal/batch/stages/vllm_engine_stage.py252CODE
LOW…on/ray/llm/_internal/batch/stages/vllm_engine_stage.py407CODE
LOWpython/ray/llm/_internal/serve/benchmark/models.py134CODE
LOWpython/ray/llm/_internal/serve/benchmark/interactive.py405CODE
LOWpython/ray/llm/_internal/serve/benchmark/interactive.py475CODE
LOWpython/ray/llm/_internal/serve/benchmark/interactive.py521CODE
LOWpython/ray/llm/_internal/serve/benchmark/runners.py471CODE
LOWpython/ray/llm/_internal/serve/benchmark/runners.py689CODE
LOW…rnal/serve/serving_patterns/data_parallel/dp_server.py244CODE
LOW…nal/serve/serving_patterns/prefill_decode/pd_server.py342CODE
LOWpython/ray/llm/_internal/serve/core/ingress/ingress.py432CODE
LOWpython/ray/llm/_internal/serve/core/ingress/builder.py172CODE
LOWpython/ray/llm/_internal/serve/core/ingress/utils.py30CODE
LOWpython/ray/llm/_internal/serve/utils/server_utils.py160CODE
LOWpython/ray/llm/_internal/serve/utils/batcher.py50CODE
LOW…on/ray/llm/_internal/serve/engines/vllm/vllm_models.py267CODE
LOW…e/routing_policies/prefix_aware/prefix_aware_router.py208CODE
LOW…nal/serve/routing_policies/prefix_aware/prefix_tree.py253CODE
LOW…nal/serve/routing_policies/prefix_aware/prefix_tree.py376CODE
LOW…nal/serve/routing_policies/prefix_aware/prefix_tree.py591CODE
LOW…loyments/routers/kv/test_request_lifecycle_tracking.py742CODE
LOWpython/ray/util/rpdb.py355CODE
LOWpython/ray/util/iter.py401CODE
LOWpython/ray/util/iter.py514CODE
LOWpython/ray/util/iter.py557CODE
LOWpython/ray/util/iter.py853CODE
LOWpython/ray/util/iter.py1043CODE
LOWpython/ray/util/iter.py1103CODE
LOWpython/ray/util/iter.py439CODE
LOWpython/ray/util/iter.py527CODE
LOWpython/ray/util/iter.py594CODE
LOWpython/ray/util/iter.py1071CODE
1148 more matches not shown…
Hallucination Indicators103 hits · 1065 pts
SeverityFileLineSnippetContext
CRITICALpython/ray/client_builder.py78 elif ray._private.worker.global_worker.node.is_head():CODE
CRITICALpython/ray/experimental/locations.py40 return ray._private.worker.global_worker.core_worker.get_object_locations(CODE
CRITICALpython/ray/_common/tests/test_usage_stats.py1090 ray.worker.global_worker.gcs_client.cluster_id.hex(),CODE
CRITICALpython/ray/tests/test_job.py215 from_worker = ray._private.worker.global_worker.core_worker.get_job_config()STRING
CRITICALpython/ray/tests/test_client_proxy.py173assert ray.util.client.ray.worker.log_client.log_thread.is_alive()CODE
CRITICALpython/ray/tests/test_advanced_7.py176 assert not ray._private.worker.global_worker.core_worker.object_exists(x_id)CODE
CRITICALpython/ray/tests/test_advanced_7.py178 assert ray._private.worker.global_worker.core_worker.object_exists(x_id)CODE
CRITICALpython/ray/tests/test_advanced_7.py182 assert not ray._private.worker.global_worker.core_worker.object_exists(x_id)CODE
CRITICALpython/ray/tests/test_advanced_7.py185 assert ray._private.worker.global_worker.core_worker.object_exists(x_id)CODE
CRITICALpython/ray/tests/test_advanced_7.py215 assert ray._private.worker.global_worker.core_worker.object_exists(CODE
CRITICALpython/ray/tests/test_advanced_7.py253 inlined = ray._private.worker.global_worker.core_worker.object_exists(CODE
CRITICALpython/ray/tests/test_reference_counting_standalone.py37 lambda: ray._private.worker.global_worker.core_worker.object_exists(obj)CODE
CRITICALpython/ray/tests/test_reference_counting_standalone.py41 lambda: not ray._private.worker.global_worker.core_worker.object_exists(obj)CODE
CRITICALpython/ray/tests/test_reference_counting_standalone.py325 actual = ray._private.worker.global_worker.core_worker.get_all_reference_counts()CODE
CRITICALpython/ray/tests/test_reference_counting_standalone.py336 len(ray._private.worker.global_worker.core_worker.get_all_reference_counts())CODE
CRITICALpython/ray/tests/test_reference_counting_standalone.py345 len(ray._private.worker.global_worker.core_worker.get_all_reference_counts())CODE
CRITICALpython/ray/tests/test_runtime_env_working_dir.py683 ray._private.worker.global_worker.core_worker.get_job_config().py_driver_sys_pathCODE
CRITICALpython/ray/tests/test_state_api_log.py1078 # log_dir = ray._private.worker.global_worker.node.get_logs_dir_path()COMMENT
CRITICALpython/ray/tests/test_state_api_log.py1113 log_dir = ray._private.worker.global_worker.node.get_logs_dir_path()CODE
CRITICALpython/ray/tests/test_state_api_log.py1337 log_dir = ray._private.worker.global_worker.node.get_logs_dir_path()CODE
CRITICALpython/ray/tests/test_state_api_log.py1612 log_dir = ray._private.worker.global_worker.node.get_logs_dir_path()CODE
CRITICALpython/ray/tests/test_advanced_3.py173 assert not ray._private.worker.global_worker.core_worker.object_exists(x_id)CODE
CRITICALpython/ray/tests/test_advanced_3.py418 assert not ray._private.worker.global_worker.core_worker.object_exists(STRING
CRITICALpython/ray/tests/test_advanced.py306 worker_id = ray._private.worker.global_worker.core_worker.get_worker_id().hex()CODE
CRITICALpython/ray/tests/test_advanced_8.py585 job_config = ray._private.worker.global_worker.core_worker.get_job_config()STRING
CRITICALpython/ray/tests/test_advanced_8.py593 job_config = ray._private.worker.global_worker.core_worker.get_job_config()STRING
CRITICALpython/ray/tests/test_memory_pressure.py91 return ray._private.worker.global_worker.core_worker.get_worker_id().hex()CODE
CRITICALpython/ray/tests/test_memory_pressure.py94 return ray._private.worker.global_worker.core_worker.get_actor_id().hex()CODE
CRITICALpython/ray/tests/test_generators.py354 ray._private.worker.global_worker.core_worker.get_all_reference_counts()CODE
CRITICALpython/ray/tests/test_basic_2.py461 assert not ray._private.worker.global_worker.core_worker.object_exists(obj_ref)CODE
CRITICALpython/ray/tests/test_basic_2.py478 assert not ray._private.worker.global_worker.core_worker.object_exists(obj_ref)CODE
CRITICALpython/ray/tests/test_basic_2.py481 assert ray._private.worker.global_worker.core_worker.object_exists(obj_ref)CODE
CRITICALpython/ray/tests/test_basic_2.py759 + ray._private.worker.global_worker.current_job_id.hex().encode()STRING
CRITICALpython/ray/tests/test_basic_2.py763 assert ray._private.worker.global_worker.gcs_client.internal_kv_exists(STRING
CRITICALpython/ray/tests/test_basic_2.py774 + ray._private.worker.global_worker.current_job_id.hex().encode()STRING
CRITICALpython/ray/tests/test_basic_2.py778 assert ray._private.worker.global_worker.gcs_client.internal_kv_exists(STRING
CRITICALpython/ray/tests/test_output.py228log_dir = ray._private.worker.global_worker.node.get_logs_dir_path()CODE
CRITICALpython/ray/tests/test_advanced_9.py121 job_id = ray._private.worker.global_worker.current_job_id.hex().encode()CODE
CRITICALpython/ray/tests/test_advanced_9.py145 job_id = ray._private.worker.global_worker.current_job_id.hex().encode()CODE
CRITICALpython/ray/tests/test_advanced_9.py158 job_id = ray._private.worker.global_worker.current_job_id.hex().encode()CODE
CRITICALpython/ray/tests/test_streaming_generator_regression.py48 ray._private.worker.global_worker.core_worker.reset_event_loop_executor(CODE
CRITICALpython/ray/tests/test_advanced_4.py214 job_id = ray._private.worker.global_worker.current_job_id.hex().encode()CODE
CRITICALpython/ray/tests/test_advanced_4.py238 job_id = ray._private.worker.global_worker.current_job_id.hex().encode()CODE
CRITICALpython/ray/tests/test_advanced_4.py251 job_id = ray._private.worker.global_worker.current_job_id.hex().encode()CODE
CRITICALpython/ray/tests/test_reference_counting_2.py62 lambda: ray._private.worker.global_worker.core_worker.object_exists(obj),CODE
CRITICALpython/ray/tests/test_reference_counting_2.py67 lambda: not ray._private.worker.global_worker.core_worker.object_exists(CODE
CRITICALpython/ray/tests/test_serialization.py654 assert ray._private.worker.global_worker.current_job_id.is_nil()CODE
CRITICALpython/ray/tests/test_reference_counting.py57 lambda: ray._private.worker.global_worker.core_worker.object_exists(obj)CODE
CRITICALpython/ray/tests/test_reference_counting.py61 lambda: not ray._private.worker.global_worker.core_worker.object_exists(CODE
CRITICALpython/ray/tests/test_reference_counting.py69 actual = ray._private.worker.global_worker.core_worker.get_all_reference_counts()CODE
CRITICALpython/ray/tests/test_reference_counting.py315 return not ray._private.worker.global_worker.core_worker.object_exists(CODE
CRITICALpython/ray/tests/aws/utils/helpers.py48 return ray.autoscaler._private.aws.config.bootstrap_aws(config)CODE
CRITICALpython/ray/tests/rdt/test_rdt_nixl.py304 lambda: ray._private.worker.global_worker.rdt_manager.get_rdt_metadata(obj_id)CODE
CRITICALpython/ray/tests/rdt/test_rdt_gloo.py849 return ray._private.worker.global_worker.rdt_manager.rdt_store.get_num_objects()CODE
CRITICALpython/ray/tests/spark/test_basic.py192 ray.util.spark.cluster_init._active_ray_cluster.shutdown()CODE
CRITICALpython/ray/tests/spark/test_basic.py400 ray.util.spark.cluster_init._global_ray_cluster_cancel_event.set()CODE
CRITICALpython/ray/tests/spark/test_databricks_hook.py83 ray.util.spark.cluster_init._active_ray_cluster.shutdown()CODE
CRITICALpython/ray/_private/serialization.py337 ray._private.worker.global_worker.core_worker.add_object_ref_reference(CODE
CRITICAL…/ray/dashboard/modules/reporter/tests/test_reporter.py1481 ray._private.worker.global_worker.node.get_session_dir_path()CODE
CRITICAL…on/ray/dashboard/modules/job/tests/test_job_manager.py897 "job_config=ray._private.worker.global_worker.core_worker.get_job_config();"CODE
43 more matches not shown…
Modern Structural Boilerplate1054 hits · 1056 pts
SeverityFileLineSnippetContext
LOWpython/setup.py23logger = logging.getLogger(__name__)CODE
LOWpython/ray/client_builder.py23logger = logging.getLogger(__name__)CODE
LOWpython/ray/runtime_context.py13logger = logging.getLogger(__name__)CODE
LOWpython/ray/__init__.py9logger = logging.getLogger(__name__)CODE
LOWpython/ray/__init__.py175__all__ = [CODE
LOWpython/ray/remote_function.py33logger = logging.getLogger(__name__)CODE
LOWpython/ray/cross_language.py9__all__ = [CODE
LOWpython/ray/cluster_utils.py20logger = logging.getLogger(__name__)CODE
LOWpython/ray/exceptions.py23logger = logging.getLogger(__name__)CODE
LOWpython/ray/actor.py66logger = logging.getLogger(__name__)CODE
LOWpython/ray/job_config.py83 def set_metadata(self, key: str, value: str) -> None:CODE
LOWpython/ray/job_config.py161 def set_ray_namespace(self, ray_namespace: str) -> None:CODE
LOWpython/ray/job_config.py172 def set_default_actor_lifetime(self, default_actor_lifetime: str) -> None:CODE
LOWpython/ray/runtime_env/__init__.py3__all__ = [CODE
LOWpython/ray/runtime_env/runtime_env.py25logger = logging.getLogger(__name__)CODE
LOWpython/ray/experimental/queue.py13__all__ = ["Empty", "Full", "Queue"]CODE
LOWpython/ray/experimental/__init__.py18__all__ = [CODE
LOWpython/ray/experimental/tqdm_ray.py23logger = logging.getLogger(__name__)CODE
LOWpython/ray/experimental/tqdm_ray.py216 def update_offset(self, pos_offset: int) -> None:CODE
LOWpython/ray/experimental/tqdm_ray.py246 def update_bar(self, state: ProgressBarState) -> None:CODE
LOWpython/ray/experimental/tqdm_ray.py267 def update_offset(self, offset: int) -> None:CODE
LOWpython/ray/experimental/collective/__init__.py13__all__ = [CODE
LOWpython/ray/experimental/collective/operations.py22logger = logging.getLogger(__name__)CODE
LOWpython/ray/experimental/multiprocessing/__init__.py5__all__ = ["Pool", "TimeoutError"]CODE
LOW…thon/ray/experimental/channel/shared_memory_channel.py19logger = logging.getLogger(__name__)CODE
LOWpython/ray/experimental/channel/torch_tensor_type.py14logger = logging.getLogger(__name__)CODE
LOWpython/ray/experimental/channel/torch_tensor_type.py173 def set_communicator_id(self, group_id: str) -> None:CODE
LOWpython/ray/experimental/channel/__init__.py26__all__ = [CODE
LOWpython/ray/experimental/channel/nccl_group.py18logger = logging.getLogger(__name__)CODE
LOW…thon/ray/experimental/channel/serialization_context.py37 def set_target_device(self, device: Device) -> None:CODE
LOW…thon/ray/experimental/channel/serialization_context.py40 def set_data(self, channel_id: str, value: Any, num_readers: int) -> None:CODE
LOW…thon/ray/experimental/channel/serialization_context.py74 def set_use_external_transport(self, use_external_transport: bool) -> None:CODE
LOWpython/ray/experimental/channel/common.py116 def set_communicator_id(self, group_id: str) -> None:CODE
LOW…perimental/channel/torch_tensor_accelerator_channel.py34logger = logging.getLogger(__name__)CODE
LOWpython/ray/experimental/rdt/util.py340def set_nixl_cuda_stream(stream: Optional["torch.cuda.Stream"]) -> None:CODE
LOWpython/ray/experimental/rdt/__init__.py20__all__ = [CODE
LOWpython/ray/experimental/rdt/rdt_manager.py53logger = logging.getLogger(__name__)CODE
LOWpython/ray/experimental/rdt/nixl_tensor_transport.py27logger = logging.getLogger(__name__)CODE
LOWpython/ray/experimental/rdt/nixl_tensor_transport.py173 def set_cuda_stream(self, stream: Optional["torch.cuda.Stream"]) -> None:CODE
LOWpython/ray/experimental/rdt/nixl_memory_pool.py9logger = logging.getLogger(__name__)CODE
LOW…ray/llm/_internal/common/callbacks/cloud_downloader.py9logger = logging.getLogger(__name__)CODE
LOWpython/ray/llm/_internal/common/callbacks/base.py11logger = logging.getLogger(__name__)CODE
LOW…ray/llm/_internal/common/patches/vllm/tokenize_once.py24logger = logging.getLogger(__name__)CODE
LOWpython/ray/llm/_internal/common/utils/cloud_utils.py443 def _update_cache(self, key: str, value: Any) -> None:CODE
LOWpython/ray/llm/_internal/common/utils/import_utils.py7logger = logging.getLogger(__name__)CODE
LOW…lm/_internal/common/utils/cloud_filesystem/__init__.py23__all__ = [CODE
LOWpython/ray/llm/_internal/batch/__init__.py8__all__ = [CODE
LOWpython/ray/llm/_internal/batch/utils.py10logger = logging.getLogger(__name__)CODE
LOW…/ray/llm/_internal/batch/stages/sglang_engine_stage.py19logger = logging.getLogger(__name__)CODE
LOWpython/ray/llm/_internal/batch/stages/__init__.py92__all__ = [CODE
LOW…on/ray/llm/_internal/batch/stages/vllm_engine_stage.py48logger = logging.getLogger(__name__)CODE
LOW…y/llm/_internal/batch/stages/serve_deployment_stage.py19logger = logging.getLogger(__name__)CODE
LOWpython/ray/llm/_internal/batch/stages/base.py10logger = logging.getLogger(__name__)CODE
LOW…ay/llm/_internal/batch/processor/sglang_engine_proc.py45logger = logging.getLogger(__name__)CODE
LOWpython/ray/llm/_internal/batch/processor/__init__.py86__all__ = [CODE
LOW…/ray/llm/_internal/batch/processor/vllm_engine_proc.py49logger = logging.getLogger(__name__)CODE
LOWpython/ray/llm/_internal/batch/processor/base.py17logger = logging.getLogger(__name__)CODE
LOW…thon/ray/llm/_internal/batch/observability/__init__.py23__all__ = ["setup_observability"]CODE
LOW…_internal/batch/observability/usage_telemetry/usage.py65 def _update_record_tag_func(self, record_tag_func: Callable) -> None:CODE
LOW…/llm/_internal/batch/observability/logging/__init__.py7def _setup_logger(logger_name: str) -> None:CODE
994 more matches not shown…
Structural Annotation Overuse445 hits · 796 pts
SeverityFileLineSnippetContext
LOWpython/ray/util/state/common.py1268 # Step 2: Create the tree structure based on ownershipSTRING
LOWpython/ray/dag/vis_utils.py94 # Step 0: check dependencies and init graphCOMMENT
LOWpython/ray/dag/vis_utils.py100 # Step 1: generate unique name for each node in dagCOMMENT
LOWpython/ray/dag/vis_utils.py107 # Step 2: create graph with all the edgesCOMMENT
LOWpython/ray/dag/compiled_dag_node.py2037 # Step 1: Build a graph of _DAGOperationGraphNodeSTRING
LOWpython/ray/dag/compiled_dag_node.py2042 # Step 2: Generate an execution schedule for each actor using topological sortSTRING
LOWpython/ray/dag/compiled_dag_node.py2045 # Step 3: Overlap GPU communication for the execution schedule if configuredSTRING
LOWpython/ray/dag/compiled_dag_node.py1798 # Step 1: populate `arg_to_consumers` and perform some validation.STRING
LOWpython/ray/dag/compiled_dag_node.py1818 # Step 2: create cached channels if neededSTRING
LOWpython/ray/dag/compiled_dag_node.py1837 # Step 3: create executable tasks for the actorSTRING
LOW…ion-tests/invalid-config-fail/ray-project/project.yaml12 # NOTE: The following is invalid because you can't have both dockerfileCOMMENT
LOWpython/ray/_private/tensor_serialization_utils.py48 # Step 1: Convert uint8 numpy array back to torch tensorCOMMENT
LOWpython/ray/_private/tensor_serialization_utils.py51 # Step 2: Restore original dtypeCOMMENT
LOWpython/ray/_private/tensor_serialization_utils.py65 # Step 3: Reshape and reinterpret bytes as target dtypeCOMMENT
LOWpython/ray/_private/tensor_serialization_utils.py68 # Step 4: Move to target deviceCOMMENT
LOW…driver_scripts/check_code_search_path_is_propagated.py22 # Step 1: Print the statement indicating that the code_search_path have beenCOMMENT
LOW…driver_scripts/check_code_search_path_is_propagated.py25 # Step 2: Print the whole runtime_env to validate that it's been passedCOMMENT
LOW…/dashboard/modules/serve/tests/test_serve_dashboard.py1040 # Step 4: Scale - should succeedCOMMENT
LOW…/dashboard/modules/serve/tests/test_serve_dashboard.py1043 # Step 5: Disable external_scaler_enabled againCOMMENT
LOW…/dashboard/modules/serve/tests/test_serve_dashboard.py1001 # Step 1: Deploy with external_scaler_enabled=FalseCOMMENT
LOW…/dashboard/modules/serve/tests/test_serve_dashboard.py1012 # Step 2: Try to scale - should failCOMMENT
LOW…/dashboard/modules/serve/tests/test_serve_dashboard.py1029 # Step 3: Enable external_scaler_enabledCOMMENT
LOW…/dashboard/modules/serve/tests/test_serve_dashboard.py1056 # Step 6: Try to scale again - should failCOMMENT
LOW…in/v2/_internal/execution/checkpoint/report_handler.py48 # Step 1: Assert that the worker group has been started and not shut down.COMMENT
LOW…in/v2/_internal/execution/checkpoint/report_handler.py56 # Step 2: Update training_reports_queues with poll_results.COMMENT
LOW…in/v2/_internal/execution/checkpoint/report_handler.py68 # Step 3: Consolidate a list of checkpoints to single checkpoint.COMMENT
LOW…in/v2/_internal/execution/checkpoint/report_handler.py93 # Step 4: Invoke all dependent `ReportCallback`s.COMMENT
LOW…n/ray/autoscaler/_private/resource_demand_scheduler.py216 # Step 1: Calculate current cluster resources and node type countsCOMMENT
LOW…n/ray/autoscaler/_private/resource_demand_scheduler.py225 # Step 2: add nodes to add to satisfy min_workers for each typeCOMMENT
LOW…n/ray/autoscaler/_private/resource_demand_scheduler.py240 # Step 3: get resource demands of placement groups and return theCOMMENT
LOWpython/ray/serve/tests/test_logging.py369 # Step 1: Get current file end positionCOMMENT
LOWpython/ray/serve/tests/test_logging.py372 # Step 2: Make HTTP callCOMMENT
LOWpython/ray/serve/tests/test_logging.py401 # Step 3: Verify HTTP response matches new log linesCOMMENT
LOWpython/ray/serve/tests/test_autoscaling_policy.py1190 # Step 4: Change the max replicas to 2COMMENT
LOWpython/ray/serve/tests/test_autoscaling_policy.py1200 # Step 5: Make sure it is the same replica (lightweight change).COMMENT
LOWpython/ray/serve/tests/test_autoscaling_policy.py1205 # Step 6: Make sure initial_replicas overrides previous replicasCOMMENT
LOWpython/ray/serve/tests/test_autoscaling_policy.py1217 # Step 7: Make sure original replica is still running (lightweight change)COMMENT
LOWpython/ray/serve/tests/test_autoscaling_policy.py1131 # Step 1: Prepare the script in a zip file so it can be submitted via REST API.COMMENT
LOWpython/ray/serve/tests/test_autoscaling_policy.py1152 # Step 2: Deploy it with max_replicas=1COMMENT
LOWpython/ray/serve/tests/test_autoscaling_policy.py1176 # Step 3: Verify that it can scale from 0 to 1.COMMENT
LOWpython/ray/serve/tests/test_capacity_queue_router.py837 # Step 1: Saturate the replica — 2/2 slots occupied.COMMENT
LOWpython/ray/serve/tests/test_capacity_queue_router.py844 # Step 2: Kill the CQ. It restarts with in_flight=0.COMMENT
LOWpython/ray/serve/tests/test_capacity_queue_router.py860 # Step 3: Send a non-blocking request. The stale CQ issues a token,COMMENT
LOWpython/ray/serve/tests/test_capacity_queue_router.py865 # Step 4: The CQ should have learned — in_flight > 0 because theCOMMENT
LOWpython/ray/serve/tests/test_capacity_queue_router.py873 # Step 5: Release the blockers so all requests complete.COMMENT
LOWpython/ray/serve/tests/test_capacity_queue_router.py632 # Step 1: Occupy 3 of 5 slots with blocking requests.COMMENT
LOWpython/ray/serve/tests/test_capacity_queue_router.py647 # Step 2: Kill the queue. It restarts with in_flight=0.COMMENT
LOWpython/ray/serve/tests/unit/test_deployment_state.py3937 # Step 1: Create some deployment info with actors in running stateCOMMENT
LOWpython/ray/data/dataset.py7795 # NOTE: This method expected to have executor fully shutdown upon returningCOMMENT
LOWpython/ray/data/_internal/planner/plan_udf_map_op.py845 # NOTE: This method is nested to support Python 3.9 where we only canCOMMENT
LOW…thon/ray/data/_internal/block_batching/iter_batches.py251 # Step 1: Prefetch logical batches locally.COMMENT
LOW…thon/ray/data/_internal/block_batching/iter_batches.py254 # Step 2: Resolve the blocks.COMMENT
LOW…thon/ray/data/_internal/block_batching/iter_batches.py257 # Step 3: Batch and shuffle the resolved blocks.COMMENT
LOW…thon/ray/data/_internal/block_batching/iter_batches.py260 # Step 4: Format and collate the batches in a threadpool.COMMENT
LOW…thon/ray/data/_internal/block_batching/iter_batches.py271 # Step 6: Finalize the batches (e.g., move to GPU).COMMENT
LOW…ay/data/_internal/logical/rules/projection_pushdown.py424 # Step 1: Iteratively fuse with upstream Project operationsCOMMENT
LOW…ay/data/_internal/logical/rules/projection_pushdown.py443 # Step 2: Push projection into the data source if supportedCOMMENT
LOWpython/ray/data/tests/test_tensor.py1024 # Step 2: Switch context to native formatCOMMENT
LOWpython/ray/data/tests/test_tensor.py1027 # Step 3: Read data back - note that reading preserves original formatCOMMENT
LOWpython/ray/data/tests/test_tensor.py1066 # Step 5: Write to different pathCOMMENT
385 more matches not shown…
Modern AI Meta-Vocabulary144 hits · 400 pts
SeverityFileLineSnippetContext
MEDIUMpython/requirements/ml/rllib-test-requirements.txt16# For tests on PettingZoo's multi-agent envs.COMMENT
MEDIUM…nal/serve/serving_patterns/prefill_decode/pd_server.py75# those two routes at its own ``chat`` / ``completions`` (which orchestrateCOMMENT
MEDIUM…ray/serve/tests/unit/test_controller_direct_ingress.py151# Deployment State Manager for dependency injectionCOMMENT
MEDIUM…ray/serve/tests/unit/test_controller_direct_ingress.py54# Application State Manager for dependency injectionCOMMENT
MEDIUM…ray/data/tests/datasource/test_turbopuffer_datasink.py471# 7. End-to-end write orchestrationCOMMENT
MEDIUMrllib/connectors/connector_v2.py862 # Single-agent/multi-agent cases.COMMENT
MEDIUMrllib/connectors/common/batch_individual_items.py32 AgentToModuleMapping, # only in multi-agent setups!STRING
MEDIUMrllib/connectors/common/batch_individual_items.py43 AgentToModuleMapping, # only in multi-agent setups!STRING
MEDIUM…tors/common/add_observations_from_episodes_to_batch.py29 AgentToModuleMapping, # only in multi-agent setups!STRING
MEDIUM…tors/common/add_observations_from_episodes_to_batch.py40 AgentToModuleMapping, # only in multi-agent setups!STRING
MEDIUM…onnectors/common/add_time_dim_to_batch_and_zero_pad.py38 AgentToModuleMapping, # only in multi-agent setups!STRING
MEDIUM…onnectors/common/add_time_dim_to_batch_and_zero_pad.py49 AgentToModuleMapping, # only in multi-agent setups!STRING
MEDIUMrllib/connectors/common/module_to_agent_unmapping.py40 # This Connector should only be used in a multi-agent setting.COMMENT
MEDIUMrllib/connectors/common/agent_to_module_mapping.py30 AgentToModuleMapping, # only in multi-agent setups!STRING
MEDIUMrllib/connectors/common/agent_to_module_mapping.py41 AgentToModuleMapping, # only in multi-agent setups!STRING
MEDIUM…connectors/common/add_states_from_episodes_to_batch.py35 AgentToModuleMapping, # only in multi-agent setups!STRING
MEDIUM…connectors/common/add_states_from_episodes_to_batch.py46 AgentToModuleMapping, # only in multi-agent setups!STRING
MEDIUMrllib/connectors/common/flatten_observations.py220 # Multi-agent example: Use the connector with a multi-agent observation space.STRING
MEDIUMrllib/connectors/common/flatten_observations.py234 # Create a multi-agent observation space with agent IDs as keys.STRING
MEDIUMrllib/connectors/common/flatten_observations.py240 # Create a multi-agent episode with observations for both agents.STRING
MEDIUMrllib/connectors/common/flatten_observations.py259 # Construct the connector for multi-agent, flattening only agent_1's observations.STRING
MEDIUMrllib/connectors/common/flatten_observations.py440 # In the multi-agent case, we need to use the specific agent'sCOMMENT
MEDIUMrllib/connectors/common/flatten_observations.py441 # space struct, not the multi-agent observation space dict.COMMENT
MEDIUMrllib/connectors/common/flatten_observations.py476 # In the multi-agent case, we need to use the specific agent'sCOMMENT
MEDIUMrllib/connectors/common/flatten_observations.py477 # space struct, not the multi-agent observation space dict.COMMENT
MEDIUMrllib/connectors/common/numpy_to_tensor.py38 AgentToModuleMapping, # only in multi-agent setups!STRING
MEDIUMrllib/connectors/common/numpy_to_tensor.py49 AgentToModuleMapping, # only in multi-agent setups!STRING
MEDIUM…rs/learner/add_columns_from_episodes_to_train_batch.py26 AgentToModuleMapping, # only in multi-agent setups!STRING
MEDIUM…nectors/learner/add_one_ts_to_episodes_and_truncate.py115 # TODO (sven): Same situation as in TODO below, but for multi-agent episode.COMMENT
MEDIUM…onnectors/module_to_env/listify_data_for_vector_env.py27 ModuleToAgentUnmapping, # only in multi-agent setups!STRING
MEDIUM…onnectors/module_to_env/listify_data_for_vector_env.py61 # Multi-agent case: Create lists of multi-agent dicts under each column.COMMENT
MEDIUM…connectors/module_to_env/normalize_and_clip_actions.py33 ModuleToAgentUnmapping, # only in multi-agent setups!STRING
MEDIUM…onnectors/module_to_env/unbatch_to_individual_items.py28 ModuleToAgentUnmapping, # only in multi-agent setups!STRING
MEDIUM…onnectors/module_to_env/unbatch_to_individual_items.py61 # Keys are always tuples to resemble multi-agent keys, whichCOMMENT
MEDIUM…module_to_env/remove_single_ts_time_rank_from_batch.py27 ModuleToAgentUnmapping, # only in multi-agent setups!STRING
MEDIUMrllib/connectors/module_to_env/get_actions.py26 ModuleToAgentUnmapping, # only in multi-agent setups!STRING
MEDIUM…/connectors/env_to_module/prev_actions_prev_rewards.py102 # f"thus far (or, for multi-agent, on Dict spaces mapping AgentIDs to "COMMENT
MEDIUM…ectors/env_to_module/write_observations_to_episodes.py24 AgentToModuleMapping, # only in multi-agent setups!STRING
MEDIUM…ectors/env_to_module/write_observations_to_episodes.py112 # Note that the following loop works with multi-agent as well as withCOMMENT
MEDIUM…ectors/env_to_module/write_observations_to_episodes.py116 # `data`, either in a list directly under the "obs" key OR for multi-agent:COMMENT
MEDIUM…b/connectors/env_to_module/observation_preprocessor.py162 # TODO (sven): Implement set_observations API for multi-agent episodes.COMMENT
MEDIUMrllib/core/testing/testing_learner.py46 # TODO (Kourosh): Make this more multi-agent for example with policy idsCOMMENT
MEDIUMrllib/core/learner/differentiable_learner_config.py124 # If multi-agent -> Map from AgentID-based data to ModuleID based data.COMMENT
MEDIUMrllib/algorithms/algorithm_config.py4652 # If the module is single-agent convert it to multi-agent specCOMMENT
MEDIUMrllib/algorithms/algorithm_config.py4654 # The default RLModuleSpec (might be multi-agent or single-agent).COMMENT
MEDIUMrllib/algorithms/algorithm_config.py4656 # The currently configured RLModuleSpec (might be multi-agent or single-agent).COMMENT
MEDIUMrllib/algorithms/algorithm_config.py4677 # Algorithm is currently setup as a multi-agent one.COMMENT
MEDIUMrllib/algorithms/algorithm_config.py4683 # Default is single-agent but the user has provided a multi-agent specCOMMENT
MEDIUMrllib/algorithms/algorithm_config.py4684 # so the use-case is multi-agent.COMMENT
MEDIUMrllib/algorithms/algorithm_config.py4703 # We need to infer the multi-agent class from `current_rl_module_spec`COMMENT
MEDIUMrllib/algorithms/algorithm_config.py4713 # Default is multi-agent and user wants to override it -> Don't use theCOMMENT
MEDIUMrllib/algorithms/algorithm_config.py4717 # to reuse for all modules in this multi-agent default setup.COMMENT
MEDIUMrllib/algorithms/algorithm_config.py142 # The default agent ID to module ID mapping function to use in the multi-agentCOMMENT
MEDIUMrllib/algorithms/algorithm_config.py460 # TODO (sven): Prepare multi-agent setup for logging each agent's and eachCOMMENT
MEDIUMrllib/algorithms/algorithm_config.py800 # Set our multi-agent settings.COMMENT
MEDIUMrllib/algorithms/algorithm_config.py1116 # If multi-agent -> Map from AgentID-based data to ModuleID based data.COMMENT
MEDIUMrllib/algorithms/algorithm_config.py1224 # If multi-agent -> Map from ModuleID-based data to AgentID based data.COMMENT
MEDIUMrllib/algorithms/algorithm_config.py1247 # for single-agent and multi-agent dicts for multi-agent.COMMENT
MEDIUMrllib/algorithms/algorithm_config.py1309 # If multi-agent -> Map from AgentID-based data to ModuleID based data.COMMENT
MEDIUMrllib/algorithms/utils.py66 # which IDs the submodules have (to figure out, whether its multi-agent orCOMMENT
84 more matches not shown…
Redundant / Tautological Comments246 hits · 372 pts
SeverityFileLineSnippetContext
LOWpython/ray/exceptions.py582 # Check if RAY_AUTH_MODE is set to token and add a heads-up if notCOMMENT
LOWpython/ray/actor.py740 # Check if decorator is called without parentheses (args[0] would be the function)COMMENT
LOWpython/ray/experimental/rdt/rdt_manager.py758 # Check if a warning should be triggered for this object:COMMENT
LOW…nternal/common/utils/cloud_filesystem/s3_filesystem.py56 # Check if anonymous@ prefix existsCOMMENT
LOW…al/common/utils/cloud_filesystem/pyarrow_filesystem.py51 # Check if the first part ends with "anonymous"COMMENT
LOW…al/common/utils/cloud_filesystem/pyarrow_filesystem.py236 # Check if file existsCOMMENT
LOW…al/common/utils/cloud_filesystem/pyarrow_filesystem.py241 # Read fileCOMMENT
LOWpython/ray/llm/_internal/serve/utils/registry.py109 # Check if registeredSTRING
LOW…nal/serve/routing_policies/prefix_aware/prefix_tree.py416 # Check if any available tenants match this nodeCOMMENT
LOWpython/ray/util/tpu.py684 # Check if user explicitly requested a slice name for this sliceCOMMENT
LOWpython/ray/util/client_connect.py34 # Check if Ray is already connected (any type of connection)COMMENT
LOWpython/ray/util/collective/collective.py236 # Check if backend is registered and availableCOMMENT
LOW…sts/single_node_cpu_tests/test_gloo_group_isolation.py26 # Check if the group is initialized correctlyCOMMENT
LOWpython/ray/util/multiprocessing/pool.py259 # Check if any of the available IDs are done. The timeout is requiredCOMMENT
LOWpython/ray/util/client/common.py291 # Check if supplied parameters match the function signature. Same caseCOMMENT
LOWpython/ray/util/client/server/server.py76 # Check if response already cachedCOMMENT
LOWpython/ray/_common/usage/usage_lib.py822 # Check if we're on KubernetesCOMMENT
LOWpython/ray/_common/usage/usage_lib.py824 # Check if we're using KubeRay >= 0.4.0.COMMENT
LOWpython/ray/tests/conftest.py386 # Check if th redis has started successfully and is listening on the port.COMMENT
LOWpython/ray/tests/conftest.py1212# Set scope to "class" to force this to run before start_cluster, whose scopeCOMMENT
LOWpython/ray/tests/test_logging.py317 # Check if the backup count is respected.COMMENT
LOWpython/ray/tests/test_logging.py423 # Check if the backup count is respected.COMMENT
LOWpython/ray/tests/test_object_spilling_3.py386 # Iterate over the data on the worker nodes from the head node.COMMENT
LOWpython/ray/tests/test_runtime_env_plugin.py628# Set scope to "class" to force this to run before start_cluster, whose scopeCOMMENT
LOWpython/ray/tests/test_runtime_env_working_dir.py38# Set scope to "module" to force this to run before start_cluster, whose scopeCOMMENT
LOWpython/ray/tests/test_runtime_env_agent.py109 # Check if agent register is OK.COMMENT
LOWpython/ray/tests/test_scheduling.py734 # Check if task2 starts within 1 second (indicating the bug)COMMENT
LOWpython/ray/tests/test_runtime_env_failure.py20# Set scope to "class" to force this to run before start_cluster, whose scopeCOMMENT
LOWpython/ray/tests/test_coordinator_server.py375 # Check if now we can create more clusters/nodes.COMMENT
LOWpython/ray/tests/test_client.py86 # Set num_cpus to zero to ensure that both tasks can always be scheduledCOMMENT
LOWpython/ray/tests/test_cli.py1569# Check if ray.serve is available (it's an optional dependency)COMMENT
LOWpython/ray/tests/test_runtime_env_working_dir_3.py34# Set scope to "class" to force this to run before start_cluster, whose scopeCOMMENT
LOWpython/ray/tests/vsphere/test_cluster_operator.py654 # Check if status is not availableCOMMENT
LOWpython/ray/tests/vsphere/test_cluster_operator.py658 # Check if ingress in unavailableCOMMENT
LOWpython/ray/air/tests/test_integration_mlflow.py113 # Check if client recognizes already existing experiment.COMMENT
LOWpython/ray/air/tests/test_integration_mlflow.py195 # Check if run is created with proper tags.COMMENT
LOWpython/ray/air/tests/test_integration_mlflow.py237 # Check if params are logged at the end.COMMENT
LOWpython/ray/air/integrations/wandb.py133 # Check if we are in a train session and if we are not the rank 0 workerCOMMENT
LOWpython/ray/air/integrations/wandb.py350 # Check if user is already logged into wandb.COMMENT
LOWpython/ray/air/execution/resources/request.py75 # Check if the head bundle is empty (no resources defined or all resourcesCOMMENT
LOWpython/ray/_private/function_manager.py562 # Check if the actor class already exists in the cache.COMMENT
LOWpython/ray/_private/inspect_util.py14 # Check if function or method, respectivelyCOMMENT
LOWpython/ray/_private/node.py1594 # Write the file BEFORE the internal_kv_put below so the two neverCOMMENT
LOWpython/ray/_private/serialization.py220 # Check if this is an RDT ObjectRef being serialized inside a collectionCOMMENT
LOWpython/ray/_private/serialization.py440 # Check if the object should be returned as raw bytes.COMMENT
LOWpython/ray/_private/runtime_env/uv_runtime_env_hook.py268 # Check if the requirements.txt file is in the working_dirCOMMENT
LOWpython/ray/_private/runtime_env/uv_runtime_env_hook.py282 # Check if the pyproject.toml file is in the working_dirCOMMENT
LOWpython/ray/_private/accelerators/tpu.py407 # Check if z coordinates are present.COMMENT
LOW…y/_private/authentication/http_token_authentication.py92 # Check if user provided their own Authorization header (case-insensitive)COMMENT
LOW…/_private/authentication/authentication_token_setup.py79 # Check if you enabled token authentication.COMMENT
LOW…/_private/thirdparty/pathspec/patterns/gitwildmatch.py268 # Set i to one past the closing braket.COMMENT
LOWpython/ray/_private/thirdparty/tabulate/tabulate.py2090 # Check if pretty is the format being used and override the defaults so itCOMMENT
LOWpython/ray/dashboard/http_server_head.py206 # Check if token authentication is enabledCOMMENT
LOWpython/ray/dashboard/http_server_head.py246 # Check if the connection is secure (HTTPS)COMMENT
LOWpython/ray/dashboard/event_loop_monitor.py57# Set RAY_DASHBOARD_AGENT_LOOP_DUMP_SIGNAL to another signal name, or to anCOMMENT
LOWpython/ray/dashboard/tests/test_dashboard.py113 # Check if agent register is OK.COMMENT
LOWpython/ray/dashboard/modules/metrics/metrics_head.py155 # Check if the required Grafana services are running.COMMENT
LOWpython/ray/dashboard/modules/reporter/gpu_providers.py182 # Check if MIG mode is enabled on this GPUCOMMENT
LOWpython/ray/dashboard/modules/reporter/gpu_providers.py543 # Check if we should disable GPU check entirelyCOMMENT
LOWpython/ray/dashboard/modules/job/cli.py567 # Set no_format to True because the logs may have unescaped "{" and "}"COMMENT
186 more matches not shown…
AI Structural Patterns316 hits · 263 pts
SeverityFileLineSnippetContext
LOWpython/ray/runtime_context.py527CODE
LOWpython/ray/actor.py612CODE
LOWpython/ray/actor.py1079CODE
LOWpython/ray/actor.py2486CODE
LOWpython/ray/job_config.py48CODE
LOWpython/ray/runtime_env/runtime_env.py324CODE
LOWpython/ray/experimental/shuffle.py231CODE
LOW…/ray/llm/_internal/batch/stages/sglang_engine_stage.py78CODE
LOWpython/ray/util/tpu.py982CODE
LOWpython/ray/util/tpu.py555CODE
LOWpython/ray/util/client_connect.py22CODE
LOWpython/ray/util/dask/scheduler_utils.py242CODE
LOWpython/ray/util/state/api.py1180CODE
LOWpython/ray/util/state/state_cli.py885CODE
LOWpython/ray/util/client/__init__.py122CODE
LOWpython/ray/util/spark/cluster_init.py1222CODE
LOWpython/ray/util/spark/cluster_init.py1392CODE
LOWpython/ray/_common/usage/usage_lib.py883CODE
LOWpython/ray/_common/usage/usage_lib.py950CODE
LOWpython/ray/_common/usage/usage_lib.py971CODE
LOWpython/ray/_common/observability/platform_events.py13CODE
LOWpython/ray/tests/test_state_api.py256CODE
LOWpython/ray/tests/test_resource_metrics.py18CODE
LOWpython/ray/tests/test_core_worker_fault_tolerance.py125CODE
LOWpython/ray/tests/test_nccl_channel.py85CODE
LOWpython/ray/tests/test_metrics_agent_2.py49CODE
LOWpython/ray/tests/horovod/horovod_example.py40CODE
LOWpython/ray/tests/kuberay/utils.py310CODE
LOWpython/ray/air/tests/_test_experiment_restore_run.py158CODE
LOWpython/ray/air/integrations/mlflow.py33CODE
LOWpython/ray/air/integrations/wandb.py593CODE
LOWpython/ray/_private/worker.py1438CODE
LOWpython/ray/_private/worker.py2480CODE
LOWpython/ray/_private/worker.py3751CODE
LOWpython/ray/_private/test_utils.py188CODE
LOWpython/ray/_private/services.py883CODE
LOWpython/ray/_private/services.py1523CODE
LOWpython/ray/_private/services.py1610CODE
LOWpython/ray/_private/services.py2338CODE
LOWpython/ray/_private/services.py2421CODE
LOWpython/ray/_private/parameter.py129CODE
LOWpython/ray/_private/thirdparty/pynvml/pynvml.py2854CODE
LOWpython/ray/_private/thirdparty/pynvml/pynvml.py5957CODE
LOWpython/ray/_private/thirdparty/pynvml/pynvml.py5962CODE
LOWpython/ray/_private/thirdparty/tabulate/tabulate.py1556CODE
LOW…ard/modules/platform_events/tests/test_k8s_provider.py22CODE
LOWpython/ray/dashboard/modules/job/sdk.py133CODE
LOWpython/ray/dashboard/modules/job/job_manager.py465CODE
LOWpython/ray/dashboard/modules/log/log_manager.py344CODE
LOWpython/ray/tune/progress_reporter.py806CODE
LOWpython/ray/tune/progress_reporter.py939CODE
LOWpython/ray/tune/progress_reporter.py177CODE
LOWpython/ray/tune/progress_reporter.py502CODE
LOWpython/ray/tune/progress_reporter.py675CODE
LOWpython/ray/tune/tune.py267CODE
LOWpython/ray/tune/tune.py1069CODE
LOWpython/ray/tune/resources.py40CODE
LOWpython/ray/tune/result_grid.py300CODE
LOWpython/ray/tune/impl/tuner_internal.py99CODE
LOWpython/ray/tune/experimental/output.py296CODE
256 more matches not shown…
Verbosity Indicators125 hits · 232 pts
SeverityFileLineSnippetContext
LOWpython/ray/util/state/common.py1268 # Step 2: Create the tree structure based on ownershipSTRING
LOWpython/ray/dag/vis_utils.py94 # Step 0: check dependencies and init graphCOMMENT
LOWpython/ray/dag/vis_utils.py100 # Step 1: generate unique name for each node in dagCOMMENT
LOWpython/ray/dag/vis_utils.py107 # Step 2: create graph with all the edgesCOMMENT
LOWpython/ray/dag/compiled_dag_node.py2037 # Step 1: Build a graph of _DAGOperationGraphNodeSTRING
LOWpython/ray/dag/compiled_dag_node.py2042 # Step 2: Generate an execution schedule for each actor using topological sortSTRING
LOWpython/ray/dag/compiled_dag_node.py2045 # Step 3: Overlap GPU communication for the execution schedule if configuredSTRING
LOWpython/ray/dag/compiled_dag_node.py1798 # Step 1: populate `arg_to_consumers` and perform some validation.STRING
LOWpython/ray/dag/compiled_dag_node.py1818 # Step 2: create cached channels if neededSTRING
LOWpython/ray/dag/compiled_dag_node.py1837 # Step 3: create executable tasks for the actorSTRING
LOWpython/ray/_private/tensor_serialization_utils.py48 # Step 1: Convert uint8 numpy array back to torch tensorCOMMENT
LOWpython/ray/_private/tensor_serialization_utils.py51 # Step 2: Restore original dtypeCOMMENT
LOWpython/ray/_private/tensor_serialization_utils.py65 # Step 3: Reshape and reinterpret bytes as target dtypeCOMMENT
LOWpython/ray/_private/tensor_serialization_utils.py68 # Step 4: Move to target deviceCOMMENT
LOW…driver_scripts/check_code_search_path_is_propagated.py22 # Step 1: Print the statement indicating that the code_search_path have beenCOMMENT
LOW…driver_scripts/check_code_search_path_is_propagated.py25 # Step 2: Print the whole runtime_env to validate that it's been passedCOMMENT
LOW…/dashboard/modules/serve/tests/test_serve_dashboard.py1040 # Step 4: Scale - should succeedCOMMENT
LOW…/dashboard/modules/serve/tests/test_serve_dashboard.py1043 # Step 5: Disable external_scaler_enabled againCOMMENT
LOW…/dashboard/modules/serve/tests/test_serve_dashboard.py1001 # Step 1: Deploy with external_scaler_enabled=FalseCOMMENT
LOW…/dashboard/modules/serve/tests/test_serve_dashboard.py1012 # Step 2: Try to scale - should failCOMMENT
LOW…/dashboard/modules/serve/tests/test_serve_dashboard.py1029 # Step 3: Enable external_scaler_enabledCOMMENT
LOW…/dashboard/modules/serve/tests/test_serve_dashboard.py1056 # Step 6: Try to scale again - should failCOMMENT
LOW…in/v2/_internal/execution/checkpoint/report_handler.py48 # Step 1: Assert that the worker group has been started and not shut down.COMMENT
LOW…in/v2/_internal/execution/checkpoint/report_handler.py56 # Step 2: Update training_reports_queues with poll_results.COMMENT
LOW…in/v2/_internal/execution/checkpoint/report_handler.py68 # Step 3: Consolidate a list of checkpoints to single checkpoint.COMMENT
LOW…in/v2/_internal/execution/checkpoint/report_handler.py93 # Step 4: Invoke all dependent `ReportCallback`s.COMMENT
LOW…n/ray/autoscaler/_private/resource_demand_scheduler.py216 # Step 1: Calculate current cluster resources and node type countsCOMMENT
LOW…n/ray/autoscaler/_private/resource_demand_scheduler.py225 # Step 2: add nodes to add to satisfy min_workers for each typeCOMMENT
LOW…n/ray/autoscaler/_private/resource_demand_scheduler.py240 # Step 3: get resource demands of placement groups and return theCOMMENT
LOWpython/ray/serve/tests/test_logging.py369 # Step 1: Get current file end positionCOMMENT
LOWpython/ray/serve/tests/test_logging.py372 # Step 2: Make HTTP callCOMMENT
LOWpython/ray/serve/tests/test_logging.py401 # Step 3: Verify HTTP response matches new log linesCOMMENT
LOWpython/ray/serve/tests/test_autoscaling_policy.py1190 # Step 4: Change the max replicas to 2COMMENT
LOWpython/ray/serve/tests/test_autoscaling_policy.py1200 # Step 5: Make sure it is the same replica (lightweight change).COMMENT
LOWpython/ray/serve/tests/test_autoscaling_policy.py1205 # Step 6: Make sure initial_replicas overrides previous replicasCOMMENT
LOWpython/ray/serve/tests/test_autoscaling_policy.py1217 # Step 7: Make sure original replica is still running (lightweight change)COMMENT
LOWpython/ray/serve/tests/test_autoscaling_policy.py1131 # Step 1: Prepare the script in a zip file so it can be submitted via REST API.COMMENT
LOWpython/ray/serve/tests/test_autoscaling_policy.py1152 # Step 2: Deploy it with max_replicas=1COMMENT
LOWpython/ray/serve/tests/test_autoscaling_policy.py1176 # Step 3: Verify that it can scale from 0 to 1.COMMENT
LOWpython/ray/serve/tests/test_capacity_queue_router.py837 # Step 1: Saturate the replica — 2/2 slots occupied.COMMENT
LOWpython/ray/serve/tests/test_capacity_queue_router.py844 # Step 2: Kill the CQ. It restarts with in_flight=0.COMMENT
LOWpython/ray/serve/tests/test_capacity_queue_router.py860 # Step 3: Send a non-blocking request. The stale CQ issues a token,COMMENT
LOWpython/ray/serve/tests/test_capacity_queue_router.py865 # Step 4: The CQ should have learned — in_flight > 0 because theCOMMENT
LOWpython/ray/serve/tests/test_capacity_queue_router.py873 # Step 5: Release the blockers so all requests complete.COMMENT
LOWpython/ray/serve/tests/test_capacity_queue_router.py632 # Step 1: Occupy 3 of 5 slots with blocking requests.COMMENT
LOWpython/ray/serve/tests/test_capacity_queue_router.py647 # Step 2: Kill the queue. It restarts with in_flight=0.COMMENT
LOWpython/ray/serve/tests/unit/test_deployment_state.py3937 # Step 1: Create some deployment info with actors in running stateCOMMENT
LOW…thon/ray/data/_internal/block_batching/iter_batches.py251 # Step 1: Prefetch logical batches locally.COMMENT
LOW…thon/ray/data/_internal/block_batching/iter_batches.py254 # Step 2: Resolve the blocks.COMMENT
LOW…thon/ray/data/_internal/block_batching/iter_batches.py257 # Step 3: Batch and shuffle the resolved blocks.COMMENT
LOW…thon/ray/data/_internal/block_batching/iter_batches.py260 # Step 4: Format and collate the batches in a threadpool.COMMENT
LOW…thon/ray/data/_internal/block_batching/iter_batches.py271 # Step 6: Finalize the batches (e.g., move to GPU).COMMENT
LOW…ay/data/_internal/logical/rules/projection_pushdown.py424 # Step 1: Iteratively fuse with upstream Project operationsCOMMENT
LOW…ay/data/_internal/logical/rules/projection_pushdown.py443 # Step 2: Push projection into the data source if supportedCOMMENT
LOWpython/ray/data/tests/test_tensor.py1024 # Step 2: Switch context to native formatCOMMENT
LOWpython/ray/data/tests/test_tensor.py1027 # Step 3: Read data back - note that reading preserves original formatCOMMENT
LOWpython/ray/data/tests/test_tensor.py1066 # Step 5: Write to different pathCOMMENT
LOWpython/ray/data/tests/test_tensor.py1070 # Step 6: Read again and verify native format is preservedCOMMENT
LOWpython/ray/data/tests/test_tensor.py995 # Step 1: Write data using V1 or V2 formatCOMMENT
LOWpython/ray/data/tests/test_tensor.py1044 # Step 4: Apply a transformation that recreates tensor arrays in native formatCOMMENT
65 more matches not shown…
AI Slop Vocabulary119 hits · 229 pts
SeverityFileLineSnippetContext
MEDIUMbuild-docker.sh36 # It also can facilitate cleanup.COMMENT
MEDIUMpython/ray/actor.py2722 """This is defined in order to make pickling work.STRING
MEDIUMpython/ray/actor.py2771 """This is defined in order to make pickling work.STRING
LOWpython/ray/llm/_internal/common/utils/download_utils.py108 # and we can just return the model_dir.COMMENT
LOWpython/ray/llm/_internal/serve/utils/server_utils.py127 # This also works for normal exceptions (we will just return everything fromCOMMENT
MEDIUMpython/ray/llm/_internal/serve/utils/server_utils.py188 # TODO make this more robustCOMMENT
LOWpython/ray/llm/tests/common/cloud/test_s3_filesystem.py248 # This should not raise, just return without downloadingCOMMENT
LOWpython/ray/dag/input_node.py119 # If user only passed in one value, for simplicity we just return it.COMMENT
LOWpython/ray/tests/test_actor_resources.py449 # can't just return them from the tasks, because the tasks don't returnCOMMENT
MEDIUMpython/ray/tests/test_dataclient_disconnect.py61 # robust mechanism if they fail with code changes or become flaky.COMMENT
MEDIUMpython/ray/tests/conftest_docker.py16# setup is a little intricate, as it uses docker-in-docker.COMMENT
MEDIUMpython/ray/tests/test_resource_demand_scheduler.py2115 # TODO (Alex): We should find a more robust way of simulating a nodeCOMMENT
MEDIUMpython/ray/tests/test_resource_demand_scheduler.py2228 # testPlacementGroupScaling for more comprehensive tests.COMMENT
LOWpython/ray/tests/test_cli_patterns/test_no_head.yaml78# you should just use file_mounts. Only use this if you know what you're doing!COMMENT
LOWpython/ray/tests/test_cli_patterns/test_no_workers.yaml79# you should just use file_mounts. Only use this if you know what you're doing!COMMENT
LOWpython/ray/_private/worker.py2148 # should simply set "global_worker" to equal "None" or something like that.COMMENT
MEDIUMpython/ray/_private/services.py360 # TODO(ekl): Find a robust solution for locating Redis.COMMENT
LOWpython/ray/_private/runtime_env/working_dir.py63 # working_dir is already a URI -- just pass it through.COMMENT
MEDIUMpython/ray/_private/runtime_env/uv_runtime_env_hook.py448 # We purposefully modify sys.argv here to make sure the hook is robustCOMMENT
MEDIUMpython/ray/dashboard/tests/test_event_loop_monitor.py19# harness (they still show on stderr). Attach a handler to the module loggerCOMMENT
LOW…n/ray/dashboard/modules/reporter/tests/test_healthz.py19 # It'll either timeout or just return an errorCOMMENT
LOWpython/ray/dashboard/modules/job/job_manager.py383 in #24546 for GPU detection and just use the user's resourceSTRING
LOWpython/ray/dashboard/modules/node/node_head.py348 # TODO(rickyx): we should just return structure data rather than strings.COMMENT
MEDIUMpython/ray/dashboard/modules/node/datacenter.py163 # with a more robust mapping in a future update.COMMENT
MEDIUMpython/ray/dashboard/modules/node/datacenter.py245 # This will be addressed with a more robust mapping in a future update.COMMENT
LOWpython/ray/tune/search/optuna/optuna_search.py384 # If storage is not provided, just set self._storage to NoneCOMMENT
LOWpython/ray/tune/experiment/trial.py487 # been set and therefore would not be empty. We can just return it.COMMENT
LOWpython/ray/tune/experiment/trial.py492 # 3. In the worst case where we have nothing, we just set theCOMMENT
MEDIUMpython/ray/tune/schedulers/pb2.py131 # add diagonal ** we would ideally make this something more robust...COMMENT
MEDIUMpython/ray/train/v2/_internal/util.py248 # changes. Figure out a more robust way to exclude these frames.COMMENT
LOW…ternal/execution/controller/placement_group_cleaner.py48 # Thread already running, just return TrueCOMMENT
LOWpython/ray/autoscaler/vsphere/defaults.yaml86# you should just use file_mounts. Only use this if you know what you're doing!COMMENT
LOWpython/ray/autoscaler/vsphere/example-full.yaml89# you should just use file_mounts. Only use this if you know what you're doing!COMMENT
LOWpython/ray/autoscaler/aliyun/defaults.yaml104# you should just use file_mounts. Only use this if you know what you're doing!COMMENT
LOWpython/ray/autoscaler/aliyun/example-full.yaml110# you should just use file_mounts. Only use this if you know what you're doing!COMMENT
LOWpython/ray/autoscaler/aliyun/example-linux.yaml113# you should just use file_mounts. Only use this if you know what you're doing!COMMENT
LOWpython/ray/autoscaler/azure/defaults.yaml110# you should just use file_mounts. Only use this if you know what you're doing!COMMENT
LOWpython/ray/autoscaler/azure/example-full.yaml134# you should just use file_mounts. Only use this if you know what you're doing!COMMENT
LOWpython/ray/autoscaler/gcp/defaults.yaml112# you should just use file_mounts. Only use this if you know what you're doing!COMMENT
LOWpython/ray/autoscaler/gcp/example-full.yaml135# you should just use file_mounts. Only use this if you know what you're doing!COMMENT
MEDIUMpython/ray/autoscaler/_private/legacy_info_string.py6"""This file provides legacy support for the old info string in order toSTRING
MEDIUMpython/ray/autoscaler/_private/cli_logger.py218 """More robust check for interactive terminal/tty."""STRING
LOWpython/ray/autoscaler/_private/vsphere/node_provider.py71 # Currently vSphere VMs do not show an internal IP. So we just return theCOMMENT
LOWpython/ray/autoscaler/local/example-full.yaml81# you should just use file_mounts. Only use this if you know what you're doing!COMMENT
LOWpython/ray/autoscaler/v2/utils.py292 # No affinity constraints, just add to the combined requests.COMMENT
LOWpython/ray/autoscaler/v2/instance_manager/config.py412 # either extending the current ray-schema.json, or just use anotherCOMMENT
LOW…on/ray/autoscaler/v2/instance_manager/ray_installer.py91 # since the updater could hide exceptions and just set the status tagCOMMENT
MEDIUMpython/ray/autoscaler/v2/tests/test_reconciler.py1127 # Probably better to have a more comprehensive mocker for instanceCOMMENT
LOWpython/ray/autoscaler/aws/defaults.yaml102# 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.yaml104 # in the same subnet. This allows your EFA interfaces to leverage theirCOMMENT
LOWpython/ray/autoscaler/aws/example-full.yaml132# you should just use file_mounts. Only use this if you know what you're doing!COMMENT
LOWpython/ray/autoscaler/aws/example-ml.yaml101# you should just use file_mounts. Only use this if you know what you're doing!COMMENT
LOWpython/ray/serve/batching.py529 # all requests have been cancelled, simply return and wait forCOMMENT
LOWpython/ray/serve/tests/test_autoscaling_policy.py440 # Instant processing - just returnCOMMENT
MEDIUMpython/ray/serve/_private/controller.py904 """Returns comprehensive health metrics for the controller.STRING
MEDIUMpython/ray/serve/_private/haproxy.py1157 # Use -x socket transfer for seamless reloads if optimization is enabledCOMMENT
MEDIUMpython/ray/data/aggregate.py472 # to be robust and not flakySTRING
MEDIUMpython/ray/data/_internal/logging.py69# To facilitate debugging, Ray Data writes debug logs to a file. However, if Ray DataCOMMENT
MEDIUM…on/ray/data/_internal/datasource/parquet_datasource.py773 # method in order to leverage pyarrow's ParquetDataset abstraction,COMMENT
MEDIUMpython/ray/data/_internal/tensor_extensions/arrow.py1701 # same as a.ctypes.data, but robust for viewsCOMMENT
59 more matches not shown…
Slop Phrases80 hits · 176 pts
SeverityFileLineSnippetContext
LOWpython/setup.py26# When the bazel version is updated, make sure to update itCOMMENT
LOWpython/ray/llm/_internal/serve/utils/batcher.py87 # If the stream task is done, make sure to exit the read taskCOMMENT
LOWpython/ray/util/serialization.py40 # make sure to keep the API consistent.COMMENT
LOWpython/ray/_common/utils.py403 # Don't forget to strip() the newline:COMMENT
LOWpython/ray/tests/test_reference_counting_standalone.py464 # 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
LOWpython/ray/tests/test_placement_group_5.py376 # So we should make sure to wait until actor is scheduled.COMMENT
MEDIUMpython/ray/tests/test_cli_patterns/test_no_head.yaml55# By default Ray creates a new private keypair, but you can also use your own.COMMENT
LOWpython/ray/tests/test_cli_patterns/test_no_head.yaml56# If you do so, make sure to also set "KeyName" in the head and worker nodeCOMMENT
MEDIUMpython/ray/tests/test_cli_patterns/test_no_head.yaml104 # has your Ray repo pre-cloned. Then, you can replace the pip installsCOMMENT
MEDIUMpython/ray/tests/test_cli_patterns/test_no_workers.yaml56# By default Ray creates a new private keypair, but you can also use your own.COMMENT
LOWpython/ray/tests/test_cli_patterns/test_no_workers.yaml57# If you do so, make sure to also set "KeyName" in the head and worker nodeCOMMENT
MEDIUMpython/ray/tests/test_cli_patterns/test_no_workers.yaml105 # has your Ray repo pre-cloned. Then, you can replace the pip installsCOMMENT
MEDIUMpython/ray/_private/node.py1006 # This should work for most cases, especitallyCOMMENT
MEDIUM…/client/public/speedscope-1.5.3/speedscope.75eb7d8e.js9"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.__DO_NOT_USE__ActionTypes=exports.compose=exCODE
MEDIUMpython/ray/train/base_trainer.py325 # Define some dummy inputs for demonstration purposesSTRING
LOWpython/ray/train/tests/test_checkpoint.py40 # the pyarrow.fs.MockFileSystem, so we must make sure to returnCOMMENT
MEDIUMpython/ray/autoscaler/vsphere/defaults.yaml37# By default Ray creates a new private keypair, but you can also use your own.COMMENT
LOWpython/ray/autoscaler/vsphere/defaults.yaml38# If you do so, make sure to also set "KeyName" in the head and worker nodeCOMMENT
MEDIUMpython/ray/autoscaler/vsphere/example-minimal.yaml15# By default Ray creates a new private keypair, but you can also use your own.COMMENT
LOWpython/ray/autoscaler/vsphere/example-minimal.yaml16# If you do so, make sure to also set "KeyName" in the head and worker nodeCOMMENT
MEDIUMpython/ray/autoscaler/vsphere/example-full.yaml37# By default Ray creates a new private keypair, but you can also use your own.COMMENT
LOWpython/ray/autoscaler/vsphere/example-full.yaml38# If you do so, make sure to also set "KeyName" in the head and worker nodeCOMMENT
MEDIUMpython/ray/autoscaler/aliyun/defaults.yaml39# By default Ray creates a new private keypair, but you can also use your own.COMMENT
LOWpython/ray/autoscaler/aliyun/defaults.yaml40# If you do so, make sure to also set "KeyName" in the head and worker nodeCOMMENT
MEDIUMpython/ray/autoscaler/aliyun/example-full.yaml47# By default Ray creates a new private keypair, but you can also use your own.COMMENT
LOWpython/ray/autoscaler/aliyun/example-full.yaml48# If you do so, make sure to also set "key_name".COMMENT
MEDIUMpython/ray/autoscaler/aliyun/example-linux.yaml46# By default Ray creates a new private keypair, but you can also use your own.COMMENT
LOWpython/ray/autoscaler/aliyun/example-linux.yaml47# If you do so, make sure to also set "KeyName" in the head and worker nodeCOMMENT
MEDIUMpython/ray/autoscaler/azure/defaults.yaml135 # has your Ray repo pre-cloned. Then, you can replace the pip installsCOMMENT
MEDIUMpython/ray/autoscaler/azure/example-full.yaml166# has your Ray repo pre-cloned. Then, you can replace the pip installsCOMMENT
MEDIUMpython/ray/autoscaler/gcp/defaults.yaml32# By default Ray creates a new private keypair, but you can also use your own.COMMENT
LOWpython/ray/autoscaler/gcp/defaults.yaml33# If you do so, make sure to also set "KeyName" in the head and worker nodeCOMMENT
MEDIUMpython/ray/autoscaler/gcp/defaults.yaml135 # has your Ray repo pre-cloned. Then, you can replace the pip installsCOMMENT
MEDIUMpython/ray/autoscaler/gcp/example-full.yaml47# By default Ray creates a new private keypair, but you can also use your own.COMMENT
LOWpython/ray/autoscaler/gcp/example-full.yaml48# If you do so, make sure to also set "KeyName" in the head and worker nodeCOMMENT
MEDIUMpython/ray/autoscaler/gcp/example-full.yaml161 # has your Ray repo pre-cloned. Then, you can replace the pip installsCOMMENT
MEDIUMpython/ray/autoscaler/gcp/example-gpu-docker.yaml41# By default Ray creates a new private keypair, but you can also use your own.COMMENT
LOWpython/ray/autoscaler/gcp/example-gpu-docker.yaml42# If you do so, make sure to also set "KeyName" in the head and worker nodeCOMMENT
MEDIUMpython/ray/autoscaler/_private/cli_logger_demoall.py4# function for demonstration purposes. Primarily useful for tuning color andCOMMENT
LOWpython/ray/autoscaler/_private/autoscaler.py498 # Sort based on last used to make sure to keep min_workers thatCOMMENT
LOWpython/ray/autoscaler/_private/vsphere/node_provider.py96 # make sure to mark newly created nodes as readyCOMMENT
LOWpython/ray/autoscaler/_private/gcp/config.py575 # We need to make sure to _create_ the file with the rightCOMMENT
LOWpython/ray/autoscaler/_private/aws/config.py410 # We need to make sure to _create_ the file with the rightCOMMENT
MEDIUMpython/ray/autoscaler/local/example-full.yaml115 # has your Ray repo pre-cloned. Then, you can replace the pip installsCOMMENT
MEDIUM…on/ray/autoscaler/local/example-minimal-automatic.yaml31# If Ray is not already installed on your cluster, you can use setupCOMMENT
MEDIUMpython/ray/autoscaler/local/example-minimal-manual.yaml18# If Ray is not already installed on your cluster, you can use setupCOMMENT
MEDIUMpython/ray/autoscaler/aws/defaults.yaml37# By default Ray creates a new private keypair, but you can also use your own.COMMENT
LOWpython/ray/autoscaler/aws/defaults.yaml38# If you do so, make sure to also set "KeyName" in the head and worker nodeCOMMENT
MEDIUMpython/ray/autoscaler/aws/example-full.yaml52# By default Ray creates a new private keypair, but you can also use your own.COMMENT
LOWpython/ray/autoscaler/aws/example-full.yaml53# If you do so, make sure to also set "KeyName" in the head and worker nodeCOMMENT
MEDIUMpython/ray/autoscaler/aws/example-full.yaml158 # has your Ray repo pre-cloned. Then, you can replace the pip installsCOMMENT
MEDIUMpython/ray/autoscaler/aws/example-ml.yaml57# By default Ray creates a new private keypair, but you can also use your own.COMMENT
LOWpython/ray/autoscaler/aws/example-ml.yaml58# If you do so, make sure to also set "KeyName" in the head and worker nodeCOMMENT
MEDIUMpython/ray/autoscaler/aws/example-ml.yaml116 # has your Ray repo pre-cloned. Then, you can replace the pip installsCOMMENT
MEDIUMpython/ray/autoscaler/aws/example-gpu-docker.yaml38# By default Ray creates a new private keypair, but you can also use your own.COMMENT
LOWpython/ray/autoscaler/aws/example-gpu-docker.yaml39# If you do so, make sure to also set "KeyName" in the head and worker nodeCOMMENT
LOW…on/ray/data/_internal/datasource/parquet_datasource.py886 # If include_paths is True, make sure to include the path column in the projectionCOMMENT
LOW…hon/ray/data/_internal/execution/streaming_executor.py515 # ray.wait() overhead, so make sure to allow multiple dispatch per call forCOMMENT
MEDIUM…ta/_internal/execution/interfaces/physical_operator.py547 Here's a simple example of implementing a basic "Map" operator:STRING
LOWpython/ray/data/tests/datasource/test_mongo.py15# To run tests locally, make sure you install mongodb-org and have mongodCOMMENT
20 more matches not shown…
Dead Code26 hits · 52 pts
SeverityFileLineSnippetContext
MEDIUM…/tests/batch/gpu/stages/test_serve_deployment_stage.py192CODE
MEDIUM…/tests/batch/gpu/stages/test_serve_deployment_stage.py231CODE
MEDIUM…/tests/batch/gpu/stages/test_serve_deployment_stage.py350CODE
MEDIUM…/tests/batch/gpu/stages/test_serve_deployment_stage.py387CODE
MEDIUM…thon/ray/llm/tests/batch/cpu/stages/test_stage_base.py242CODE
MEDIUM…ts/prefill_decode_disagg/test_prefill_decode_disagg.py698CODE
MEDIUMpython/ray/dag/tests/experimental/actor_defs.py78CODE
MEDIUMpython/ray/tests/test_basic.py1176CODE
MEDIUMpython/ray/tests/test_runtime_env_working_dir.py347CODE
MEDIUM…hon/ray/tests/test_streaming_generator_backpressure.py1439CODE
MEDIUMpython/ray/tests/test_baseexceptionandgroup.py69CODE
MEDIUMpython/ray/tests/test_gcs_fault_tolerance.py457CODE
MEDIUMpython/ray/tests/test_generators.py883CODE
MEDIUMpython/ray/tests/test_generators.py907CODE
MEDIUMpython/ray/tests/test_generators.py932CODE
MEDIUMpython/ray/tests/test_streaming_generator.py286CODE
MEDIUMpython/ray/tests/test_streaming_generator.py682CODE
MEDIUMpython/ray/tests/test_streaming_generator.py686CODE
MEDIUMpython/ray/serve/tests/test_grpc.py1229CODE
MEDIUMpython/ray/serve/tests/test_grpc.py1271CODE
MEDIUMpython/ray/serve/tests/test_fastapi.py421CODE
MEDIUMpython/ray/serve/_private/local_testing_mode.py392CODE
MEDIUMpython/ray/data/tests/test_map.py207CODE
MEDIUMrllib/core/learner/tests/test_learner_group.py162CODE
MEDIUMrllib/core/learner/tests/test_learner_group.py164CODE
MEDIUM…ray-observability/doc_code/ray-distributed-debugger.py24CODE
AI Response Leakage6 hits · 49 pts
SeverityFileLineSnippetContext
HIGHpython/ray/tune/tests/tutorial.py26 # In this example, we don't change the model architectureCOMMENT
HIGHpython/ray/tune/tests/test_logger.py300 # In this example, this is `self.test_dir`.COMMENT
HIGHdoc/source/cluster/kubernetes/k8s-ecosystem/ingress.md47# 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.md612# In this example, we use 2 GPUs.COMMENT
HIGH…al/pytorch_tutorials_hyperparameter_tuning_tutorial.py87# In this example, we can specifyCOMMENT
HIGH…al/pytorch_tutorials_hyperparameter_tuning_tutorial.py369# In this example, the ``l1`` and ``l2`` parametersCOMMENT
Fake / Example Data41 hits · 42 pts
SeverityFileLineSnippetContext
LOW…thon/ray/experimental/channel/serialization_context.py155 "placeholder",CODE
LOWpython/ray/llm/examples/sglang/query_example.py13client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")CODE
LOWpython/ray/tests/chaos/streaming_llm.py53 words = "Lorem ipsum dolor sit amet".split()CODE
LOWpython/ray/tests/chaos/streaming_llm.py53 words = "Lorem ipsum dolor sit amet".split()CODE
LOWpython/ray/air/tests/test_experiment_restore.py82 csv_file = str(tmp_path / "dummy_data.csv")CODE
LOWpython/ray/air/tests/_test_experiment_restore_run.py106 trainable = tune.with_parameters(trainable, data={"dummy_data": [1, 2, 3]})CODE
LOW…/train/v2/tests/test_async_checkpointing_validation.py494 .build_checkpoint_path_from_name("placeholder")CODE
LOWpython/ray/serve/llm/__init__.py233 client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")STRING
LOWpython/ray/serve/llm/__init__.py322 client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")STRING
LOWpython/ray/serve/_private/test_utils.py699 actor_options={"name": "placeholder"},CODE
LOWpython/ray/data/tests/test_with_column.py205 "expected_first": "John Doe",CODE
LOWrelease/llm_tests/serve/test_utils.py199 os.environ["OPENAI_API_KEY"] = api_token or "fake-key"CODE
LOWrelease/llm_tests/serve/test_utils.py251 return OpenAI(base_url=f"{server_url}/v1", api_key="fake-key")CODE
LOWrelease/llm_tests/serve/test_llm_serve_sglang.py71 client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")CODE
LOWrelease/llm_tests/serve/test_llm_serve_sglang.py355 client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")CODE
LOWrelease/llm_tests/serve/test_llm_serve_sglang.py425 client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")CODE
LOWrelease/llm_tests/serve/test_llm_serve_sglang.py490 client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")CODE
LOWrelease/llm_tests/serve/test_llm_serve_sglang.py559 client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")CODE
LOWrelease/llm_tests/serve/test_llm_serve_sleep_wakeup.py203 client = OpenAI(base_url=f"{BASE_URL}/v1", api_key="fake-key")CODE
LOWrelease/llm_tests/serve/test_llm_serve_pause_resume.py113 client = OpenAI(base_url=f"{BASE_URL}/v1", api_key="fake-key")CODE
LOWrelease/llm_tests/serve/test_llm_serve_rlhf.py129 client = OpenAI(base_url=f"{BASE_URL}/v1", api_key="fake-key")CODE
LOWrelease/ray_release/tests/test_glue.py256 self.command_runner_return["get_last_logs_ex"] = "Lorem ipsum"CODE
LOW…/doc_code/serve/transcription/transcription_example.py85client = openai.OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")CODE
LOW…urce/llm/doc_code/serve/sglang/sglang_query_example.py4client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")CODE
LOWdoc/source/serve/llm/quick-start.md87 -H "Authorization: Bearer fake-key" \CODE
LOWdoc/source/serve/llm/quick-start.md102client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")CODE
LOWdoc/source/serve/llm/user-guides/multi-lora.md124client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")CODE
LOW…ource/serve/llm/user-guides/data-parallel-attention.md101 -H "Authorization: Bearer fake-key" \CODE
LOW…ource/serve/llm/user-guides/data-parallel-attention.md119 api_key="fake-key"CODE
LOWdoc/source/serve/llm/user-guides/vllm-compatibility.md53client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")CODE
LOWdoc/source/serve/llm/user-guides/vllm-compatibility.md72 -H "Authorization: Bearer fake-key" \CODE
LOWdoc/source/serve/llm/user-guides/vllm-compatibility.md110client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")CODE
LOWdoc/source/serve/llm/user-guides/vllm-compatibility.md132 -H "Authorization: Bearer fake-key" \CODE
LOWdoc/source/serve/llm/user-guides/vllm-compatibility.md185client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")CODE
LOWdoc/source/serve/llm/user-guides/vllm-compatibility.md230client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")CODE
LOWdoc/source/serve/llm/user-guides/vllm-compatibility.md317client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key")CODE
LOWdoc/source/serve/doc_code/fake_email_creator.yaml23 image: shrekrisanyscale/serve-fake-email-example:exampleCODE
LOWdoc/source/serve/doc_code/fake_email_creator.yaml49 image: shrekrisanyscale/serve-fake-email-example:exampleCODE
LOWdoc/source/serve/production-guide/docker.md104A pre-built version of this image is available at [shrekrisanyscale/serve-fake-email-example](https://hub.docker.com/r/sCODE
LOWdoc/source/serve/tutorials/serve-deepseek.md114 -H "Authorization: Bearer fake-key" \CODE
LOWdoc/source/serve/tutorials/serve-deepseek.md136 -H "Authorization: Bearer fake-key" \CODE
Overly Generic Function Names30 hits · 27 pts
SeverityFileLineSnippetContext
LOW…/cpu/deployments/llm/multiplex/test_multiplex_utils.py147 def test_function(x, y):CODE
LOWpython/ray/util/dask/scheduler_utils.py122def execute_task(key, task_info, dumps, loads, get_id, pack_exception):CODE
LOWpython/ray/tests/test_basic.py979 def test_function(fn, remote_fn):STRING
LOWpython/ray/tests/test_basic.py1007 def test_function(fn, remote_fn):STRING
LOWpython/ray/tests/test_basic.py1064 def test_function(fn, remote_fn):STRING
LOWpython/ray/tests/test_args.py18 def test_function(fn, remote_fn):CODE
LOWpython/ray/tests/test_args.py50 def test_function(fn, remote_fn):CODE
LOWpython/ray/tests/test_task_metrics.py128def my_function():CODE
LOWpython/ray/tests/chaos/streaming_llm.py45 async def handle_request(self, prompt: str) -> StreamingResponse:CODE
LOWpython/ray/tune/tests/test_api.py640 def run_task(config):CODE
LOWpython/ray/serve/tests/test_handle_1.py363 async def handle_request(self, request: str):CODE
LOWpython/ray/serve/tests/test_handle_1.py406 async def handle_request(self, request: str):CODE
LOWpython/ray/serve/tests/test_handle_1.py439 async def handle_request(self, request: str):CODE
LOWpython/ray/serve/tests/test_handle_1.py477 async def handle_request(self, request: str):CODE
LOWpython/ray/serve/tests/test_handle_1.py527 async def handle_request(self, request: str):CODE
LOWpython/ray/serve/tests/test_task_processor.py612 def process_data(self, payload):CODE
LOWpython/ray/serve/tests/test_task_processor.py681 def process_data(self, data):CODE
LOWpython/ray/serve/tests/test_actor_replica_wrapper.py110 async def handle_request(CODE
LOW…on/ray/serve/tests/typing_files/check_handle_typing.py129 def my_method(self, x: int) -> str:CODE
LOWpython/ray/serve/_private/tracing_utils.py176 def my_function(obj):STRING
LOWpython/ray/serve/_private/replica.py1620 async def handle_request(CODE
LOWpython/ray/serve/_private/replica.py3308 async def handle_request(CODE
LOW…ve_tests/workloads/multi_deployment_1k_noop_replica.py98 async def handle_request(self, body: bytes, depth: int):CODE
LOWrllib/utils/actor_manager.py225 def do_something(self):STRING
LOWdoc/source/ray-core/doc_code/tasks.py16def my_function():CODE
LOWdoc/source/ray-core/doc_code/tasks.py115def my_function():CODE
LOWdoc/source/ray-core/doc_code/actor_checkpointing.py15 def execute_task(self, crash=False):CODE
LOWdoc/source/serve/doc_code/streaming_tutorial.py39 def handle_request(self, prompt: str) -> StreamingResponse:CODE
LOWdoc/source/serve/doc_code/streaming_tutorial.py126 async def handle_request(self, ws: WebSocket) -> None:CODE
LOWdoc/source/serve/doc_code/streaming_tutorial.py267 async def handle_request(self, prompt: str) -> StreamingResponse:CODE
Magic Placeholder Names11 hits · 25 pts
SeverityFileLineSnippetContext
HIGHpython/ray/data/dataset.py5891 api_key="<YOUR_API_KEY>",STRING
HIGHpython/ray/data/dataset.py5891 api_key="<YOUR_API_KEY>",STRING
HIGHpython/ray/data/dataset.py5902 api_key="<YOUR_API_KEY>",STRING
HIGHpython/ray/data/dataset.py5902 api_key="<YOUR_API_KEY>",STRING
HIGH…/ray/data/_internal/datasource/turbopuffer_datasink.py101 api_key="<YOUR_API_KEY>",STRING
HIGH…/ray/data/_internal/datasource/turbopuffer_datasink.py101 api_key="<YOUR_API_KEY>",STRING
HIGH…/ray/data/_internal/datasource/turbopuffer_datasink.py114 api_key="<YOUR_API_KEY>",STRING
HIGH…/ray/data/_internal/datasource/turbopuffer_datasink.py114 api_key="<YOUR_API_KEY>",STRING
HIGH…/ray/data/_internal/datasource/turbopuffer_datasink.py127 api_key="<YOUR_API_KEY>",STRING
HIGH…/ray/data/_internal/datasource/turbopuffer_datasink.py127 api_key="<YOUR_API_KEY>",STRING
HIGHdoc/source/serve/tutorials/video-analysis/README.md94PEXELS_API_KEY = os.environ.get("PEXELS_API_KEY") # Or set directly: "your-api-key"CODE
Example Usage Blocks5 hits · 8 pts
SeverityFileLineSnippetContext
LOWpython/ray/serve/_private/constants.py137# Example usage:COMMENT
LOWrllib/utils/tests/run_memory_leak_tests.py6# Example usage:COMMENT
LOWdoc/source/cluster/doc_code/slurm-launch.py2# Usage:COMMENT
LOWsrc/ray/util/shared_lru.h20// Example usage:COMMENT
LOWsrc/ray/util/thread_checker.h17// Example usage:COMMENT
TODO Padding2 hits · 3 pts
SeverityFileLineSnippetContext
LOWpython/ray/train/__init__.py113# TODO: consider implementing these in v1 and raising ImportError instead.COMMENT
LOW…ray/serve/tests/test_deployment_scheduler_downscale.py159 # TODO: Add test for downscale placement group fallback_strategy when it's added to deployment options.COMMENT