Ray is an AI compute engine. Ray consists of a core distributed runtime and a set of AI Libraries for accelerating ML workloads.
This report summarizes scanner evidence for ray-project/ray, a Python project with 44,004 GitHub stars. SynthScan examined 1,760,086 lines of code across 8031 source files, recording 30496 pattern matches distributed across 27 syntactic categories. The legacy adjusted pattern signal is 22.8 (Elevated pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Can maintainers explain intent, assumptions, and trade-offs? 23002 finding(s).
Are imports declared and package/API names verified? 3144 finding(s).
Are wrappers, guards, and repeated structures necessary? 20572 finding(s).
Which changes need focused human review? 30496 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 30496 distinct pattern matches across 27 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. 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 configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/setup.py | 426 | def is_native_windows_or_msys(): | CODE |
| LOW | python/setup.py | 432 | def is_invalid_windows_platform(): | CODE |
| LOW | python/ray/client_builder.py | 345 | def _get_builder_from_address(address: Optional[str]) -> ClientBuilder: | CODE |
| LOW | python/ray/runtime_context.py | 461 | def was_current_actor_reconstructed(self): | CODE |
| LOW | python/ray/runtime_context.py | 475 | def current_placement_group_id(self): | CODE |
| LOW | python/ray/runtime_context.py | 493 | def should_capture_child_tasks_in_placement_group(self): | CODE |
| LOW | python/ray/cross_language.py | 124 | def _get_function_descriptor_for_actor_method( | CODE |
| LOW | python/ray/cluster_utils.py | 402 | def remaining_processes_alive(self): | CODE |
| LOW | python/ray/exceptions.py | 121 | def _is_hidden_internal_frame(line: str, extra_markers: Sequence[str] = ()) -> bool: | CODE |
| LOW | python/ray/exceptions.py | 207 | def make_dual_exception_instance(self) -> "RayTaskError": | CODE |
| LOW | python/ray/exceptions.py | 221 | def _make_normal_dual_exception_instance(self) -> "RayTaskError": | CODE |
| LOW | python/ray/exceptions.py | 255 | def _make_exceptiongroup_dual_exception_instance(self) -> "RayTaskError": | CODE |
| LOW | python/ray/actor.py | 1690 | def _ray_from_function_descriptor( | CODE |
| LOW | python/ray/job_config.py | 182 | def set_default_actor_lifetime(self, default_actor_lifetime: str) -> None: | CODE |
| LOW⚡ | python/ray/job_config.py | 269 | def _runtime_env_has_working_dir(self): | CODE |
| LOW⚡ | python/ray/job_config.py | 272 | def _get_serialized_runtime_env(self) -> str: | CODE |
| LOW⚡ | python/ray/job_config.py | 276 | def _get_proto_runtime_env_config(self) -> str: | CODE |
| LOW | python/ray/runtime_env/runtime_env.py | 97 | def parse_and_validate_runtime_env_config( | CODE |
| LOW | python/ray/runtime_env/runtime_env.py | 124 | def build_proto_runtime_env_config(self) -> ProtoRuntimeEnvConfig: | CODE |
| LOW | python/ray/experimental/shuffle.py | 286 | def output_writer_non_streaming( | CODE |
| LOW | python/ray/experimental/internal_kv.py | 16 | def internal_kv_get_gcs_client(): | CODE |
| LOW | python/ray/experimental/locations.py | 45 | def get_local_object_locations( | CODE |
| LOW | python/ray/experimental/tqdm_ray.py | 316 | def _process_state_update_locked(self, state: ProgressBarState) -> None: | CODE |
| LOW | python/ray/experimental/tqdm_ray.py | 378 | def _get_or_allocate_bar_group(self, state: ProgressBarState): | CODE |
| LOW | python/ray/experimental/collective/conftest.py | 201 | def mock_do_destroy_nccl_group(self, group_id: str) -> None: | CODE |
| LOW | python/ray/experimental/collective/conftest.py | 231 | def check_nccl_group_teardown( | CODE |
| LOW | python/ray/experimental/collective/collective.py | 39 | def remove_remote_communicator(self, name: str): | CODE |
| LOW | python/ray/experimental/collective/collective.py | 134 | def _do_init_collective_group(self, rank: int): | CODE |
| LOW | python/ray/experimental/collective/collective.py | 182 | def _do_destroy_collective_group(self): | CODE |
| LOW | python/ray/experimental/collective/collective.py | 200 | def destroy_all_collective_groups(): | CODE |
| LOW | python/ray/experimental/channel/accelerator_context.py | 222 | def register_accelerator_context( | CODE |
| LOW | python/ray/experimental/channel/accelerator_context.py | 236 | def is_accelerator_context_registered(): | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 335 | def ensure_registered_as_writer(self) -> None: | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 357 | def ensure_registered_as_reader(self) -> None: | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 369 | def _deserialize_reader_channel( | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 410 | def _resize_channel_if_needed(self, serialized_value: str, timeout_ms: int): | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 584 | def ensure_registered_as_writer(self): | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 591 | def ensure_registered_as_reader(self): | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 760 | def ensure_registered_as_writer(self) -> None: | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 767 | def ensure_registered_as_reader(self) -> None: | CODE |
| LOW | python/ray/experimental/channel/torch_tensor_type.py | 117 | def register_custom_serializer(self) -> None: | CODE |
| LOW | …thon/ray/experimental/channel/intra_process_channel.py | 38 | def ensure_registered_as_writer(self) -> None: | CODE |
| LOW | …thon/ray/experimental/channel/intra_process_channel.py | 41 | def ensure_registered_as_reader(self) -> None: | CODE |
| LOW | python/ray/experimental/channel/cached_channel.py | 38 | def ensure_registered_as_writer(self) -> None: | CODE |
| LOW | python/ray/experimental/channel/cached_channel.py | 42 | def ensure_registered_as_reader(self) -> None: | CODE |
| LOW⚡ | …thon/ray/experimental/channel/serialization_context.py | 74 | def set_use_external_transport(self, use_external_transport: bool) -> None: | CODE |
| LOW⚡ | …thon/ray/experimental/channel/serialization_context.py | 81 | def reset_out_of_band_tensors( | CODE |
| LOW | …thon/ray/experimental/channel/serialization_context.py | 113 | def serialize_to_numpy_or_scalar( | CODE |
| LOW | …thon/ray/experimental/channel/serialization_context.py | 170 | def deserialize_from_numpy_or_scalar( | CODE |
| LOW | python/ray/experimental/channel/common.py | 35 | def retry_and_check_interpreter_exit(f: Callable[[], None]) -> bool: | CODE |
| LOW | python/ray/experimental/channel/common.py | 68 | def register_custom_serializer(self) -> None: | CODE |
| LOW | python/ray/experimental/channel/common.py | 201 | def ensure_registered_as_writer(self): | CODE |
| LOW | python/ray/experimental/channel/common.py | 207 | def ensure_registered_as_reader(self): | CODE |
| LOW | python/ray/experimental/channel/common.py | 324 | def _consume_leftover_channels_if_needed( | CODE |
| LOW | python/ray/experimental/channel/utils.py | 17 | def split_readers_by_locality( | CODE |
| LOW | python/ray/experimental/channel/utils.py | 46 | def split_actors_by_node_locality( | CODE |
| LOW | …perimental/channel/torch_tensor_accelerator_channel.py | 167 | def ensure_registered_as_writer(self): | CODE |
| LOW | …perimental/channel/torch_tensor_accelerator_channel.py | 174 | def ensure_registered_as_reader(self): | CODE |
| LOW | …perimental/channel/torch_tensor_accelerator_channel.py | 463 | def ensure_registered_as_writer(self): | CODE |
| LOW | …perimental/channel/torch_tensor_accelerator_channel.py | 471 | def ensure_registered_as_reader(self) -> bool: | CODE |
| 15818 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | python/requirements/ml/rllib-test-requirements.txt | 6 | # --------------------- | COMMENT |
| MEDIUM | python/ray/experimental/sandbox/http/host.py | 194 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/sandbox/http/host.py | 196 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/sandbox/http/host.py | 394 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/sandbox/http/host.py | 396 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/sandbox/http/host.py | 455 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/sandbox/http/host.py | 457 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/sandbox/http/host.py | 561 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/sandbox/http/host.py | 563 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/sandbox/http/app.py | 245 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/sandbox/http/app.py | 247 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/sandbox/http/app.py | 427 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/sandbox/http/app.py | 429 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/sandbox/http/app.py | 476 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/sandbox/http/app.py | 478 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …n/ray/experimental/sandbox/http/tests/test_http_app.py | 51 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …n/ray/experimental/sandbox/http/tests/test_http_app.py | 53 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …n/ray/experimental/sandbox/http/tests/test_http_app.py | 102 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …n/ray/experimental/sandbox/http/tests/test_http_app.py | 104 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …n/ray/experimental/sandbox/http/tests/test_http_app.py | 303 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …n/ray/experimental/sandbox/http/tests/test_http_app.py | 305 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …n/ray/experimental/sandbox/http/tests/test_http_app.py | 413 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …n/ray/experimental/sandbox/http/tests/test_http_app.py | 415 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ay/experimental/sandbox/http/tests/test_grpc_facade.py | 869 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ay/experimental/sandbox/http/tests/test_grpc_facade.py | 871 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …y/experimental/sandbox/http/tests/test_sandbox_host.py | 54 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …y/experimental/sandbox/http/tests/test_sandbox_host.py | 56 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …y/experimental/sandbox/http/tests/test_sandbox_host.py | 164 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …y/experimental/sandbox/http/tests/test_sandbox_host.py | 167 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …y/experimental/sandbox/http/tests/test_sandbox_host.py | 197 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …y/experimental/sandbox/http/tests/test_sandbox_host.py | 199 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …y/experimental/sandbox/http/tests/test_sandbox_host.py | 331 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …y/experimental/sandbox/http/tests/test_sandbox_host.py | 333 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …y/experimental/sandbox/http/tests/test_sandbox_host.py | 371 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …y/experimental/sandbox/http/tests/test_sandbox_host.py | 373 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …y/experimental/sandbox/http/tests/test_sandbox_host.py | 461 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …y/experimental/sandbox/http/tests/test_sandbox_host.py | 463 | # ---------------------------------------------------------------------- | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 27 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 29 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 126 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 128 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 179 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 181 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 399 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 401 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 440 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | python/ray/experimental/raysort/main.py | 442 | # ------------------------------------------------------------ | COMMENT |
| MEDIUM | …y/llm/_internal/batch/benchmark/benchmark_processor.py | 458 | # ----------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …y/llm/_internal/batch/benchmark/benchmark_processor.py | 460 | # ----------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …y/llm/_internal/batch/benchmark/benchmark_processor.py | 551 | # ----------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …y/llm/_internal/batch/benchmark/benchmark_processor.py | 553 | # ----------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/interactive.py | 47 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/interactive.py | 49 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/interactive.py | 57 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/interactive.py | 59 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/interactive.py | 799 | # ============================================================================ | COMMENT |
| MEDIUM⚡ | python/ray/llm/_internal/serve/benchmark/interactive.py | 801 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/interactive.py | 87 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/interactive.py | 89 | # ============================================================================ | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/benchmark/interactive.py | 166 | # ============================================================================ | COMMENT |
| 827 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 87 | CODE | |
| LOW | python/ray/__init__.py | 108 | CODE | |
| LOW | python/ray/__init__.py | 108 | CODE | |
| LOW | python/ray/__init__.py | 108 | CODE | |
| LOW | python/ray/__init__.py | 108 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 114 | CODE | |
| LOW | python/ray/__init__.py | 132 | CODE | |
| LOW | python/ray/__init__.py | 137 | CODE | |
| LOW | python/ray/__init__.py | 140 | CODE | |
| LOW | python/ray/__init__.py | 140 | CODE | |
| LOW | python/ray/__init__.py | 141 | CODE | |
| LOW | python/ray/__init__.py | 142 | CODE | |
| LOW | python/ray/__init__.py | 143 | CODE | |
| LOW | python/ray/__init__.py | 147 | CODE | |
| LOW | python/ray/__init__.py | 147 | CODE | |
| LOW | python/ray/__init__.py | 283 | CODE | |
| LOW | python/ray/__init__.py | 284 | CODE | |
| LOW | python/ray/__init__.py | 285 | CODE | |
| LOW | python/ray/cross_language.py | 1 | CODE | |
| LOW | python/ray/cross_language.py | 1 | CODE | |
| LOW | python/ray/cross_language.py | 1 | CODE | |
| LOW | python/ray/runtime_env/__init__.py | 1 | CODE | |
| LOW | python/ray/runtime_env/__init__.py | 1 | CODE | |
| LOW | python/ray/experimental/queue.py | 3 | CODE | |
| LOW | python/ray/experimental/queue.py | 3 | CODE | |
| LOW | python/ray/experimental/queue.py | 3 | CODE | |
| LOW | python/ray/experimental/__init__.py | 1 | CODE | |
| LOW | python/ray/experimental/__init__.py | 2 | CODE | |
| LOW | python/ray/experimental/__init__.py | 2 | CODE | |
| LOW | python/ray/experimental/__init__.py | 3 | CODE | |
| LOW | python/ray/experimental/__init__.py | 3 | CODE | |
| LOW | python/ray/experimental/__init__.py | 3 | CODE | |
| 2626 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | .vale.ini | 21 | Google.Headings = No | COMMENT |
| LOW | .vale.ini | 61 | # Not enforced yet, same as the KubeRay block above: Vale never runs these in CI. | COMMENT |
| LOW | .vale.ini | 81 | # Not enforced yet, same as the KubeRay and RLlib blocks above: Vale never runs these in | COMMENT |
| LOW | .readthedocs.yaml | 1 | # .readthedocs.yaml | COMMENT |
| LOW | .readthedocs.yaml | 21 | # Code sources (python/ray/) are intentionally not matched, so a | COMMENT |
| LOW | .readthedocs.yaml | 61 | # config value differs between the environment that produced the cache and | COMMENT |
| LOW | .readthedocs.yaml | 81 | # Only the retry count is raised. The observed failures are immediate 502 | COMMENT |
| LOW | .readthedocs.yaml | 101 | # Most of that memory was a leak: MyST {eval-rst} blocks pickled the whole | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 1 | --extra-index-url https://download.pytorch.org/whl/cpu | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 21 | # via | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 41 | # via | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 61 | # via -r python/requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 81 | # via moto | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 101 | # via jupyter-server | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 121 | # via -r python/requirements/test-requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 141 | aws-sam-translator==1.98.0 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 161 | # azure-identity | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 181 | azure-mgmt-network==29.0.0 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 201 | # -r python/requirements/ml/tune-requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 221 | # semgrep | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 241 | # moto | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 261 | # via | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 281 | cfgv==3.5.0 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 301 | # dask | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 321 | clickhouse-connect==0.15.1 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 341 | # via | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 361 | # via -r python/requirements/ml/data-test-requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 381 | # jwcrypto | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 401 | dask==2026.3.0 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 421 | # tensorflow-probability | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 441 | # via | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 461 | # via pymongo | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 481 | # array-record | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 501 | # mlflow-skinny | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 521 | # torch | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 541 | # via | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 561 | # modin | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 581 | # mlflow-skinny | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 601 | # via | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 621 | # via -r python/requirements/ml/data-test-requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 641 | # via | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 661 | # via alive-progress | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 681 | # -r python/requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 701 | gsutil==5.27 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 721 | # via gradio | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 741 | # oauth2client | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 761 | # datasets | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 781 | # jsonschema | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 801 | # via prophet | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 821 | # azure-mgmt-resource | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 841 | # -r python/requirements/test-requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 861 | # botocore | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 881 | # jsonschema | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 901 | # openapi-schema-validator | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 921 | # via | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 941 | # -r python/requirements/test-requirements.txt | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 961 | # via openapi-spec-validator | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 981 | # via | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 1001 | markdown-it-py==2.2.0 | COMMENT |
| LOW | python/requirements_compiled_py3.14.txt | 1021 | # zoopt | COMMENT |
| 2889 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | python/setup.py | 636 | # Create the target directory if it doesn't already exist. | COMMENT |
| MEDIUM | python/ray/cluster_utils.py | 172 | # Create a new global state accessor for fetching GCS table. | COMMENT |
| MEDIUM | python/ray/actor.py | 1284 | # Create an instance without __init__ called. | COMMENT |
| MEDIUM | python/ray/runtime_env/runtime_env.py | 160 | """This class is used to define a runtime environment for a job, task, | STRING |
| MEDIUM | python/ray/experimental/shuffle.py | 42 | """This class is used to stream shuffle map outputs to the object store. | STRING |
| MEDIUM | …thon/ray/experimental/channel/shared_memory_channel.py | 720 | # Create a local channel for the writer and the local readers. | COMMENT |
| MEDIUM | python/ray/experimental/channel/common.py | 36 | """This function is only useful when f contains channel read/write. | STRING |
| MEDIUM | …perimental/channel/torch_tensor_accelerator_channel.py | 136 | # Create a CPU channel to send non-tensor data. | COMMENT |
| MEDIUM | python/ray/experimental/rdt/cuda_ipc_transport.py | 77 | # Create an interprocess-shareable CUDA event so that the receiver | COMMENT |
| MEDIUM | python/ray/llm/_internal/common/utils/cloud_utils.py | 530 | # Create a single cache instance for this function | COMMENT |
| MEDIUM | python/ray/llm/_internal/common/utils/download_utils.py | 278 | # Create the torch cache kernels directory if it doesn't exist. | COMMENT |
| MEDIUM | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 145 | # Create the adlfs filesystem | COMMENT |
| MEDIUM | …/ray/llm/_internal/batch/stages/sglang_engine_stage.py | 264 | # Create an LLM engine. | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/core/ingress/ingress.py | 211 | # Create a new class that inherits from the original to avoid modifying it | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/core/ingress/utils.py | 118 | # Create a new generator that yields the peeked item first | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/utils/registry.py | 74 | # Create a loader callable that imports on demand | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/utils/registry.py | 100 | # Create a registry for a component category | STRING |
| MEDIUM | python/ray/llm/_internal/serve/utils/registry.py | 151 | # Create a loader callable (handles both direct values and string paths) | COMMENT |
| MEDIUM⚡ | …_internal/serve/observability/usage_telemetry/usage.py | 83 | """This method is only used in tests to record the telemetry tags to a different | STRING |
| MEDIUM⚡ | …_internal/serve/observability/usage_telemetry/usage.py | 88 | """This method is only used in tests to clean up the models list.""" | STRING |
| MEDIUM | python/ray/llm/tests/conftest.py | 244 | # Create a vLLM serve deployment | STRING |
| MEDIUM | python/ray/llm/tests/common/cloud/test_s3_filesystem.py | 344 | # Create a test file | COMMENT |
| MEDIUM⚡ | python/ray/llm/tests/common/cloud/test_s3_filesystem.py | 365 | # Create a test file | COMMENT |
| MEDIUM | …y/llm/tests/batch/gpu/stages/test_vllm_engine_stage.py | 27 | # Create a mock instance that will be returned by the wrapper class | COMMENT |
| MEDIUM | …/tests/batch/gpu/stages/test_serve_deployment_stage.py | 69 | # Create a mock response that will be returned directly | COMMENT |
| MEDIUM | …llm/tests/batch/gpu/stages/test_sglang_engine_stage.py | 23 | # Create a mock instance that will be returned by the wrapper class | COMMENT |
| MEDIUM | …llm/tests/batch/gpu/stages/test_sglang_engine_stage.py | 90 | # Create a mock SGLang output | COMMENT |
| MEDIUM | …llm/tests/batch/gpu/stages/test_sglang_engine_stage.py | 265 | # Create a task type that doesn't exist in the prepare_llm_request method | COMMENT |
| MEDIUM | …/llm/tests/batch/cpu/stages/test_http_request_stage.py | 99 | # Create a fake session | COMMENT |
| MEDIUM⚡ | python/ray/llm/tests/serve/conftest.py | 124 | # Create a mock audio file for testing | COMMENT |
| MEDIUM⚡ | python/ray/llm/tests/serve/conftest.py | 129 | # Create a simple mock audio file (WAV format) | COMMENT |
| MEDIUM | …llm/tests/serve/cpu/deployments/routers/test_router.py | 551 | # Create a mock deployment handle that captures raw_request_info | COMMENT |
| MEDIUM | …llm/tests/serve/cpu/deployments/routers/test_router.py | 587 | # Create a mock FastAPI request | COMMENT |
| MEDIUM | …e/cpu/deployments/routers/test_make_fastapi_ingress.py | 29 | # Create the ingress class - should not raise | COMMENT |
| MEDIUM | …llm/tests/serve/cpu/deployments/llm/test_llm_server.py | 335 | # Create a server with a mocked engine | COMMENT |
| MEDIUM | …llm/tests/serve/cpu/deployments/llm/test_llm_server.py | 358 | # Create a server with a mocked engine | COMMENT |
| MEDIUM | …llm/tests/serve/cpu/deployments/llm/test_llm_server.py | 381 | # Create a server with a mocked engine | COMMENT |
| MEDIUM | …llm/tests/serve/cpu/deployments/llm/test_llm_server.py | 404 | # Create a server with a mocked engine | COMMENT |
| MEDIUM | …llm/tests/serve/cpu/deployments/llm/test_llm_server.py | 435 | # Create a chat completion request | COMMENT |
| MEDIUM | …loyments/llm/vllm/kv_transfer_backends/test_factory.py | 40 | # Create a Serve deployment that will run in a different process than the | COMMENT |
| MEDIUM | …/cpu/deployments/llm/multiplex/test_multiplex_utils.py | 32 | # Create a mock that raises ValueError twice then succeeds | COMMENT |
| MEDIUM | …/cpu/deployments/llm/multiplex/test_multiplex_utils.py | 52 | # Create a mock that always raises ValueError | COMMENT |
| MEDIUM | …/cpu/deployments/llm/multiplex/test_multiplex_utils.py | 74 | # Create a mock that raises TypeError | COMMENT |
| MEDIUM | …/cpu/deployments/llm/multiplex/test_multiplex_utils.py | 96 | # Create a mock that always raises ValueError | COMMENT |
| MEDIUM | …/cpu/deployments/llm/multiplex/test_multiplex_utils.py | 121 | # Create a mock that always raises ValueError | COMMENT |
| MEDIUM⚡ | …/cpu/deployments/llm/multiplex/test_multiplex_utils.py | 146 | # Define a function with docstring and name | COMMENT |
| MEDIUM | …pu/deployments/llm/multiplex/test_lora_model_loader.py | 56 | # Create a simple mock for sync_model | COMMENT |
| MEDIUM | …pu/deployments/llm/multiplex/test_lora_model_loader.py | 93 | # Create a mock for sync_files_with_lock that tracks calls and fails initially | COMMENT |
| MEDIUM | …pu/deployments/llm/multiplex/test_lora_model_loader.py | 140 | # Create a mock for sync_files_with_lock that tracks calls and fails initially | COMMENT |
| MEDIUM | …lm/tests/serve/cpu/deployments/utils/test_broadcast.py | 11 | # Define a simple deployment for testing | COMMENT |
| MEDIUM | python/ray/util/tracing/setup_tempo_tracing.py | 1 | # This file is intended for examples exporting traces to a local OTLP listener | COMMENT |
| MEDIUM | …ective/collective_group/torch_gloo_collective_group.py | 106 | # Create a subgroup for this logical group. For the default group, use WORLD. | COMMENT |
| MEDIUM | python/ray/util/state/state_cli.py | 253 | # Create a table. | STRING |
| MEDIUM | python/ray/util/state/state_cli.py | 296 | # Create a table per callsite. | STRING |
| MEDIUM | python/ray/util/state/state_cli.py | 453 | # Create the State API server and put it into context | STRING |
| MEDIUM | python/ray/util/state/state_cli.py | 604 | # Create the State API server and put it into context | STRING |
| MEDIUM | python/ray/_common/tests/test_usage_stats.py | 1551 | # Create a mock response based on the URL. | COMMENT |
| MEDIUM | python/ray/_common/tests/test_signature.py | 95 | # Create a mock Cython function missing required attributes | COMMENT |
| MEDIUM | python/ray/_common/observability/__init__.py | 1 | """This module provides the Python API for emitting internal Ray events | STRING |
| MEDIUM | python/ray/dag/compiled_dag_node.py | 1660 | # Create an output channel for each output of the current node. | STRING |
| 741 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/ray/remote_function.py | 203 | Configures and overrides the task invocation parameters. The arguments are the same as those that can be passed | STRING |
| HIGH | python/ray/cluster_utils.py | 352 | Waits for correct number of nodes to be registered. This will wait until the number of live nodes in the client | STRING |
| HIGH | python/ray/actor.py | 948 | Convenience method for executing an actor method call with options. Same arguments as func._remote(), but retur | STRING |
| HIGH | python/ray/actor.py | 1732 | Configures and overrides the actor instantiation parameters. The arguments are the same as those that can be pa | STRING |
| HIGH | python/ray/actor.py | 2611 | Handle dynamic attribute access for actor methods. This method is called when accessing attributes that don't e | STRING |
| HIGH | python/ray/actor.py | 2844 | Run a closure remotely on this actor instance. Provides a standard way to execute an arbitrary callable on | STRING |
| HIGH | python/ray/job_config.py | 282 | Generates a JobConfig object from json. Examples: .. testcode:: from ray.job_confi | STRING |
| HIGH | python/ray/experimental/locations.py | 10 | Lookup the locations for a list of objects. It returns a dict maps from an object to its location. The dict exclude | STRING |
| HIGH | python/ray/experimental/locations.py | 48 | Lookup the locations for a list of objects *from the local core worker*. No RPCs are made in this method. It re | STRING |
| HIGH | python/ray/experimental/sandbox/image_manager.py | 285 | Path of the cached image's EROFS root filesystem. Args: image: Container image name or tar path. | STRING |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 268 | Resolve ``rel`` under ``root`` the way a sandbox rooted there would. Every symlink met along the way is followed wi | STRING |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 949 | Flatten ``image`` into ``rootfs_dir`` and return its recorded owners. ``image`` is a local tar archive or a registr | STRING |
| HIGH | python/ray/experimental/sandbox/backend/gvisor.py | 303 | Turn ``user`` into the numeric ``uid[:gid]`` form runsc exec accepts. Names resolve against the ``/etc/passwd`` | STRING |
| HIGH | python/ray/experimental/rdt/tensor_transport_manager.py | 224 | Wait for a previously initiated fetch to complete and return the tensors. The default implementation returns th | STRING |
| HIGH | python/ray/experimental/rdt/rdt_manager.py | 903 | Fetch and get RDT objects for a list of object IDs, pipelining async fetches. This is used in the ray. | STRING |
| HIGH | python/ray/experimental/rdt/nixl_tensor_transport.py | 558 | Waits for a previously initiated fetch to complete and returns the tensors. Args: fetch_request: Th | STRING |
| HIGH | python/ray/experimental/rdt/nixl_memory_pool.py | 214 | Pack tensors into as few contiguous pool blocks as possible. Copies only each tensor's own bytes (numel * eleme | STRING |
| HIGH | python/ray/llm/_internal/common/utils/cloud_utils.py | 148 | Get the appropriate provider-specific filesystem class based on URI. Args: bucket_uri: URI of the c | STRING |
| HIGH | python/ray/llm/_internal/common/utils/import_utils.py | 11 | Try importing the module and returns the module (or None). Args: name: The name of the module to import. | STRING |
| HIGH | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 45 | Parse S3 URI into bucket and key. Args: uri: S3 URI (e.g., s3://bucket/path/to/object or s3://anony | STRING |
| HIGH | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 81 | Create an Azure filesystem for Azure Blob Storage or ABFSS. Args: object_uri: Azure URI (azure://co | STRING |
| HIGH | python/ray/llm/_internal/batch/benchmark/dataset.py | 45 | Sample prompts from the loaded dataset. Args: num_requests: The number of prompts to sampl | STRING |
| HIGH | python/ray/llm/_internal/batch/stages/base.py | 107 | A stage UDF wrapper that processes the input and output columns before and after the UDF. The expected | STRING |
| HIGH | python/ray/llm/_internal/batch/processor/base.py | 78 | Return a normalized dict of worker pool parameters from `self.concurrency`. Behavior: - If `concurrency | STRING |
| HIGH | …rnal/serve/serving_patterns/data_parallel/dp_server.py | 72 | Retrieve the DP master info for gang_id, polling until available. Args: gang_id: The ID of the gang | STRING |
| HIGH | python/ray/llm/_internal/serve/core/ingress/ingress.py | 178 | Create a Ray Serve ingress deployment from a class and endpoint mapping. Args: cls: The class to conve | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 59 | Run a ChatCompletion with the engine. To implement this method, you need to take a openAI compatible chat reque | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 88 | Run a Completion with the engine. Similar to chat, this method is an async generator, so it yields chunks | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 149 | Run a Transcription with the engine. Similar to chat and completion, this method is an async generator, | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 181 | Tokenize the input text. This method tokenizes the input prompt or chat messages and returns the token | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 205 | Detokenize the input token IDs. This method converts token IDs back into text. Args: reque | STRING |
| HIGH | python/ray/llm/_internal/serve/utils/registry.py | 52 | Create a loader callable for a value. Handles both direct objects/classes and string paths for lazy loading. A | STRING |
| HIGH | python/ray/llm/_internal/serve/utils/registry.py | 126 | Register a component. Args: name: The name to register under value: The component to re | STRING |
| HIGH | python/ray/llm/_internal/serve/utils/registry.py | 176 | Get a registered component. Args: name: The name of the component Returns: The | STRING |
| HIGH | …lm/_internal/serve/engines/vllm/kv_transfer/factory.py | 57 | Get the connector backend class by name. For registered connectors, returns the registered backend class. | STRING |
| HIGH | …rnal/serve/routing_policies/kv_aware/vllm/tokenizer.py | 134 | Tokenize a request ``payload`` into prompt token IDs. Args: payload: The request body, already pars | STRING |
| HIGH | …e/routing_policies/prefix_aware/prefix_aware_router.py | 135 | Extracts the text content from a pending request for prefix matching. Searches through request arguments for ei | STRING |
| HIGH | python/ray/util/queue.py | 156 | Gets an item from the queue. If block is True and the queue is empty, blocks until the queue is no long | STRING |
| HIGH | python/ray/util/queue.py | 193 | Gets an item from the queue. There is no guarantee of order if multiple consumers get from the same emp | STRING |
| HIGH | python/ray/util/queue.py | 261 | Gets items from the queue and returns them in a list in order. Args: num_items: Number of i | STRING |
| HIGH | python/ray/util/iter.py | 86 | Create a parallel iterator from a list of iterables. An iterable can be a conatiner (list, str, tuple, set, etc.), | STRING |
| HIGH | python/ray/util/iter.py | 233 | Remotely transform the iterator. This is advanced version of for_each that allows you to apply arbitrary | STRING |
| HIGH | python/ray/util/iter.py | 266 | Remotely apply fn to each item in this iterator. If `max_concurrency` == 1 then `fn` will be executed serially | STRING |
| HIGH | python/ray/util/iter.py | 310 | Remotely filter items from this iterator. Args: fn: returns False for items to drop from the iterat | STRING |
| HIGH | python/ray/util/iter.py | 327 | Remotely batch together items in this iterator. Args: n: Number of items to batch together. | STRING |
| HIGH | python/ray/util/iter.py | 367 | Remotely shuffle items of each shard independently Args: shuffle_buffer_size: The algorithm fills a | STRING |
| HIGH | python/ray/util/iter.py | 404 | Returns a new ParallelIterator instance with num_partitions shards. The new iterator contains the same data in | STRING |
| HIGH | python/ray/util/iter.py | 558 | Returns a local iterable for asynchronous iteration. New items will be fetched from the shards asynchronously a | STRING |
| HIGH | python/ray/util/placement_group.py | 137 | Asynchronously creates a PlacementGroup. Args: bundles: A list of bundles which represent the r | STRING |
| HIGH | python/ray/util/tpu.py | 42 | Extracts the version from the accelerator type. Args: accelerator_type: The full accelerator type string (e | STRING |
| HIGH | python/ray/util/tpu.py | 977 | Run a remote function on every host in a TPU slice. Dispatches one task per host in the slice, pinning each task to | STRING |
| HIGH | python/ray/util/tpu.py | 2160 | Asynchronously creates a PlacementGroup for a TPU subslice. A subslice placement group reserves a contiguous subset | STRING |
| HIGH | python/ray/util/actor_pool.py | 220 | Returns the next pending result in order. This returns the next result produced by submit(), blocking for up to | STRING |
| HIGH | python/ray/util/actor_pool.py | 288 | Returns any of the next pending results. This returns some result produced by submit(), blocking for up to | STRING |
| HIGH | python/ray/util/annotations.py | 34 | Annotation for documenting public APIs. Public APIs are classes and methods exposed to end users of Ray. If `` | STRING |
| HIGH | python/ray/util/annotations.py | 108 | Annotation for documenting developer APIs. Developer APIs are lower-level methods explicitly exposed to advanced Ra | STRING |
| HIGH | python/ray/util/annotations.py | 168 | Annotation for documenting a deprecated API. Deprecated APIs may be removed in future releases of Ray. Args: | STRING |
| HIGH | python/ray/util/dask/scheduler_utils.py | 48 | Start state from a dask. Args: dsk: A dask dictionary specifying a workflow. cache: Temporary stora | STRING |
| HIGH | python/ray/util/dask/scheduler_utils.py | 196 | Get nested index from collection. Args: ind: Index or nested list of indices. coll: Collection to i | STRING |
| HIGH | python/ray/util/state/state_manager.py | 86 | Apply the network error handling logic to each APIs, such as retry or exception policies. Args: | STRING |
| 385 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/setup.py | 19 | except ImportError: | CODE |
| HIGH | python/ray/setup-dev.py | 56 | except FileNotFoundError: | CODE |
| HIGH | python/ray/exceptions.py | 834 | except Exception: | CODE |
| HIGH | python/ray/actor.py | 2480 | except AttributeError: | CODE |
| HIGH | python/ray/actor.py | 1996 | except ValueError: # Name is not taken. | CODE |
| HIGH | python/ray/actor.py | 1924 | except ActorAlreadyExistsError: | CODE |
| HIGH | python/ray/experimental/collective/collective.py | 193 | except ray.exceptions.ActorDiedError: | CODE |
| HIGH | python/ray/experimental/channel/common.py | 482 | except ray.exceptions.RayChannelTimeoutError: | CODE |
| HIGH | python/ray/experimental/sandbox/runtime.py | 133 | except Exception: | CODE |
| HIGH | python/ray/experimental/sandbox/sandbox.py | 72 | except Exception: | CODE |
| HIGH | python/ray/experimental/sandbox/sandbox.py | 95 | except Exception: | CODE |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 567 | except OSError: | CODE |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 698 | except OSError: | CODE |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 490 | except OSError: | CODE |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 597 | except OSError: | CODE |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 639 | except OSError: | CODE |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 938 | except Exception: | CODE |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 440 | except OSError: | CODE |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 785 | except OSError: | CODE |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 816 | except OSError: | CODE |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 408 | except OSError: | CODE |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 394 | except OSError: | CODE |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 454 | except OSError: | CODE |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 375 | except OSError: | CODE |
| HIGH | …thon/ray/experimental/sandbox/_internal/image_utils.py | 471 | except OSError: | CODE |
| HIGH | python/ray/experimental/sandbox/backend/gvisor.py | 508 | except subprocess.TimeoutExpired: | CODE |
| HIGH | python/ray/experimental/sandbox/backend/gvisor.py | 587 | except (subprocess.TimeoutExpired, ValueError): | CODE |
| HIGH | python/ray/experimental/sandbox/backend/gvisor.py | 271 | except subprocess.TimeoutExpired: | CODE |
| HIGH | python/ray/experimental/sandbox/backend/gvisor.py | 285 | except Exception: | CODE |
| HIGH | python/ray/experimental/sandbox/http/host.py | 451 | except asyncio.TimeoutError: | CODE |
| HIGH | python/ray/experimental/sandbox/http/host.py | 557 | except asyncio.TimeoutError: | CODE |
| HIGH | python/ray/experimental/sandbox/http/app.py | 420 | except _ApiError: | CODE |
| HIGH | …y/experimental/sandbox/http/tests/test_modal_client.py | 90 | except asyncio.TimeoutError: | CODE |
| HIGH | python/ray/experimental/rdt/util.py | 113 | except ImportError: | CODE |
| HIGH | python/ray/experimental/rdt/rdt_manager.py | 442 | except ValueError: | CODE |
| HIGH | python/ray/experimental/rdt/rdt_manager.py | 954 | except TimeoutError: | CODE |
| HIGH | python/ray/experimental/rdt/rdt_store.py | 135 | except AssertionError: | CODE |
| HIGH | python/ray/llm/_internal/common/errors.py | 13 | except ImportError: | CODE |
| HIGH | python/ray/llm/_internal/common/errors.py | 24 | except ImportError: | CODE |
| HIGH | python/ray/llm/_internal/common/utils/lora_utils.py | 63 | except FileNotFoundError: | CODE |
| HIGH | …nal/serve/serving_patterns/prefill_decode/pd_server.py | 480 | except asyncio.CancelledError: | CODE |
| HIGH | python/ray/llm/_internal/serve/utils/batcher.py | 109 | except asyncio.QueueEmpty: | CODE |
| HIGH | python/ray/llm/_internal/serve/utils/batcher.py | 70 | except asyncio.TimeoutError: | CODE |
| HIGH | …y/llm/tests/batch/gpu/stages/test_vllm_engine_stage.py | 903 | except Exception: | CODE |
| HIGH | …rve/gpu/deployments/llm/vllm/test_config_congruence.py | 119 | except Exception: | CODE |
| HIGH | …rve/gpu/deployments/llm/vllm/test_config_congruence.py | 173 | except Exception: | CODE |
| HIGH | …rve/gpu/deployments/llm/vllm/test_config_congruence.py | 71 | except Exception: | CODE |
| HIGH | …tests/serve/cpu/deployments/llm/test_llm_engine_tpu.py | 122 | except Exception: | CODE |
| HIGH | …tests/serve/cpu/deployments/llm/test_llm_engine_tpu.py | 229 | except Exception: | CODE |
| HIGH | …tests/serve/cpu/deployments/llm/test_llm_engine_tpu.py | 55 | except Exception: | CODE |
| HIGH | …tests/serve/cpu/deployments/llm/test_llm_engine_tpu.py | 95 | except Exception: | CODE |
| HIGH | …loyments/llm/vllm/kv_transfer_backends/test_factory.py | 62 | except RuntimeError: | CODE |
| HIGH | …lm/tests/serve/cpu/deployments/utils/test_broadcast.py | 145 | except Exception: | CODE |
| HIGH | python/ray/util/iter.py | 1282 | except StopIteration: | CODE |
| HIGH | python/ray/util/iter.py | 472 | except StopIteration: | CODE |
| HIGH | python/ray/util/iter.py | 623 | except StopIteration: | CODE |
| HIGH | python/ray/util/check_serialize.py | 232 | except Exception: | CODE |
| HIGH | python/ray/util/tpu.py | 1250 | except Exception: | CODE |
| HIGH | python/ray/util/actor_pool.py | 91 | except TimeoutError: | CODE |
| HIGH | python/ray/util/actor_pool.py | 141 | except TimeoutError: | CODE |
| 326 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/client_builder.py | 367 | except Exception as e: | CODE |
| MEDIUM | python/ray/setup-dev.py | 146 | print("Error: --skip and --allow cannot be used together.") | CODE |
| LOW | python/ray/exceptions.py | 51 | except Exception: | CODE |
| LOW | python/ray/exceptions.py | 314 | except Exception as e: | CODE |
| LOW | python/ray/exceptions.py | 834 | except Exception: | CODE |
| LOW | python/ray/actor.py | 1646 | except Exception as e: | CODE |
| MEDIUM | python/ray/actor.py | 1643 | def __init__(self, *args, **kwargs): | CODE |
| LOW | python/ray/experimental/shuffle.py | 319 | except Exception: | CODE |
| LOW | python/ray/experimental/compiled_dag_ref.py | 139 | except Exception as execution_error: | CODE |
| LOW | python/ray/experimental/compiled_dag_ref.py | 145 | except Exception: | CODE |
| LOW | python/ray/experimental/sandbox/image_manager.py | 333 | except Exception as err: | CODE |
| LOW | python/ray/experimental/sandbox/runtime.py | 133 | except Exception: | CODE |
| LOW | python/ray/experimental/sandbox/sandbox.py | 72 | except Exception: | CODE |
| LOW | python/ray/experimental/sandbox/sandbox.py | 95 | except Exception: | CODE |
| MEDIUM | python/ray/experimental/sandbox/sandbox.py | 92 | def __del__(self): | CODE |
| LOW | …thon/ray/experimental/sandbox/_internal/image_utils.py | 234 | except Exception as auth_err: | CODE |
| LOW | …thon/ray/experimental/sandbox/_internal/image_utils.py | 239 | except Exception as err: | CODE |
| LOW | …thon/ray/experimental/sandbox/_internal/image_utils.py | 846 | except Exception as err: | CODE |
| LOW | …thon/ray/experimental/sandbox/_internal/image_utils.py | 904 | except Exception: | CODE |
| LOW | …thon/ray/experimental/sandbox/_internal/image_utils.py | 938 | except Exception: | CODE |
| LOW | …thon/ray/experimental/sandbox/_internal/image_utils.py | 973 | except Exception as err: | CODE |
| LOW | …thon/ray/experimental/sandbox/_internal/image_utils.py | 1051 | except Exception as e: | CODE |
| LOW | …thon/ray/experimental/sandbox/_internal/image_utils.py | 1072 | except Exception as err: | CODE |
| LOW | python/ray/experimental/sandbox/tests/conftest.py | 63 | except Exception as e: | CODE |
| LOW | python/ray/experimental/sandbox/tests/conftest.py | 80 | except Exception as e: | CODE |
| MEDIUM | …/ray/experimental/sandbox/tests/test_gvisor_backend.py | 728 | def run(sb, name): | CODE |
| LOW | …/ray/experimental/sandbox/tests/test_gvisor_backend.py | 733 | except Exception as exc: # surfaced in the main thread below | CODE |
| LOW | python/ray/experimental/sandbox/backend/gvisor.py | 154 | except Exception as err: | CODE |
| LOW | python/ray/experimental/sandbox/backend/gvisor.py | 176 | except Exception: | CODE |
| LOW | python/ray/experimental/sandbox/backend/gvisor.py | 218 | except Exception as e: | CODE |
| LOW | python/ray/experimental/sandbox/backend/gvisor.py | 232 | except Exception: | CODE |
| LOW | python/ray/experimental/sandbox/backend/gvisor.py | 285 | except Exception: | CODE |
| LOW | python/ray/experimental/sandbox/backend/gvisor.py | 408 | except Exception as err: | CODE |
| LOW | python/ray/experimental/sandbox/http/grpc_facade.py | 353 | except Exception as exc: | CODE |
| LOW | python/ray/experimental/sandbox/http/grpc_facade.py | 369 | except Exception as exc: | CODE |
| LOW | python/ray/experimental/sandbox/http/grpc_facade.py | 761 | except Exception as exc: | CODE |
| LOW | python/ray/experimental/sandbox/http/grpc_facade.py | 849 | except Exception: | CODE |
| LOW | python/ray/experimental/sandbox/http/grpc_facade.py | 982 | except Exception as exc: | CODE |
| LOW | python/ray/experimental/sandbox/http/host.py | 303 | except Exception as exc: | CODE |
| LOW | python/ray/experimental/sandbox/http/host.py | 338 | except Exception: | CODE |
| LOW | python/ray/experimental/sandbox/http/host.py | 375 | except Exception as exc: | CODE |
| LOW | python/ray/experimental/sandbox/http/host.py | 524 | except Exception as exc: | CODE |
| LOW | python/ray/experimental/sandbox/http/resolver.py | 182 | except Exception as exc: | CODE |
| LOW | python/ray/experimental/sandbox/http/app.py | 90 | except Exception as exc: | CODE |
| LOW | python/ray/experimental/sandbox/http/tests/conftest.py | 275 | except Exception as e: | CODE |
| LOW | python/ray/experimental/rdt/cuda_ipc_transport.py | 181 | except Exception as e: | CODE |
| LOW | python/ray/experimental/rdt/rdt_manager.py | 338 | except Exception as e: | CODE |
| LOW⚡ | python/ray/experimental/rdt/nixl_tensor_transport.py | 806 | except Exception: | CODE |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 75 | except Exception: | CODE |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 538 | except Exception: | CODE |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 605 | except Exception: | CODE |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 764 | except Exception as e: | CODE |
| LOW | python/ray/experimental/rdt/rdt_store.py | 92 | except Exception as e: | CODE |
| LOW | python/ray/experimental/rdt/rdt_store.py | 127 | except Exception: | CODE |
| LOW | python/ray/llm/_internal/common/callbacks/base.py | 109 | except Exception as e: | CODE |
| LOW | python/ray/llm/_internal/common/callbacks/base.py | 131 | except Exception as e: | CODE |
| LOW | python/ray/llm/_internal/common/utils/cloud_utils.py | 286 | except Exception as e: | CODE |
| LOW | python/ray/llm/_internal/common/utils/cloud_utils.py | 336 | except Exception as e: | CODE |
| LOW | python/ray/llm/_internal/common/utils/lora_utils.py | 127 | except Exception as e: | CODE |
| LOW | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 126 | except Exception as e: | CODE |
| 1566 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/ray/experimental/channel/cpu_communicator.py | 0 | return the given actor's rank in the group. args: actor: the actor handle to look up. returns: the rank of ``actor`` wit | STRING |
| HIGH | python/ray/experimental/channel/nccl_group.py | 0 | return the given actor's rank in the group. args: actor: the actor handle to look up. returns: the rank of ``actor`` wit | STRING |
| HIGH | python/ray/experimental/channel/communicator.py | 0 | return the given actor's rank in the group. args: actor: the actor handle to look up. returns: the rank of ``actor`` wit | STRING |
| HIGH | python/ray/llm/_internal/common/models.py | 0 | take a blocking function, and run it on in an executor thread. this function prevents the blocking function from blockin | STRING |
| HIGH | python/ray/llm/_internal/serve/utils/server_utils.py | 0 | take a blocking function, and run it on in an executor thread. this function prevents the blocking function from blockin | STRING |
| HIGH | release/llm_tests/serve/probes/util.py | 0 | take a blocking function, and run it on in an executor thread. this function prevents the blocking function from blockin | STRING |
| HIGH | python/ray/llm/_internal/common/utils/cloud_utils.py | 0 | download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8 | STRING |
| HIGH | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 0 | download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8 | STRING |
| HIGH | …ay/llm/_internal/common/utils/cloud_filesystem/base.py | 0 | download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8 | STRING |
| HIGH | …ternal/common/utils/cloud_filesystem/gcs_filesystem.py | 0 | download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8 | STRING |
| HIGH | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 0 | download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8 | STRING |
| HIGH | …rnal/common/utils/cloud_filesystem/azure_filesystem.py | 0 | download a file from cloud storage into memory. args: object_uri: uri of the file (abfss:// or azure://) decode_as_utf_8 | STRING |
| HIGH | python/ray/llm/_internal/common/utils/cloud_utils.py | 0 | list the immediate subfolders in a cloud directory. args: folder_uri: uri of the directory (s3://, gs://, abfss://, or a | STRING |
| HIGH | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 0 | list the immediate subfolders in a cloud directory. args: folder_uri: uri of the directory (s3://, gs://, abfss://, or a | STRING |
| HIGH | …ay/llm/_internal/common/utils/cloud_filesystem/base.py | 0 | list the immediate subfolders in a cloud directory. args: folder_uri: uri of the directory (s3://, gs://, abfss://, or a | STRING |
| HIGH | python/ray/llm/_internal/common/utils/cloud_utils.py | 0 | download files from cloud storage to a local directory. args: path: local directory where files will be downloaded bucke | STRING |
| HIGH | …ternal/common/utils/cloud_filesystem/gcs_filesystem.py | 0 | download files from cloud storage to a local directory. args: path: local directory where files will be downloaded bucke | STRING |
| HIGH | …rnal/common/utils/cloud_filesystem/azure_filesystem.py | 0 | download files from cloud storage to a local directory. args: path: local directory where files will be downloaded bucke | STRING |
| HIGH | …ay/llm/_internal/common/utils/cloud_filesystem/base.py | 0 | download files from cloud storage to a local directory. args: path: local directory where files will be downloaded bucke | STRING |
| HIGH | python/ray/llm/_internal/common/utils/cloud_utils.py | 0 | upload files to cloud storage. args: local_path: the local path of the files to upload. bucket_uri: the bucket uri to up | STRING |
| HIGH | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 0 | upload files to cloud storage. args: local_path: the local path of the files to upload. bucket_uri: the bucket uri to up | STRING |
| HIGH | …ay/llm/_internal/common/utils/cloud_filesystem/base.py | 0 | upload files to cloud storage. args: local_path: the local path of the files to upload. bucket_uri: the bucket uri to up | STRING |
| HIGH | …llm/_internal/common/observability/logging/__init__.py | 0 | get a structured logger inherited from the ray serve logger. loggers by default are logging to stdout, and are expected | STRING |
| HIGH | …/llm/_internal/batch/observability/logging/__init__.py | 0 | get a structured logger inherited from the ray serve logger. loggers by default are logging to stdout, and are expected | STRING |
| HIGH | …/llm/_internal/serve/observability/logging/__init__.py | 0 | get a structured logger inherited from the ray serve logger. loggers by default are logging to stdout, and are expected | STRING |
| HIGH | …ay/llm/_internal/common/observability/logging/setup.py | 0 | configures stdlib root logger to make sure stdlib loggers (created as `logging.getlogger(...)`) are using ray's `jsonfor | STRING |
| HIGH | …ray/llm/_internal/batch/observability/logging/setup.py | 0 | configures stdlib root logger to make sure stdlib loggers (created as `logging.getlogger(...)`) are using ray's `jsonfor | STRING |
| HIGH | …ray/llm/_internal/serve/observability/logging/setup.py | 0 | configures stdlib root logger to make sure stdlib loggers (created as `logging.getlogger(...)`) are using ray's `jsonfor | STRING |
| HIGH | …/ray/llm/_internal/batch/stages/sglang_engine_stage.py | 0 | the required input keys of the stage and their descriptions. | STRING |
| HIGH | …/ray/llm/_internal/batch/stages/chat_template_stage.py | 0 | the required input keys of the stage and their descriptions. | STRING |
| HIGH | …llm/_internal/batch/stages/prepare_multimodal_stage.py | 0 | the required input keys of the stage and their descriptions. | STRING |
| HIGH | …n/ray/llm/_internal/batch/stages/http_request_stage.py | 0 | the required input keys of the stage and their descriptions. | STRING |
| HIGH | …on/ray/llm/_internal/batch/stages/vllm_engine_stage.py | 0 | the required input keys of the stage and their descriptions. | STRING |
| HIGH | python/ray/llm/_internal/batch/stages/tokenize_stage.py | 0 | the required input keys of the stage and their descriptions. | STRING |
| HIGH | python/ray/llm/_internal/batch/stages/base.py | 0 | the required input keys of the stage and their descriptions. | STRING |
| HIGH | …/ray/llm/_internal/batch/stages/sglang_engine_stage.py | 0 | the optional input keys of the stage and their descriptions. | STRING |
| HIGH | …on/ray/llm/_internal/batch/stages/vllm_engine_stage.py | 0 | the optional input keys of the stage and their descriptions. | STRING |
| HIGH | python/ray/llm/_internal/batch/stages/base.py | 0 | the optional input keys of the stage and their descriptions. | STRING |
| HIGH | …ay/llm/_internal/batch/processor/sglang_engine_proc.py | 0 | construct a processor that runs a serve deployment. args: config: the configuration for the processor. preprocess: an op | STRING |
| HIGH | …/ray/llm/_internal/batch/processor/vllm_engine_proc.py | 0 | construct a processor that runs a serve deployment. args: config: the configuration for the processor. preprocess: an op | STRING |
| HIGH | …ray/llm/_internal/batch/processor/http_request_proc.py | 0 | construct a processor that runs a serve deployment. args: config: the configuration for the processor. preprocess: an op | STRING |
| HIGH | …llm/_internal/batch/processor/serve_deployment_proc.py | 0 | construct a processor that runs a serve deployment. args: config: the configuration for the processor. preprocess: an op | STRING |
| HIGH | python/ray/llm/_internal/serve/core/protocol.py | 0 | check the health of the engine. does not return anything. raise error when the engine is dead and needs to be restarted. | STRING |
| HIGH | …thon/ray/llm/_internal/serve/core/server/llm_server.py | 0 | check the health of the engine. does not return anything. raise error when the engine is dead and needs to be restarted. | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 0 | check the health of the engine. does not return anything. raise error when the engine is dead and needs to be restarted. | STRING |
| HIGH | python/ray/llm/_internal/serve/core/protocol.py | 0 | check whether the vllm engine is currently sleeping. returns: true if the engine is sleeping, false otherwise. | STRING |
| HIGH | …thon/ray/llm/_internal/serve/core/server/llm_server.py | 0 | check whether the vllm engine is currently sleeping. returns: true if the engine is sleeping, false otherwise. | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 0 | check whether the vllm engine is currently sleeping. returns: true if the engine is sleeping, false otherwise. | STRING |
| HIGH | …on/ray/llm/_internal/serve/engines/vllm/vllm_engine.py | 0 | check whether the vllm engine is currently sleeping. returns: true if the engine is sleeping, false otherwise. | STRING |
| HIGH | python/ray/llm/_internal/serve/core/protocol.py | 0 | check whether the vllm engine is currently paused. returns: true if the engine is paused, false otherwise. | STRING |
| HIGH | …thon/ray/llm/_internal/serve/core/server/llm_server.py | 0 | check whether the vllm engine is currently paused. returns: true if the engine is paused, false otherwise. | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 0 | check whether the vllm engine is currently paused. returns: true if the engine is paused, false otherwise. | STRING |
| HIGH | …on/ray/llm/_internal/serve/engines/vllm/vllm_engine.py | 0 | check whether the vllm engine is currently paused. returns: true if the engine is paused, false otherwise. | STRING |
| HIGH | …thon/ray/llm/_internal/serve/core/server/llm_server.py | 0 | execute a collective rpc call on all vllm workers. this is used for rlhf workflows where a trainer needs to execute meth | STRING |
| HIGH | python/ray/llm/_internal/serve/core/engine/protocol.py | 0 | execute a collective rpc call on all vllm workers. this is used for rlhf workflows where a trainer needs to execute meth | STRING |
| HIGH | …on/ray/llm/_internal/serve/engines/vllm/vllm_engine.py | 0 | execute a collective rpc call on all vllm workers. this is used for rlhf workflows where a trainer needs to execute meth | STRING |
| HIGH | python/ray/llm/tests/conftest.py | 0 | {% if messages[0]['role'] == 'system' %} {% set offset = 1 %} {% else %} {% set offset = 0 %} {% endif %} {{ bos_token } | STRING |
| HIGH | …llm/tests/batch/gpu/processor/test_vllm_engine_proc.py | 0 | {% if messages[0]['role'] == 'system' %} {% set offset = 1 %} {% else %} {% set offset = 0 %} {% endif %} {{ bos_token } | STRING |
| HIGH | release/llm_tests/batch/test_batch_sglang.py | 0 | {% if messages[0]['role'] == 'system' %} {% set offset = 1 %} {% else %} {% set offset = 0 %} {% endif %} {{ bos_token } | STRING |
| HIGH | python/ray/util/collective/collective.py | 0 | returns the ip address and a free port on this node. | STRING |
| 248 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH⚡ | …/ray/experimental/sandbox/tests/test_gvisor_backend.py | 449 | "touch /probe && chown 38:38 /probe && stat -c %u:%g /probe && " | CODE |
| HIGH⚡ | …/ray/experimental/sandbox/tests/test_gvisor_backend.py | 450 | "adduser -D -u 1234 alice && mkdir -p /srv/lists && touch /srv/lists/cfg && " | CODE |
| HIGH⚡ | …/ray/experimental/sandbox/tests/test_gvisor_backend.py | 451 | "chown -R alice:alice /srv/lists && stat -c %u:%g /srv/lists/cfg && " | CODE |
| HIGH⚡ | …/ray/experimental/sandbox/tests/test_gvisor_backend.py | 452 | "mkdir /srv/shared && chown 0:104 /srv/shared && chmod 2770 /srv/shared && " | CODE |
| HIGH⚡ | …/ray/experimental/sandbox/tests/test_gvisor_backend.py | 453 | "touch /srv/shared/post && stat -c %g /srv/shared/post", | CODE |
| HIGH⚡ | …/ray/experimental/sandbox/tests/test_gvisor_backend.py | 489 | "touch /x 2>/dev/null; test ! -e /x && echo ro && echo hi > /tmp/x && cat /tmp/x", | CODE |
| HIGH⚡ | …/ray/experimental/sandbox/tests/test_gvisor_backend.py | 489 | "touch /x 2>/dev/null; test ! -e /x && echo ro && echo hi > /tmp/x && cat /tmp/x", | CODE |
| HIGH | …/ray/experimental/sandbox/tests/test_gvisor_backend.py | 215 | "/bin/sh -c 'echo ws_ok > /workspace/ws.txt && cat /workspace/ws.txt'", | CODE |
| HIGH | …/ray/experimental/sandbox/tests/test_gvisor_backend.py | 275 | "echo ws_ok > /workspace/ws.txt && cat /workspace/ws.txt && " | CODE |
| HIGH | …/ray/experimental/sandbox/tests/test_gvisor_backend.py | 276 | "echo root_ok > /probe.txt && cat /probe.txt", | CODE |
| HIGH | …/ray/experimental/sandbox/tests/test_gvisor_backend.py | 787 | res = backend.exec_command(sb, "id -u && id -g", user="alice", timeout=30) | CODE |
| HIGH | python/ray/experimental/sandbox/backend/gvisor.py | 554 | "kill -0 $HOLDER 2>/dev/null || break; sleep 0.1; done; " | CODE |
| HIGH | python/ray/experimental/sandbox/backend/gvisor.py | 555 | f"NSPID=$(cat {netns_pidfile} 2>/dev/null); " | CODE |
| HIGH | python/ray/experimental/sandbox/backend/gvisor.py | 566 | "kill -0 $SLIRP 2>/dev/null || break; sleep 0.1; done; " | CODE |
| HIGH | …perimental/sandbox/http/tests/test_http_integration.py | 118 | "command": ["sh", "-c", "echo hello-from-sandbox && exit 4"], | CODE |
| HIGH | python/ray/llm/_internal/serve/core/ingress/router.py | 338 | if self._token_sender.push(token_endpoint, key, payload): | CODE |
| HIGH⚡ | …serve/cpu/deployments/routers/kv/test_token_channel.py | 81 | sender.push("not-a-valid-endpoint", "k", _payload([1, 2])) is False | CODE |
| HIGH | …serve/cpu/deployments/routers/kv/test_token_channel.py | 54 | if sender.push(endpoint, key, _payload(ids)): | CODE |
| HIGH | …serve/cpu/deployments/routers/kv/test_token_channel.py | 105 | assert sender.push(endpoint, "k", _payload([1, 2])) is False | CODE |
| HIGH | …serve/cpu/deployments/routers/kv/test_token_channel.py | 127 | if not sender.push(endpoint, f"k{i}", _payload([i] * 512)): | CODE |
| HIGH | python/ray/util/timer.py | 37 | self.push(time_delta) | CODE |
| HIGH | python/ray/util/actor_pool.py | 433 | >>> pool.push(a2) | STRING |
| HIGH | python/ray/util/dask/tests/test_dask_scheduler.py | 94 | assert sorted_with_pb.equals(sorted_without_pb) | CODE |
| HIGH⚡ | python/ray/tests/test_actor_pool.py | 263 | pool.push(a1) | CODE |
| HIGH⚡ | python/ray/tests/test_actor_pool.py | 264 | pool.push(a2) | CODE |
| HIGH⚡ | python/ray/tests/test_actor_pool.py | 271 | pool.push(a3) | CODE |
| HIGH | python/ray/tests/accelerators/test_neuron.py | 43 | b'"connected_to":null,"nc_count":2,' | CODE |
| HIGH⚡ | python/ray/tests/accelerators/test_neuron.py | 61 | b'"connected_to":null,"nc_count":2,' | CODE |
| HIGH⚡ | python/ray/tests/accelerators/test_neuron.py | 63 | b'{"neuron_device":1,"bdf":"00:1f.0","connected_to":null,' | CODE |
| HIGH | python/ray/tests/modin/modin_test_utils.py | 90 | and df1.columns.equals(df2.columns) | CODE |
| HIGH | python/ray/_private/thirdparty/tabulate/tabulate.py | 1941 | | spam || align="right"| 41.9999 | STRING |
| HIGH | python/ray/_private/thirdparty/tabulate/tabulate.py | 1943 | | eggs || align="right"| 451 | STRING |
| HIGH | python/ray/dashboard/modules/job/sdk.py | 485 | ... entrypoint="echo hi && sleep 5 && echo hi2") | STRING |
| HIGH | …on/ray/dashboard/modules/job/tests/test_job_manager.py | 1532 | entrypoint=f"{cmd} & {cmd} && wait && echo 'done'" | CODE |
| HIGH⚡ | …ay/dashboard/modules/job/tests/test_cli_integration.py | 203 | cmd = "sleep 1 && echo hello && sleep 1 && echo hello" | CODE |
| HIGH⚡ | …ay/dashboard/modules/job/tests/test_cli_integration.py | 213 | cmd = "echo hello && sleep 1000" | CODE |
| HIGH | …ay/dashboard/modules/job/tests/test_cli_integration.py | 274 | cmd = "echo hello && sleep 1000" | CODE |
| HIGH | …thon/ray/dashboard/modules/job/tests/test_job_agent.py | 189 | "python script.py && python -c 'import pip_install_test'" | STRING |
| HIGH | …ay/dashboard/modules/job/tests/test_http_job_server.py | 316 | "python script.py && python -c 'import pip_install_test'" | STRING |
| HIGH | …ay/dashboard/modules/job/tests/test_http_job_server.py | 538 | job_id = client.submit_job(entrypoint="sleep 300 && echo hello") | STRING |
| HIGH⚡ | …rllib/algorithms/tests/test_env_runner_state_server.py | 19 | server.push(state) | CODE |
| HIGH⚡ | …rllib/algorithms/tests/test_env_runner_state_server.py | 29 | server.push(_state(1)) | CODE |
| HIGH⚡ | …rllib/algorithms/tests/test_env_runner_state_server.py | 30 | server.push(_state(2)) | CODE |
| HIGH⚡ | …rllib/algorithms/tests/test_env_runner_state_server.py | 41 | server.push({"rl_module": "WEIGHTS_OBJ_REF"}) | CODE |
| HIGH⚡ | …rllib/algorithms/tests/test_env_runner_state_server.py | 53 | server.push(state) | CODE |
| HIGH⚡ | python/ray/rllib/utils/filter.py | 426 | rs.push(x[i]) | CODE |
| HIGH⚡ | python/ray/rllib/utils/filter.py | 427 | buffer.push(x[i]) | CODE |
| HIGH⚡ | python/ray/rllib/utils/filter.py | 430 | rs.push(x) | CODE |
| HIGH⚡ | python/ray/rllib/utils/filter.py | 431 | buffer.push(x) | CODE |
| HIGH | python/ray/rllib/utils/metrics/legacy_stats.py | 313 | self.push(time_delta_s) | CODE |
| HIGH | python/ray/rllib/utils/metrics/legacy_stats.py | 586 | self._throughput_stats.push(value / time_diff) | CODE |
| HIGH⚡ | python/ray/rllib/utils/metrics/window_stat.py | 14 | win_stats.push(5.0) | STRING |
| HIGH⚡ | python/ray/rllib/utils/metrics/window_stat.py | 15 | win_stats.push(7.0) | STRING |
| HIGH⚡ | python/ray/rllib/utils/metrics/window_stat.py | 16 | win_stats.push(7.0) | STRING |
| HIGH⚡ | python/ray/rllib/utils/metrics/window_stat.py | 17 | win_stats.push(10.0) | STRING |
| HIGH | python/ray/rllib/utils/metrics/metrics_logger.py | 438 | stats.push(value) | CODE |
| HIGH⚡ | python/ray/rllib/utils/metrics/tests/test_stats.py | 135 | tensor_stats_with_nan.push(tensor_val) | CODE |
| HIGH⚡ | python/ray/rllib/utils/metrics/tests/test_stats.py | 138 | tensor_stats_with_nan.push(nan_tensor_val) | CODE |
| HIGH⚡ | python/ray/rllib/utils/metrics/tests/test_stats.py | 152 | stats.push(value) | CODE |
| HIGH⚡ | python/ray/rllib/utils/metrics/tests/test_stats.py | 303 | incoming_stats.push(42) | CODE |
| 225 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | python/ray/client_builder.py | 78 | elif ray._private.worker.global_worker.node.is_head(): | CODE |
| CRITICAL | python/ray/experimental/locations.py | 40 | return ray._private.worker.global_worker.core_worker.get_object_locations( | CODE |
| CRITICAL | python/ray/_common/tests/test_usage_stats.py | 1090 | ray.worker.global_worker.gcs_client.cluster_id.hex(), | CODE |
| CRITICAL | python/ray/tests/test_job.py | 215 | from_worker = ray._private.worker.global_worker.core_worker.get_job_config() | STRING |
| CRITICAL | python/ray/tests/test_client_proxy.py | 173 | assert ray.util.client.ray.worker.log_client.log_thread.is_alive() | CODE |
| CRITICAL⚡ | python/ray/tests/test_advanced_7.py | 176 | assert not ray._private.worker.global_worker.core_worker.object_exists(x_id) | CODE |
| CRITICAL⚡ | python/ray/tests/test_advanced_7.py | 178 | assert ray._private.worker.global_worker.core_worker.object_exists(x_id) | CODE |
| CRITICAL⚡ | python/ray/tests/test_advanced_7.py | 182 | assert not ray._private.worker.global_worker.core_worker.object_exists(x_id) | CODE |
| CRITICAL⚡ | python/ray/tests/test_advanced_7.py | 185 | assert ray._private.worker.global_worker.core_worker.object_exists(x_id) | CODE |
| CRITICAL | python/ray/tests/test_advanced_7.py | 215 | assert ray._private.worker.global_worker.core_worker.object_exists( | CODE |
| CRITICAL | python/ray/tests/test_advanced_7.py | 253 | inlined = ray._private.worker.global_worker.core_worker.object_exists( | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting_standalone.py | 37 | lambda: ray._private.worker.global_worker.core_worker.object_exists(obj) | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting_standalone.py | 41 | lambda: not ray._private.worker.global_worker.core_worker.object_exists(obj) | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting_standalone.py | 325 | actual = ray._private.worker.global_worker.core_worker.get_all_reference_counts() | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting_standalone.py | 336 | len(ray._private.worker.global_worker.core_worker.get_all_reference_counts()) | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting_standalone.py | 345 | len(ray._private.worker.global_worker.core_worker.get_all_reference_counts()) | CODE |
| CRITICAL | python/ray/tests/test_runtime_env_working_dir.py | 705 | ray._private.worker.global_worker.core_worker.get_job_config().py_driver_sys_path | CODE |
| CRITICAL | python/ray/tests/test_state_api_log.py | 1363 | # log_dir = ray._private.worker.global_worker.node.get_logs_dir_path() | COMMENT |
| CRITICAL | python/ray/tests/test_state_api_log.py | 1398 | log_dir = ray._private.worker.global_worker.node.get_logs_dir_path() | CODE |
| CRITICAL | python/ray/tests/test_state_api_log.py | 1623 | log_dir = ray._private.worker.global_worker.node.get_logs_dir_path() | CODE |
| CRITICAL | python/ray/tests/test_state_api_log.py | 1898 | log_dir = ray._private.worker.global_worker.node.get_logs_dir_path() | CODE |
| CRITICAL | python/ray/tests/test_advanced_3.py | 173 | assert not ray._private.worker.global_worker.core_worker.object_exists(x_id) | CODE |
| CRITICAL | python/ray/tests/test_advanced_3.py | 418 | assert not ray._private.worker.global_worker.core_worker.object_exists( | STRING |
| CRITICAL | python/ray/tests/test_advanced.py | 213 | worker_id = ray._private.worker.global_worker.core_worker.get_worker_id().hex() | CODE |
| CRITICAL | python/ray/tests/test_advanced_8.py | 585 | job_config = ray._private.worker.global_worker.core_worker.get_job_config() | STRING |
| CRITICAL | python/ray/tests/test_advanced_8.py | 593 | job_config = ray._private.worker.global_worker.core_worker.get_job_config() | STRING |
| CRITICAL⚡ | python/ray/tests/test_memory_pressure.py | 98 | return ray._private.worker.global_worker.core_worker.get_worker_id().hex() | CODE |
| CRITICAL⚡ | python/ray/tests/test_memory_pressure.py | 101 | return ray._private.worker.global_worker.core_worker.get_actor_id().hex() | CODE |
| CRITICAL | python/ray/tests/test_generators.py | 364 | ray._private.worker.global_worker.core_worker.get_all_reference_counts() | CODE |
| CRITICAL | python/ray/tests/test_basic_2.py | 461 | assert not ray._private.worker.global_worker.core_worker.object_exists(obj_ref) | CODE |
| CRITICAL | python/ray/tests/test_basic_2.py | 478 | assert not ray._private.worker.global_worker.core_worker.object_exists(obj_ref) | CODE |
| CRITICAL | python/ray/tests/test_basic_2.py | 481 | assert ray._private.worker.global_worker.core_worker.object_exists(obj_ref) | CODE |
| CRITICAL | python/ray/tests/test_basic_2.py | 759 | + ray._private.worker.global_worker.current_job_id.hex().encode() | STRING |
| CRITICAL | python/ray/tests/test_basic_2.py | 763 | assert ray._private.worker.global_worker.gcs_client.internal_kv_exists( | STRING |
| CRITICAL | python/ray/tests/test_basic_2.py | 774 | + ray._private.worker.global_worker.current_job_id.hex().encode() | STRING |
| CRITICAL | python/ray/tests/test_basic_2.py | 778 | assert ray._private.worker.global_worker.gcs_client.internal_kv_exists( | STRING |
| CRITICAL | python/ray/tests/test_output.py | 228 | log_dir = ray._private.worker.global_worker.node.get_logs_dir_path() | CODE |
| CRITICAL | python/ray/tests/test_advanced_9.py | 121 | job_id = ray._private.worker.global_worker.current_job_id.hex().encode() | CODE |
| CRITICAL | python/ray/tests/test_advanced_9.py | 145 | job_id = ray._private.worker.global_worker.current_job_id.hex().encode() | CODE |
| CRITICAL | python/ray/tests/test_advanced_9.py | 158 | job_id = ray._private.worker.global_worker.current_job_id.hex().encode() | CODE |
| CRITICAL | python/ray/tests/test_streaming_generator_regression.py | 51 | ray._private.worker.global_worker.core_worker.reset_event_loop_executor( | CODE |
| CRITICAL | python/ray/tests/test_advanced_4.py | 214 | job_id = ray._private.worker.global_worker.current_job_id.hex().encode() | CODE |
| CRITICAL | python/ray/tests/test_advanced_4.py | 238 | job_id = ray._private.worker.global_worker.current_job_id.hex().encode() | CODE |
| CRITICAL | python/ray/tests/test_advanced_4.py | 251 | job_id = ray._private.worker.global_worker.current_job_id.hex().encode() | CODE |
| CRITICAL | python/ray/tests/test_reference_counting_2.py | 62 | lambda: ray._private.worker.global_worker.core_worker.object_exists(obj), | CODE |
| CRITICAL | python/ray/tests/test_reference_counting_2.py | 67 | lambda: not ray._private.worker.global_worker.core_worker.object_exists( | CODE |
| CRITICAL | python/ray/tests/test_serialization.py | 654 | assert ray._private.worker.global_worker.current_job_id.is_nil() | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting.py | 57 | lambda: ray._private.worker.global_worker.core_worker.object_exists(obj) | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting.py | 61 | lambda: not ray._private.worker.global_worker.core_worker.object_exists( | CODE |
| CRITICAL⚡ | python/ray/tests/test_reference_counting.py | 69 | actual = ray._private.worker.global_worker.core_worker.get_all_reference_counts() | CODE |
| CRITICAL | python/ray/tests/test_reference_counting.py | 315 | return not ray._private.worker.global_worker.core_worker.object_exists( | CODE |
| CRITICAL | python/ray/tests/aws/utils/helpers.py | 48 | return ray.autoscaler._private.aws.config.bootstrap_aws(config) | CODE |
| CRITICAL | python/ray/tests/rdt/test_rdt_nixl.py | 342 | lambda: ray._private.worker.global_worker.rdt_manager.get_rdt_metadata(obj_id) | CODE |
| CRITICAL | python/ray/tests/rdt/test_rdt_gloo.py | 849 | return ray._private.worker.global_worker.rdt_manager.rdt_store.get_num_objects() | CODE |
| CRITICAL | python/ray/tests/spark/test_basic.py | 192 | ray.util.spark.cluster_init._active_ray_cluster.shutdown() | CODE |
| CRITICAL | python/ray/tests/spark/test_basic.py | 441 | ray.util.spark.cluster_init._global_ray_cluster_cancel_event.set() | CODE |
| CRITICAL | python/ray/tests/spark/test_databricks_hook.py | 83 | ray.util.spark.cluster_init._active_ray_cluster.shutdown() | CODE |
| CRITICAL | python/ray/_private/serialization.py | 337 | ray._private.worker.global_worker.core_worker.add_object_ref_reference( | CODE |
| CRITICAL | …/ray/dashboard/modules/reporter/tests/test_reporter.py | 1618 | ray._private.worker.global_worker.node.get_session_dir_path() | CODE |
| CRITICAL | …on/ray/dashboard/modules/job/tests/test_job_manager.py | 943 | "job_config=ray._private.worker.global_worker.core_worker.get_job_config();" | CODE |
| 49 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/setup.py | 22 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/client_builder.py | 23 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/runtime_context.py | 13 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/__init__.py | 9 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/__init__.py | 175 | __all__ = [ | CODE |
| LOW | python/ray/remote_function.py | 33 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/cross_language.py | 9 | __all__ = [ | CODE |
| LOW | python/ray/cluster_utils.py | 20 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/exceptions.py | 23 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/actor.py | 66 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/job_config.py | 93 | def set_metadata(self, key: str, value: str) -> None: | CODE |
| LOW | python/ray/job_config.py | 171 | def set_ray_namespace(self, ray_namespace: str) -> None: | CODE |
| LOW | python/ray/job_config.py | 182 | def set_default_actor_lifetime(self, default_actor_lifetime: str) -> None: | CODE |
| LOW | python/ray/runtime_env/__init__.py | 3 | __all__ = [ | CODE |
| LOW | python/ray/runtime_env/runtime_env.py | 25 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/queue.py | 13 | __all__ = ["Empty", "Full", "Queue"] | CODE |
| LOW | python/ray/experimental/__init__.py | 18 | __all__ = [ | CODE |
| LOW | python/ray/experimental/tqdm_ray.py | 23 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/tqdm_ray.py | 216 | def update_offset(self, pos_offset: int) -> None: | CODE |
| LOW | python/ray/experimental/tqdm_ray.py | 246 | def update_bar(self, state: ProgressBarState) -> None: | CODE |
| LOW | python/ray/experimental/tqdm_ray.py | 267 | def update_offset(self, offset: int) -> None: | CODE |
| LOW | python/ray/experimental/collective/__init__.py | 13 | __all__ = [ | CODE |
| LOW | python/ray/experimental/collective/operations.py | 22 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/multiprocessing/__init__.py | 5 | __all__ = ["Pool", "TimeoutError"] | CODE |
| LOW | …thon/ray/experimental/channel/shared_memory_channel.py | 19 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/channel/torch_tensor_type.py | 14 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/channel/torch_tensor_type.py | 173 | def set_communicator_id(self, group_id: str) -> None: | CODE |
| LOW | python/ray/experimental/channel/__init__.py | 26 | __all__ = [ | CODE |
| LOW | python/ray/experimental/channel/nccl_group.py | 18 | logger = logging.getLogger(__name__) | CODE |
| LOW | …thon/ray/experimental/channel/serialization_context.py | 37 | def set_target_device(self, device: Device) -> None: | CODE |
| LOW | …thon/ray/experimental/channel/serialization_context.py | 40 | def set_data(self, channel_id: str, value: Any, num_readers: int) -> None: | CODE |
| LOW⚡ | …thon/ray/experimental/channel/serialization_context.py | 74 | def set_use_external_transport(self, use_external_transport: bool) -> None: | CODE |
| LOW | python/ray/experimental/channel/common.py | 116 | def set_communicator_id(self, group_id: str) -> None: | CODE |
| LOW | …perimental/channel/torch_tensor_accelerator_channel.py | 34 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/sandbox/image_manager.py | 20 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/sandbox/__init__.py | 117 | __all__ = [ | CODE |
| LOW | …thon/ray/experimental/sandbox/_internal/image_utils.py | 24 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/sandbox/backend/__init__.py | 8 | __all__ = [ | CODE |
| LOW | python/ray/experimental/sandbox/backend/gvisor.py | 27 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/sandbox/http/grpc_facade.py | 76 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/sandbox/http/host.py | 58 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/sandbox/http/host.py | 419 | def _set_status(self, status: str) -> None: | CODE |
| LOW | python/ray/experimental/sandbox/http/resolver.py | 18 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/sandbox/http/app.py | 48 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/sandbox/http/tests/conftest.py | 289 | __all__ = [ | CODE |
| LOW | python/ray/experimental/rdt/util.py | 344 | def set_nixl_cuda_stream(stream: Optional["torch.cuda.Stream"]) -> None: | CODE |
| LOW | python/ray/experimental/rdt/__init__.py | 20 | __all__ = [ | CODE |
| LOW | python/ray/experimental/rdt/rdt_manager.py | 53 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 33 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 182 | def set_cuda_stream(self, stream: Optional["torch.cuda.Stream"]) -> None: | CODE |
| LOW | python/ray/experimental/rdt/rdt_store.py | 20 | logger = logging.getLogger(__name__) | CODE |
| LOW | …ray/llm/_internal/common/callbacks/cloud_downloader.py | 9 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/llm/_internal/common/callbacks/base.py | 11 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/llm/_internal/common/utils/cloud_utils.py | 443 | def _update_cache(self, key: str, value: Any) -> None: | CODE |
| LOW | python/ray/llm/_internal/common/utils/import_utils.py | 7 | logger = logging.getLogger(__name__) | CODE |
| LOW | …lm/_internal/common/utils/cloud_filesystem/__init__.py | 23 | __all__ = [ | CODE |
| LOW | python/ray/llm/_internal/batch/__init__.py | 8 | __all__ = [ | CODE |
| LOW | python/ray/llm/_internal/batch/utils.py | 10 | logger = logging.getLogger(__name__) | CODE |
| LOW | …/ray/llm/_internal/batch/stages/sglang_engine_stage.py | 19 | logger = logging.getLogger(__name__) | CODE |
| LOW | python/ray/llm/_internal/batch/stages/__init__.py | 92 | __all__ = [ | CODE |
| 1057 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/setup.py | 649 | CODE | |
| LOW | python/setup.py | 81 | CODE | |
| LOW | python/ray/exceptions.py | 324 | CODE | |
| LOW | python/ray/runtime_env/runtime_env.py | 97 | CODE | |
| LOW | python/ray/experimental/channel/cpu_communicator.py | 69 | CODE | |
| LOW | python/ray/experimental/channel/common.py | 357 | CODE | |
| LOW | python/ray/experimental/channel/common.py | 456 | CODE | |
| LOW | python/ray/experimental/sandbox/config.py | 39 | CODE | |
| LOW | …thon/ray/experimental/sandbox/_internal/image_utils.py | 187 | CODE | |
| LOW | …thon/ray/experimental/sandbox/_internal/image_utils.py | 318 | CODE | |
| LOW | …thon/ray/experimental/sandbox/_internal/image_utils.py | 720 | CODE | |
| LOW | …thon/ray/experimental/sandbox/_internal/image_utils.py | 746 | CODE | |
| LOW | …thon/ray/experimental/sandbox/_internal/image_utils.py | 824 | CODE | |
| LOW | …thon/ray/experimental/sandbox/_internal/image_utils.py | 942 | CODE | |
| LOW | python/ray/experimental/sandbox/backend/gvisor.py | 98 | CODE | |
| LOW | python/ray/experimental/sandbox/http/grpc_facade.py | 884 | CODE | |
| LOW | python/ray/experimental/sandbox/http/grpc_facade.py | 1017 | CODE | |
| LOW | python/ray/experimental/sandbox/http/app.py | 128 | CODE | |
| LOW | python/ray/experimental/sandbox/http/app.py | 250 | CODE | |
| LOW | …ay/experimental/sandbox/http/tests/test_grpc_facade.py | 984 | CODE | |
| LOW | …ay/experimental/sandbox/http/tests/test_grpc_facade.py | 1006 | CODE | |
| LOW | python/ray/experimental/rdt/rdt_manager.py | 316 | CODE | |
| LOW | python/ray/experimental/rdt/rdt_manager.py | 559 | CODE | |
| LOW | python/ray/experimental/rdt/rdt_manager.py | 705 | CODE | |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 278 | CODE | |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 376 | CODE | |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 555 | CODE | |
| LOW | python/ray/experimental/rdt/nixl_tensor_transport.py | 720 | CODE | |
| LOW | python/ray/experimental/rdt/nixl_memory_pool.py | 209 | CODE | |
| LOW | python/ray/llm/_internal/common/utils/cloud_utils.py | 82 | CODE | |
| LOW | python/ray/llm/_internal/common/utils/cloud_utils.py | 147 | CODE | |
| LOW | python/ray/llm/_internal/common/utils/download_utils.py | 226 | CODE | |
| LOW | python/ray/llm/_internal/common/utils/download_utils.py | 122 | CODE | |
| LOW | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 230 | CODE | |
| LOW | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 351 | CODE | |
| LOW | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 29 | CODE | |
| LOW | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 285 | CODE | |
| LOW | …llm/_internal/batch/stages/prepare_multimodal_stage.py | 49 | CODE | |
| LOW | …n/ray/llm/_internal/batch/stages/http_request_stage.py | 93 | CODE | |
| LOW | …n/ray/llm/_internal/batch/stages/http_request_stage.py | 124 | CODE | |
| LOW | …on/ray/llm/_internal/batch/stages/vllm_engine_stage.py | 119 | CODE | |
| LOW | …on/ray/llm/_internal/batch/stages/vllm_engine_stage.py | 252 | CODE | |
| LOW | python/ray/llm/_internal/serve/benchmark/models.py | 134 | CODE | |
| LOW | python/ray/llm/_internal/serve/benchmark/interactive.py | 405 | CODE | |
| LOW | python/ray/llm/_internal/serve/benchmark/interactive.py | 475 | CODE | |
| LOW | python/ray/llm/_internal/serve/benchmark/interactive.py | 521 | CODE | |
| LOW | python/ray/llm/_internal/serve/benchmark/runners.py | 471 | CODE | |
| LOW | python/ray/llm/_internal/serve/benchmark/runners.py | 689 | CODE | |
| LOW | …rnal/serve/serving_patterns/data_parallel/dp_server.py | 244 | CODE | |
| LOW | …nal/serve/serving_patterns/prefill_decode/pd_server.py | 399 | CODE | |
| LOW | python/ray/llm/_internal/serve/core/ingress/ingress.py | 439 | CODE | |
| LOW | python/ray/llm/_internal/serve/core/ingress/builder.py | 190 | CODE | |
| LOW | python/ray/llm/_internal/serve/core/ingress/utils.py | 30 | CODE | |
| LOW | python/ray/llm/_internal/serve/utils/server_utils.py | 160 | CODE | |
| LOW | python/ray/llm/_internal/serve/utils/batcher.py | 50 | CODE | |
| LOW | …on/ray/llm/_internal/serve/engines/vllm/vllm_models.py | 267 | CODE | |
| LOW | …ting_policies/kv_aware/vllm/prompt_token_forwarding.py | 18 | CODE | |
| LOW | …e/routing_policies/prefix_aware/prefix_aware_router.py | 208 | CODE | |
| LOW | …nal/serve/routing_policies/prefix_aware/prefix_tree.py | 253 | CODE | |
| LOW | …nal/serve/routing_policies/prefix_aware/prefix_tree.py | 376 | CODE | |
| 1215 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/util/state/common.py | 1268 | # Step 2: Create the tree structure based on ownership | STRING |
| LOW⚡ | python/ray/dag/vis_utils.py | 94 | # Step 0: check dependencies and init graph | COMMENT |
| LOW⚡ | python/ray/dag/vis_utils.py | 100 | # Step 1: generate unique name for each node in dag | COMMENT |
| LOW⚡ | python/ray/dag/vis_utils.py | 107 | # Step 2: create graph with all the edges | COMMENT |
| LOW⚡ | python/ray/dag/compiled_dag_node.py | 2037 | # Step 1: Build a graph of _DAGOperationGraphNode | STRING |
| LOW⚡ | python/ray/dag/compiled_dag_node.py | 2042 | # Step 2: Generate an execution schedule for each actor using topological sort | STRING |
| LOW⚡ | python/ray/dag/compiled_dag_node.py | 2045 | # Step 3: Overlap GPU communication for the execution schedule if configured | STRING |
| LOW | python/ray/dag/compiled_dag_node.py | 1798 | # Step 1: populate `arg_to_consumers` and perform some validation. | STRING |
| LOW | python/ray/dag/compiled_dag_node.py | 1818 | # Step 2: create cached channels if needed | STRING |
| LOW | python/ray/dag/compiled_dag_node.py | 1837 | # Step 3: create executable tasks for the actor | STRING |
| LOW | …ion-tests/invalid-config-fail/ray-project/project.yaml | 12 | # NOTE: The following is invalid because you can't have both dockerfile | COMMENT |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 48 | # Step 1: Convert uint8 numpy array back to torch tensor | COMMENT |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 51 | # Step 2: Restore original dtype | COMMENT |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 65 | # Step 3: Reshape and reinterpret bytes as target dtype | COMMENT |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 68 | # Step 4: Move to target device | COMMENT |
| LOW⚡ | …driver_scripts/check_code_search_path_is_propagated.py | 22 | # Step 1: Print the statement indicating that the code_search_path have been | COMMENT |
| LOW⚡ | …driver_scripts/check_code_search_path_is_propagated.py | 25 | # Step 2: Print the whole runtime_env to validate that it's been passed | COMMENT |
| LOW⚡ | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1067 | # Step 4: Scale - should succeed | COMMENT |
| LOW⚡ | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1070 | # Step 5: Disable external_scaler_enabled again | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1027 | # Step 1: Deploy with external_scaler_enabled=False | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1038 | # Step 2: Try to scale - should fail | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1056 | # Step 3: Enable external_scaler_enabled | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1083 | # Step 6: Try to scale again - should fail | COMMENT |
| LOW⚡ | python/ray/rllib/core/models/catalog.py | 447 | # Step 1: Construct the dictionary. | COMMENT |
| LOW | python/ray/rllib/core/models/catalog.py | 501 | # Step 2: Return the correct distribution class for the given action space. | COMMENT |
| LOW | python/ray/rllib/algorithms/algorithm_config.py | 4571 | # NOTE: The following if-block is only relevant for the old API stack. | COMMENT |
| LOW⚡ | …in/v2/_internal/execution/checkpoint/report_handler.py | 75 | # Step 1: Assert that the worker group has been started and not shut down. | COMMENT |
| LOW⚡ | …in/v2/_internal/execution/checkpoint/report_handler.py | 83 | # Step 2: Update training_reports_queues with poll_results. | COMMENT |
| LOW | …in/v2/_internal/execution/checkpoint/report_handler.py | 105 | # Step 3: Consolidate a list of checkpoints to single checkpoint. | COMMENT |
| LOW | …in/v2/_internal/execution/checkpoint/report_handler.py | 130 | # Step 4: Invoke all dependent `ReportCallback`s. | COMMENT |
| LOW⚡ | …n/ray/autoscaler/_private/resource_demand_scheduler.py | 216 | # Step 1: Calculate current cluster resources and node type counts | COMMENT |
| LOW⚡ | …n/ray/autoscaler/_private/resource_demand_scheduler.py | 225 | # Step 2: add nodes to add to satisfy min_workers for each type | COMMENT |
| LOW | …n/ray/autoscaler/_private/resource_demand_scheduler.py | 240 | # Step 3: get resource demands of placement groups and return the | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_logging.py | 369 | # Step 1: Get current file end position | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_logging.py | 372 | # Step 2: Make HTTP call | COMMENT |
| LOW | python/ray/serve/tests/test_logging.py | 401 | # Step 3: Verify HTTP response matches new log lines | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1211 | # Step 4: Change the max replicas to 2 | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1221 | # Step 5: Make sure it is the same replica (lightweight change). | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1226 | # Step 6: Make sure initial_replicas overrides previous replicas | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1238 | # Step 7: Make sure original replica is still running (lightweight change) | COMMENT |
| LOW | python/ray/serve/tests/test_autoscaling_policy.py | 1150 | # Step 1: Prepare the script in a zip file so it can be submitted via REST API. | COMMENT |
| LOW | python/ray/serve/tests/test_autoscaling_policy.py | 1171 | # Step 2: Deploy it with max_replicas=1 | COMMENT |
| LOW | python/ray/serve/tests/test_autoscaling_policy.py | 1195 | # Step 3: Verify that it can scale from 0 to 1. | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 837 | # Step 1: Saturate the replica — 2/2 slots occupied. | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 844 | # Step 2: Kill the CQ. It restarts with in_flight=0. | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 860 | # Step 3: Send a non-blocking request. The stale CQ issues a token, | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 865 | # Step 4: The CQ should have learned — in_flight > 0 because the | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 873 | # Step 5: Release the blockers so all requests complete. | COMMENT |
| LOW | python/ray/serve/tests/test_capacity_queue_router.py | 632 | # Step 1: Occupy 3 of 5 slots with blocking requests. | COMMENT |
| LOW | python/ray/serve/tests/test_capacity_queue_router.py | 647 | # Step 2: Kill the queue. It restarts with in_flight=0. | COMMENT |
| LOW | python/ray/serve/tests/unit/test_deployment_state.py | 4026 | # Step 1: Create some deployment info with actors in running state | COMMENT |
| LOW | python/ray/data/aggregate.py | 2180 | # NOTE: The result must itself be a valid accumulator: the reduce side | COMMENT |
| LOW | python/ray/data/dataset.py | 8538 | # NOTE: This method expected to have executor fully shutdown upon returning | COMMENT |
| LOW | python/ray/data/_internal/table_block.py | 345 | # Step 1: Initialize accumulators for this group | COMMENT |
| LOW | python/ray/data/_internal/table_block.py | 357 | # Step 2: Apply aggregations to provided group's block | COMMENT |
| LOW | python/ray/data/_internal/table_block.py | 368 | # Step 3: Compose resulting row from | COMMENT |
| LOW | python/ray/data/_internal/planner/plan_udf_map_op.py | 850 | # NOTE: This method is nested to support Python 3.9 where we only can | COMMENT |
| LOW⚡ | …thon/ray/data/_internal/block_batching/iter_batches.py | 241 | # Step 1: Prefetch logical batches locally. | COMMENT |
| LOW⚡ | …thon/ray/data/_internal/block_batching/iter_batches.py | 244 | # Step 2: Resolve the blocks. | COMMENT |
| LOW⚡ | …thon/ray/data/_internal/block_batching/iter_batches.py | 247 | # Step 3: Batch and shuffle the resolved blocks. | COMMENT |
| 452 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | python/requirements/ml/rllib-test-requirements.txt | 18 | # For tests on PettingZoo's multi-agent envs. | COMMENT |
| MEDIUM⚡ | …nal/serve/serving_patterns/prefill_decode/pd_server.py | 60 | # those two routes at its own ``chat`` / ``completions`` (which orchestrate | COMMENT |
| MEDIUM | python/ray/rllib/connectors/connector_v2.py | 863 | # Single-agent/multi-agent cases. | COMMENT |
| MEDIUM | …/ray/rllib/connectors/common/batch_individual_items.py | 32 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …/ray/rllib/connectors/common/batch_individual_items.py | 43 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …tors/common/add_observations_from_episodes_to_batch.py | 29 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …tors/common/add_observations_from_episodes_to_batch.py | 40 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …onnectors/common/add_time_dim_to_batch_and_zero_pad.py | 38 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …onnectors/common/add_time_dim_to_batch_and_zero_pad.py | 49 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …y/rllib/connectors/common/module_to_agent_unmapping.py | 40 | # This Connector should only be used in a multi-agent setting. | COMMENT |
| MEDIUM | …ray/rllib/connectors/common/agent_to_module_mapping.py | 30 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …ray/rllib/connectors/common/agent_to_module_mapping.py | 41 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …connectors/common/add_states_from_episodes_to_batch.py | 35 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …connectors/common/add_states_from_episodes_to_batch.py | 46 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM⚡ | …on/ray/rllib/connectors/common/flatten_observations.py | 223 | # Multi-agent example: Use the connector with a multi-agent observation space. | STRING |
| MEDIUM⚡ | …on/ray/rllib/connectors/common/flatten_observations.py | 237 | # Create a multi-agent observation space with agent IDs as keys. | STRING |
| MEDIUM⚡ | …on/ray/rllib/connectors/common/flatten_observations.py | 243 | # Create a multi-agent episode with observations for both agents. | STRING |
| MEDIUM | …on/ray/rllib/connectors/common/flatten_observations.py | 262 | # Construct the connector for multi-agent, flattening only agent_1's observations. | STRING |
| MEDIUM | …on/ray/rllib/connectors/common/flatten_observations.py | 444 | # In the multi-agent case, we need to use the specific agent's | COMMENT |
| MEDIUM | …on/ray/rllib/connectors/common/flatten_observations.py | 445 | # space struct, not the multi-agent observation space dict. | COMMENT |
| MEDIUM | …on/ray/rllib/connectors/common/flatten_observations.py | 480 | # In the multi-agent case, we need to use the specific agent's | COMMENT |
| MEDIUM | …on/ray/rllib/connectors/common/flatten_observations.py | 481 | # space struct, not the multi-agent observation space dict. | COMMENT |
| MEDIUM | python/ray/rllib/connectors/common/numpy_to_tensor.py | 38 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | python/ray/rllib/connectors/common/numpy_to_tensor.py | 49 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …rs/learner/add_columns_from_episodes_to_train_batch.py | 26 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …nectors/learner/add_one_ts_to_episodes_and_truncate.py | 115 | # TODO (sven): Same situation as in TODO below, but for multi-agent episode. | COMMENT |
| MEDIUM | …onnectors/module_to_env/listify_data_for_vector_env.py | 27 | ModuleToAgentUnmapping, # only in multi-agent setups! | STRING |
| MEDIUM | …onnectors/module_to_env/listify_data_for_vector_env.py | 61 | # Multi-agent case: Create lists of multi-agent dicts under each column. | COMMENT |
| MEDIUM | …connectors/module_to_env/normalize_and_clip_actions.py | 33 | ModuleToAgentUnmapping, # only in multi-agent setups! | STRING |
| MEDIUM | …onnectors/module_to_env/unbatch_to_individual_items.py | 28 | ModuleToAgentUnmapping, # only in multi-agent setups! | STRING |
| MEDIUM | …onnectors/module_to_env/unbatch_to_individual_items.py | 61 | # Keys are always tuples to resemble multi-agent keys, which | COMMENT |
| MEDIUM | …module_to_env/remove_single_ts_time_rank_from_batch.py | 27 | ModuleToAgentUnmapping, # only in multi-agent setups! | STRING |
| MEDIUM | …thon/ray/rllib/connectors/module_to_env/get_actions.py | 26 | ModuleToAgentUnmapping, # only in multi-agent setups! | STRING |
| MEDIUM | …/connectors/env_to_module/prev_actions_prev_rewards.py | 110 | # f"thus far (or, for multi-agent, on Dict spaces mapping AgentIDs to " | COMMENT |
| MEDIUM | …ectors/env_to_module/write_observations_to_episodes.py | 24 | AgentToModuleMapping, # only in multi-agent setups! | STRING |
| MEDIUM | …ectors/env_to_module/write_observations_to_episodes.py | 112 | # Note that the following loop works with multi-agent as well as with | COMMENT |
| MEDIUM | …ectors/env_to_module/write_observations_to_episodes.py | 116 | # `data`, either in a list directly under the "obs" key OR for multi-agent: | COMMENT |
| MEDIUM | …b/connectors/env_to_module/observation_preprocessor.py | 166 | # TODO (sven): Implement set_observations API for multi-agent episodes. | COMMENT |
| MEDIUM | python/ray/rllib/core/testing/testing_learner.py | 46 | # TODO (Kourosh): Make this more multi-agent for example with policy ids | COMMENT |
| MEDIUM | …ay/rllib/core/learner/differentiable_learner_config.py | 124 | # If multi-agent -> Map from AgentID-based data to ModuleID based data. | COMMENT |
| MEDIUM⚡ | python/ray/rllib/algorithms/algorithm_config.py | 4830 | # If the module is single-agent convert it to multi-agent spec | COMMENT |
| MEDIUM⚡ | python/ray/rllib/algorithms/algorithm_config.py | 4832 | # The default RLModuleSpec (might be multi-agent or single-agent). | COMMENT |
| MEDIUM⚡ | python/ray/rllib/algorithms/algorithm_config.py | 4834 | # The currently configured RLModuleSpec (might be multi-agent or single-agent). | COMMENT |
| MEDIUM⚡ | python/ray/rllib/algorithms/algorithm_config.py | 4855 | # Algorithm is currently setup as a multi-agent one. | COMMENT |
| MEDIUM⚡ | python/ray/rllib/algorithms/algorithm_config.py | 4861 | # Default is single-agent but the user has provided a multi-agent spec | COMMENT |
| MEDIUM⚡ | python/ray/rllib/algorithms/algorithm_config.py | 4862 | # so the use-case is multi-agent. | COMMENT |
| MEDIUM⚡ | python/ray/rllib/algorithms/algorithm_config.py | 4881 | # We need to infer the multi-agent class from `current_rl_module_spec` | COMMENT |
| MEDIUM⚡ | python/ray/rllib/algorithms/algorithm_config.py | 4891 | # Default is multi-agent and user wants to override it -> Don't use the | COMMENT |
| MEDIUM⚡ | python/ray/rllib/algorithms/algorithm_config.py | 4895 | # to reuse for all modules in this multi-agent default setup. | COMMENT |
| MEDIUM | python/ray/rllib/algorithms/algorithm_config.py | 139 | # The default agent ID to module ID mapping function to use in the multi-agent | COMMENT |
| MEDIUM | python/ray/rllib/algorithms/algorithm_config.py | 459 | # TODO (sven): Prepare multi-agent setup for logging each agent's and each | COMMENT |
| MEDIUM | python/ray/rllib/algorithms/algorithm_config.py | 799 | # Set our multi-agent settings. | COMMENT |
| MEDIUM | python/ray/rllib/algorithms/algorithm_config.py | 1115 | # If multi-agent -> Map from AgentID-based data to ModuleID based data. | COMMENT |
| MEDIUM | python/ray/rllib/algorithms/algorithm_config.py | 1223 | # If multi-agent -> Map from ModuleID-based data to AgentID based data. | COMMENT |
| MEDIUM | python/ray/rllib/algorithms/algorithm_config.py | 1246 | # for single-agent and multi-agent dicts for multi-agent. | COMMENT |
| MEDIUM | python/ray/rllib/algorithms/algorithm_config.py | 1308 | # If multi-agent -> Map from AgentID-based data to ModuleID based data. | COMMENT |
| MEDIUM⚡ | python/ray/rllib/algorithms/utils.py | 66 | # which IDs the submodules have (to figure out, whether its multi-agent or | COMMENT |
| MEDIUM | python/ray/rllib/algorithms/cql/cql.py | 350 | # Use simple optimizer (only for multi-agent or tf-eager; all other | COMMENT |
| MEDIUM⚡ | …on/ray/rllib/algorithms/tests/test_algorithm_config.py | 335 | # multi-agent | COMMENT |
| MEDIUM | …on/ray/rllib/algorithms/tests/test_algorithm_config.py | 405 | # in the multi-agent scenario. | COMMENT |
| 99 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/exceptions.py | 582 | # Check if RAY_AUTH_MODE is set to token and add a heads-up if not | COMMENT |
| LOW | python/ray/actor.py | 740 | # Check if decorator is called without parentheses (args[0] would be the function) | COMMENT |
| LOW | python/ray/experimental/rdt/rdt_manager.py | 776 | # Check if a warning should be triggered for this object: | COMMENT |
| LOW | …nternal/common/utils/cloud_filesystem/s3_filesystem.py | 56 | # Check if anonymous@ prefix exists | COMMENT |
| LOW | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 51 | # Check if the first part ends with "anonymous" | COMMENT |
| LOW⚡ | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 236 | # Check if file exists | COMMENT |
| LOW⚡ | …al/common/utils/cloud_filesystem/pyarrow_filesystem.py | 241 | # Read file | COMMENT |
| LOW | python/ray/llm/_internal/serve/utils/registry.py | 109 | # Check if registered | STRING |
| LOW | …nal/serve/routing_policies/prefix_aware/prefix_tree.py | 416 | # Check if any available tenants match this node | COMMENT |
| LOW | python/ray/util/tpu.py | 664 | # Check if user explicitly requested a slice name for this slice | COMMENT |
| LOW | python/ray/util/client_connect.py | 34 | # Check if Ray is already connected (any type of connection) | COMMENT |
| LOW | python/ray/util/collective/collective.py | 236 | # Check if backend is registered and available | COMMENT |
| LOW | …sts/single_node_cpu_tests/test_gloo_group_isolation.py | 26 | # Check if the group is initialized correctly | COMMENT |
| LOW | python/ray/util/multiprocessing/pool.py | 259 | # Check if any of the available IDs are done. The timeout is required | COMMENT |
| LOW | python/ray/util/client/common.py | 291 | # Check if supplied parameters match the function signature. Same case | COMMENT |
| LOW | python/ray/util/client/server/server.py | 76 | # Check if response already cached | COMMENT |
| LOW | python/ray/_common/usage/usage_lib.py | 822 | # Check if we're on Kubernetes | COMMENT |
| LOW | python/ray/_common/usage/usage_lib.py | 824 | # Check if we're using KubeRay >= 0.4.0. | COMMENT |
| LOW | python/ray/tests/conftest.py | 387 | # Check if th redis has started successfully and is listening on the port. | COMMENT |
| LOW | python/ray/tests/conftest.py | 1213 | # Set scope to "class" to force this to run before start_cluster, whose scope | COMMENT |
| LOW | python/ray/tests/test_logging.py | 317 | # Check if the backup count is respected. | COMMENT |
| LOW | python/ray/tests/test_logging.py | 423 | # Check if the backup count is respected. | COMMENT |
| LOW | python/ray/tests/test_object_spilling_3.py | 386 | # Iterate over the data on the worker nodes from the head node. | COMMENT |
| LOW | python/ray/tests/test_runtime_env_plugin.py | 628 | # Set scope to "class" to force this to run before start_cluster, whose scope | COMMENT |
| LOW | python/ray/tests/test_runtime_env_working_dir.py | 40 | # Set scope to "module" to force this to run before start_cluster, whose scope | COMMENT |
| LOW⚡ | python/ray/tests/test_runtime_env_agent.py | 115 | # Check if agent register is OK. | COMMENT |
| LOW | python/ray/tests/test_scheduling.py | 734 | # Check if task2 starts within 1 second (indicating the bug) | COMMENT |
| LOW | python/ray/tests/test_runtime_env_failure.py | 20 | # Set scope to "class" to force this to run before start_cluster, whose scope | COMMENT |
| LOW | python/ray/tests/test_coordinator_server.py | 375 | # Check if now we can create more clusters/nodes. | COMMENT |
| LOW | python/ray/tests/test_client.py | 86 | # Set num_cpus to zero to ensure that both tasks can always be scheduled | COMMENT |
| LOW | python/ray/tests/test_cli.py | 1569 | # Check if ray.serve is available (it's an optional dependency) | COMMENT |
| LOW | python/ray/tests/test_runtime_env_working_dir_3.py | 34 | # Set scope to "class" to force this to run before start_cluster, whose scope | COMMENT |
| LOW⚡ | python/ray/tests/vsphere/test_cluster_operator.py | 654 | # Check if status is not available | COMMENT |
| LOW⚡ | python/ray/tests/vsphere/test_cluster_operator.py | 658 | # Check if ingress in unavailable | COMMENT |
| LOW | python/ray/air/tests/test_integration_mlflow.py | 113 | # Check if client recognizes already existing experiment. | COMMENT |
| LOW | python/ray/air/tests/test_integration_mlflow.py | 195 | # Check if run is created with proper tags. | COMMENT |
| LOW | python/ray/air/tests/test_integration_mlflow.py | 237 | # Check if params are logged at the end. | COMMENT |
| LOW | python/ray/air/integrations/wandb.py | 132 | # Check if we are in a train session and if we are not the rank 0 worker | COMMENT |
| LOW | python/ray/air/integrations/wandb.py | 351 | # Check if user is already logged into wandb. | COMMENT |
| LOW | python/ray/air/execution/resources/request.py | 75 | # Check if the head bundle is empty (no resources defined or all resources | COMMENT |
| LOW | python/ray/_private/function_manager.py | 562 | # Check if the actor class already exists in the cache. | COMMENT |
| LOW | python/ray/_private/inspect_util.py | 14 | # Check if function or method, respectively | COMMENT |
| LOW | python/ray/_private/node.py | 1607 | # Write the file BEFORE the internal_kv_put below so the two never | COMMENT |
| LOW | python/ray/_private/serialization.py | 220 | # Check if this is an RDT ObjectRef being serialized inside a collection | COMMENT |
| LOW | python/ray/_private/serialization.py | 440 | # Check if the object should be returned as raw bytes. | COMMENT |
| LOW | python/ray/_private/runtime_env/uv_runtime_env_hook.py | 268 | # Check if the requirements.txt file is in the working_dir | COMMENT |
| LOW | python/ray/_private/runtime_env/uv_runtime_env_hook.py | 282 | # Check if the pyproject.toml file is in the working_dir | COMMENT |
| LOW | python/ray/_private/accelerators/tpu.py | 411 | # Check if z coordinates are present. | COMMENT |
| LOW | …y/_private/authentication/http_token_authentication.py | 92 | # Check if user provided their own Authorization header (case-insensitive) | COMMENT |
| LOW | …/_private/authentication/authentication_token_setup.py | 143 | # Check if you enabled token authentication. | COMMENT |
| LOW | …/_private/thirdparty/pathspec/patterns/gitwildmatch.py | 268 | # Set i to one past the closing braket. | COMMENT |
| LOW | python/ray/_private/thirdparty/tabulate/tabulate.py | 2090 | # Check if pretty is the format being used and override the defaults so it | COMMENT |
| LOW | python/ray/dashboard/http_server_head.py | 206 | # Check if token authentication is enabled | COMMENT |
| LOW | python/ray/dashboard/http_server_head.py | 246 | # Check if the connection is secure (HTTPS) | COMMENT |
| LOW | python/ray/dashboard/event_loop_monitor.py | 57 | # Set RAY_DASHBOARD_AGENT_LOOP_DUMP_SIGNAL to another signal name, or to an | COMMENT |
| LOW | python/ray/dashboard/tests/test_dashboard.py | 117 | # Check if agent register is OK. | COMMENT |
| LOW | python/ray/dashboard/modules/metrics/metrics_head.py | 165 | # Check if the required Grafana services are running. | COMMENT |
| LOW | python/ray/dashboard/modules/reporter/gpu_providers.py | 284 | # Check if MIG mode is enabled on this GPU | COMMENT |
| LOW | python/ray/dashboard/modules/reporter/gpu_providers.py | 654 | # Check if we should disable GPU check entirely | COMMENT |
| LOW | python/ray/dashboard/modules/job/cli.py | 567 | # Set no_format to True because the logs may have unescaped "{" and "}" | COMMENT |
| 188 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/runtime_context.py | 527 | CODE | |
| LOW | python/ray/actor.py | 612 | CODE | |
| LOW | python/ray/actor.py | 1079 | CODE | |
| LOW | python/ray/actor.py | 2486 | CODE | |
| LOW | python/ray/job_config.py | 54 | CODE | |
| LOW | python/ray/runtime_env/runtime_env.py | 326 | CODE | |
| LOW | python/ray/experimental/shuffle.py | 231 | CODE | |
| LOW | python/ray/experimental/sandbox/image_manager.py | 136 | CODE | |
| LOW | python/ray/experimental/sandbox/image_manager.py | 187 | CODE | |
| LOW | python/ray/experimental/sandbox/image_manager.py | 361 | CODE | |
| LOW | python/ray/experimental/sandbox/image_manager.py | 583 | CODE | |
| LOW | python/ray/experimental/sandbox/__init__.py | 34 | CODE | |
| LOW | python/ray/experimental/sandbox/runtime.py | 47 | CODE | |
| LOW | python/ray/experimental/sandbox/sandbox.py | 46 | CODE | |
| LOW | python/ray/experimental/sandbox/backend/gvisor.py | 603 | CODE | |
| LOW | …/ray/llm/_internal/batch/stages/sglang_engine_stage.py | 78 | CODE | |
| LOW | python/ray/util/tpu.py | 962 | CODE | |
| LOW | python/ray/util/tpu.py | 537 | CODE | |
| LOW | python/ray/util/client_connect.py | 22 | CODE | |
| LOW | python/ray/util/dask/scheduler_utils.py | 242 | CODE | |
| LOW | python/ray/util/state/api.py | 1180 | CODE | |
| LOW | python/ray/util/state/state_cli.py | 885 | CODE | |
| LOW | python/ray/util/client/__init__.py | 122 | CODE | |
| LOW | python/ray/util/spark/cluster_init.py | 1233 | CODE | |
| LOW | python/ray/util/spark/cluster_init.py | 1406 | CODE | |
| LOW | python/ray/_common/usage/usage_lib.py | 883 | CODE | |
| LOW | python/ray/_common/usage/usage_lib.py | 950 | CODE | |
| LOW | python/ray/_common/usage/usage_lib.py | 971 | CODE | |
| LOW | python/ray/_common/observability/platform_events.py | 13 | CODE | |
| LOW | python/ray/tests/test_state_api.py | 264 | CODE | |
| LOW | python/ray/tests/test_resource_metrics.py | 18 | CODE | |
| LOW | python/ray/tests/test_core_worker_fault_tolerance.py | 125 | CODE | |
| LOW | python/ray/tests/test_nccl_channel.py | 85 | CODE | |
| LOW | python/ray/tests/test_metrics_agent_2.py | 49 | CODE | |
| LOW | python/ray/tests/horovod/horovod_example.py | 40 | CODE | |
| LOW | python/ray/tests/kuberay/utils.py | 310 | CODE | |
| LOW | python/ray/air/integrations/mlflow.py | 33 | CODE | |
| LOW | python/ray/air/integrations/wandb.py | 594 | CODE | |
| LOW | python/ray/_private/worker.py | 1446 | CODE | |
| LOW | python/ray/_private/worker.py | 2506 | CODE | |
| LOW | python/ray/_private/worker.py | 3774 | CODE | |
| LOW | python/ray/_private/test_utils.py | 266 | CODE | |
| LOW | python/ray/_private/services.py | 883 | CODE | |
| LOW | python/ray/_private/services.py | 1523 | CODE | |
| LOW | python/ray/_private/services.py | 1610 | CODE | |
| LOW | python/ray/_private/services.py | 2338 | CODE | |
| LOW | python/ray/_private/services.py | 2421 | CODE | |
| LOW | python/ray/_private/parameter.py | 129 | CODE | |
| LOW | python/ray/_private/thirdparty/pynvml/pynvml.py | 2854 | CODE | |
| LOW | python/ray/_private/thirdparty/pynvml/pynvml.py | 5957 | CODE | |
| LOW | python/ray/_private/thirdparty/pynvml/pynvml.py | 5962 | CODE | |
| LOW | python/ray/_private/thirdparty/tabulate/tabulate.py | 1556 | CODE | |
| LOW | …ard/modules/platform_events/tests/test_k8s_provider.py | 22 | CODE | |
| LOW | python/ray/dashboard/modules/job/sdk.py | 133 | CODE | |
| LOW | python/ray/dashboard/modules/job/job_manager.py | 463 | CODE | |
| LOW | python/ray/dashboard/modules/log/log_manager.py | 390 | CODE | |
| LOW | python/ray/rllib/core/models/torch/primitives.py | 27 | CODE | |
| LOW | python/ray/rllib/core/learner/learner_group.py | 256 | CODE | |
| LOW | python/ray/rllib/core/learner/learner.py | 1067 | CODE | |
| LOW | …hon/ray/rllib/core/learner/torch/torch_meta_learner.py | 97 | CODE | |
| 284 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | build-docker.sh | 36 | # It also can facilitate cleanup. | COMMENT |
| MEDIUM | python/ray/actor.py | 2722 | """This is defined in order to make pickling work. | STRING |
| MEDIUM | python/ray/actor.py | 2771 | """This is defined in order to make pickling work. | STRING |
| LOW | python/ray/llm/_internal/common/utils/download_utils.py | 108 | # and we can just return the model_dir. | COMMENT |
| LOW | python/ray/llm/_internal/serve/utils/server_utils.py | 127 | # This also works for normal exceptions (we will just return everything from | COMMENT |
| MEDIUM | python/ray/llm/_internal/serve/utils/server_utils.py | 190 | # TODO make this more robust | COMMENT |
| LOW | python/ray/llm/tests/common/cloud/test_s3_filesystem.py | 248 | # This should not raise, just return without downloading | COMMENT |
| LOW | python/ray/dag/input_node.py | 119 | # If user only passed in one value, for simplicity we just return it. | COMMENT |
| LOW | python/ray/tests/test_actor_resources.py | 450 | # can't just return them from the tasks, because the tasks don't return | COMMENT |
| MEDIUM | python/ray/tests/test_dataclient_disconnect.py | 61 | # robust mechanism if they fail with code changes or become flaky. | COMMENT |
| MEDIUM | python/ray/tests/conftest_docker.py | 16 | # setup is a little intricate, as it uses docker-in-docker. | COMMENT |
| MEDIUM | python/ray/tests/test_resource_demand_scheduler.py | 2115 | # TODO (Alex): We should find a more robust way of simulating a node | COMMENT |
| MEDIUM | python/ray/tests/test_resource_demand_scheduler.py | 2228 | # testPlacementGroupScaling for more comprehensive tests. | COMMENT |
| LOW | python/ray/tests/test_cli_patterns/test_no_head.yaml | 78 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| LOW | python/ray/tests/test_cli_patterns/test_no_workers.yaml | 79 | # you should just use file_mounts. Only use this if you know what you're doing! | COMMENT |
| LOW | python/ray/_private/worker.py | 2162 | # should simply set "global_worker" to equal "None" or something like that. | COMMENT |
| MEDIUM | python/ray/_private/services.py | 360 | # TODO(ekl): Find a robust solution for locating Redis. | COMMENT |
| LOW | python/ray/_private/runtime_env/working_dir.py | 74 | # working_dir is already a URI -- just pass it through. | COMMENT |
| MEDIUM | python/ray/_private/runtime_env/uv_runtime_env_hook.py | 448 | # We purposefully modify sys.argv here to make sure the hook is robust | COMMENT |
| MEDIUM | python/ray/dashboard/tests/test_event_loop_monitor.py | 19 | # harness (they still show on stderr). Attach a handler to the module logger | COMMENT |
| LOW | …n/ray/dashboard/modules/reporter/tests/test_healthz.py | 19 | # It'll either timeout or just return an error | COMMENT |
| MEDIUM | …oard/modules/aggregator/tests/test_aggregator_agent.py | 91 | # Pinning it off for now -- make these robust by filtering the batch for the | COMMENT |
| LOW | python/ray/dashboard/modules/job/job_manager.py | 381 | in #24546 for GPU detection and just use the user's resource | STRING |
| LOW | python/ray/dashboard/modules/node/node_head.py | 348 | # TODO(rickyx): we should just return structure data rather than strings. | COMMENT |
| MEDIUM | python/ray/dashboard/modules/node/datacenter.py | 163 | # with a more robust mapping in a future update. | COMMENT |
| MEDIUM | python/ray/dashboard/modules/node/datacenter.py | 245 | # This will be addressed with a more robust mapping in a future update. | COMMENT |
| LOW | python/ray/rllib/connectors/connector_v2.py | 511 | # Otherwise, just use episode's ID. | COMMENT |
| LOW | python/ray/rllib/connectors/agent/mean_std_filter.py | 42 | # We simply use the old MeanStdFilter until non-connector env_runner is fully | COMMENT |
| LOW | python/ray/rllib/connectors/agent/mean_std_filter.py | 167 | # We simply use the old MeanStdFilter until non-connector env_runner is fully | COMMENT |
| MEDIUM | python/ray/rllib/connectors/agent/view_requirement.py | 52 | # Note(jungong): We only leverage AgentCollector for building sample | COMMENT |
| LOW | …ray/rllib/connectors/common/agent_to_module_mapping.py | 269 | # If all obs spaces are the same anyway, just use the first | COMMENT |
| LOW | …connectors/common/add_states_from_episodes_to_batch.py | 279 | # Then simply use the `look_back_state`, i.e. in this case the | COMMENT |
| LOW | …/ray/rllib/connectors/env_to_module/mean_std_filter.py | 93 | # We simply use the old MeanStdFilter until non-connector env_runner is fully | COMMENT |
| LOW | python/ray/rllib/core/models/torch/encoder.py | 179 | # Otherwise, just use the raw observations. | COMMENT |
| LOW | python/ray/rllib/core/models/torch/encoder.py | 269 | # Otherwise, just use the raw observations. | COMMENT |
| LOW | python/ray/rllib/core/models/torch/heads.py | 67 | # Otherwise just return the logits. | COMMENT |
| MEDIUM | python/ray/rllib/core/rl_module/multi_rl_module.py | 476 | """Returns self in order to match `RLModule.as_multi_rl_module()` behavior. | STRING |
| MEDIUM | python/ray/rllib/core/rl_module/multi_rl_module.py | 772 | """Returns self in order to match `RLModuleSpec.as_multi_rl_module_spec()`.""" | STRING |
| LOW | python/ray/rllib/callbacks/callbacks.py | 209 | # Here, we just set some arbitrary property to 1. | STRING |
| LOW | python/ray/rllib/callbacks/callbacks.py | 270 | # Here, we just set some arbitrary property to 1. | STRING |
| LOW | python/ray/rllib/algorithms/algorithm.py | 1035 | # Otherwise we can simply pass in the local learner. | COMMENT |
| LOW | python/ray/rllib/algorithms/algorithm_config.py | 5987 | # If all obs spaces are the same, just use the first space. | STRING |
| LOW | python/ray/rllib/algorithms/algorithm_config.py | 6050 | # If all obs spaces are the same, just use the first space. | STRING |
| LOW | python/ray/rllib/algorithms/impala/impala.py | 1208 | # local worker. Otherwise just return an empty list. | COMMENT |
| MEDIUM | python/ray/rllib/algorithms/dqn/dqn_tf_policy.py | 92 | # priority is robust and insensitive to `prioritized_replay_alpha` | COMMENT |
| MEDIUM | python/ray/rllib/algorithms/dqn/dqn_torch_policy.py | 98 | # priority is robust and insensitive to `prioritized_replay_alpha` | COMMENT |
| LOW | …ib/algorithms/dqn/torch/default_dqn_torch_rl_module.py | 147 | # Otherwise we can just use the current observations. | COMMENT |
| MEDIUM | python/ray/rllib/utils/filter_manager.py | 62 | # Should we utilize the remote workers' filter stats to update the local | COMMENT |
| LOW | python/ray/rllib/utils/metrics/metrics_logger.py | 925 | # If value is a longer list, we should just return the list because there is no reduction method applied | COMMENT |
| LOW | python/ray/rllib/utils/runners/runner_group.py | 198 | # If a local runner is requested just return a runner instance. | COMMENT |
| LOW | …thon/ray/rllib/models/torch/modules/skip_connection.py | 37 | # Residual case, just add inputs to outputs. | COMMENT |
| LOW | python/ray/rllib/models/tf/layers/skip_connection.py | 39 | # Residual case, just add inputs to outputs. | COMMENT |
| LOW | python/ray/rllib/examples/utils.py | 773 | # Anyscale release dashboard (not just pass/fail). | COMMENT |
| MEDIUM | …ay/rllib/examples/_old_api_stack/centralized_critic.py | 8 | """An example of customizing PPO to leverage a centralized critic. | STRING |
| LOW | python/ray/rllib/examples/envs/classes/mock_env.py | 165 | # Since we only have one underlying sub-environment, just use the first seed | COMMENT |
| MEDIUM | …n/ray/rllib/examples/envs/classes/gpu_requiring_env.py | 11 | """A dummy env that requires a GPU in order to work. | STRING |
| LOW | …amples/envs/classes/multi_agent/rock_paper_scissors.py | 109 | # Set the next observations (simply use the other player's action). | COMMENT |
| MEDIUM | …ples/envs/classes/multi_agent/footsies/footsies_env.py | 94 | # game server and the Python harness via gRPC | COMMENT |
| LOW | …hon/ray/rllib/evaluation/collectors/agent_collector.py | 379 | # simply use the time dim as the batch dim. | COMMENT |
| LOW | …hon/ray/rllib/evaluation/collectors/agent_collector.py | 502 | # In this case we should just create an empty array and return it. | COMMENT |
| 77 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/util/state/common.py | 1268 | # Step 2: Create the tree structure based on ownership | STRING |
| LOW⚡ | python/ray/dag/vis_utils.py | 94 | # Step 0: check dependencies and init graph | COMMENT |
| LOW⚡ | python/ray/dag/vis_utils.py | 100 | # Step 1: generate unique name for each node in dag | COMMENT |
| LOW⚡ | python/ray/dag/vis_utils.py | 107 | # Step 2: create graph with all the edges | COMMENT |
| LOW⚡ | python/ray/dag/compiled_dag_node.py | 2037 | # Step 1: Build a graph of _DAGOperationGraphNode | STRING |
| LOW⚡ | python/ray/dag/compiled_dag_node.py | 2042 | # Step 2: Generate an execution schedule for each actor using topological sort | STRING |
| LOW⚡ | python/ray/dag/compiled_dag_node.py | 2045 | # Step 3: Overlap GPU communication for the execution schedule if configured | STRING |
| LOW | python/ray/dag/compiled_dag_node.py | 1798 | # Step 1: populate `arg_to_consumers` and perform some validation. | STRING |
| LOW | python/ray/dag/compiled_dag_node.py | 1818 | # Step 2: create cached channels if needed | STRING |
| LOW | python/ray/dag/compiled_dag_node.py | 1837 | # Step 3: create executable tasks for the actor | STRING |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 48 | # Step 1: Convert uint8 numpy array back to torch tensor | COMMENT |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 51 | # Step 2: Restore original dtype | COMMENT |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 65 | # Step 3: Reshape and reinterpret bytes as target dtype | COMMENT |
| LOW⚡ | python/ray/_private/tensor_serialization_utils.py | 68 | # Step 4: Move to target device | COMMENT |
| LOW⚡ | …driver_scripts/check_code_search_path_is_propagated.py | 22 | # Step 1: Print the statement indicating that the code_search_path have been | COMMENT |
| LOW⚡ | …driver_scripts/check_code_search_path_is_propagated.py | 25 | # Step 2: Print the whole runtime_env to validate that it's been passed | COMMENT |
| LOW⚡ | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1067 | # Step 4: Scale - should succeed | COMMENT |
| LOW⚡ | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1070 | # Step 5: Disable external_scaler_enabled again | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1027 | # Step 1: Deploy with external_scaler_enabled=False | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1038 | # Step 2: Try to scale - should fail | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1056 | # Step 3: Enable external_scaler_enabled | COMMENT |
| LOW | …/dashboard/modules/serve/tests/test_serve_dashboard.py | 1083 | # Step 6: Try to scale again - should fail | COMMENT |
| LOW | python/ray/rllib/core/models/catalog.py | 290 | # we need to check if no latent dim was set and simply reuse the last | COMMENT |
| LOW⚡ | python/ray/rllib/core/models/catalog.py | 447 | # Step 1: Construct the dictionary. | COMMENT |
| LOW | python/ray/rllib/core/models/catalog.py | 501 | # Step 2: Return the correct distribution class for the given action space. | COMMENT |
| LOW⚡ | …in/v2/_internal/execution/checkpoint/report_handler.py | 75 | # Step 1: Assert that the worker group has been started and not shut down. | COMMENT |
| LOW⚡ | …in/v2/_internal/execution/checkpoint/report_handler.py | 83 | # Step 2: Update training_reports_queues with poll_results. | COMMENT |
| LOW | …in/v2/_internal/execution/checkpoint/report_handler.py | 105 | # Step 3: Consolidate a list of checkpoints to single checkpoint. | COMMENT |
| LOW | …in/v2/_internal/execution/checkpoint/report_handler.py | 130 | # Step 4: Invoke all dependent `ReportCallback`s. | COMMENT |
| LOW⚡ | …n/ray/autoscaler/_private/resource_demand_scheduler.py | 216 | # Step 1: Calculate current cluster resources and node type counts | COMMENT |
| LOW⚡ | …n/ray/autoscaler/_private/resource_demand_scheduler.py | 225 | # Step 2: add nodes to add to satisfy min_workers for each type | COMMENT |
| LOW | …n/ray/autoscaler/_private/resource_demand_scheduler.py | 240 | # Step 3: get resource demands of placement groups and return the | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_logging.py | 369 | # Step 1: Get current file end position | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_logging.py | 372 | # Step 2: Make HTTP call | COMMENT |
| LOW | python/ray/serve/tests/test_logging.py | 401 | # Step 3: Verify HTTP response matches new log lines | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1211 | # Step 4: Change the max replicas to 2 | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1221 | # Step 5: Make sure it is the same replica (lightweight change). | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1226 | # Step 6: Make sure initial_replicas overrides previous replicas | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_autoscaling_policy.py | 1238 | # Step 7: Make sure original replica is still running (lightweight change) | COMMENT |
| LOW | python/ray/serve/tests/test_autoscaling_policy.py | 1150 | # Step 1: Prepare the script in a zip file so it can be submitted via REST API. | COMMENT |
| LOW | python/ray/serve/tests/test_autoscaling_policy.py | 1171 | # Step 2: Deploy it with max_replicas=1 | COMMENT |
| LOW | python/ray/serve/tests/test_autoscaling_policy.py | 1195 | # Step 3: Verify that it can scale from 0 to 1. | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 837 | # Step 1: Saturate the replica — 2/2 slots occupied. | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 844 | # Step 2: Kill the CQ. It restarts with in_flight=0. | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 860 | # Step 3: Send a non-blocking request. The stale CQ issues a token, | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 865 | # Step 4: The CQ should have learned — in_flight > 0 because the | COMMENT |
| LOW⚡ | python/ray/serve/tests/test_capacity_queue_router.py | 873 | # Step 5: Release the blockers so all requests complete. | COMMENT |
| LOW | python/ray/serve/tests/test_capacity_queue_router.py | 632 | # Step 1: Occupy 3 of 5 slots with blocking requests. | COMMENT |
| LOW | python/ray/serve/tests/test_capacity_queue_router.py | 647 | # Step 2: Kill the queue. It restarts with in_flight=0. | COMMENT |
| LOW | python/ray/serve/tests/unit/test_deployment_state.py | 4026 | # Step 1: Create some deployment info with actors in running state | COMMENT |
| LOW | python/ray/data/_internal/table_block.py | 345 | # Step 1: Initialize accumulators for this group | COMMENT |
| LOW | python/ray/data/_internal/table_block.py | 357 | # Step 2: Apply aggregations to provided group's block | COMMENT |
| LOW | python/ray/data/_internal/table_block.py | 368 | # Step 3: Compose resulting row from | COMMENT |
| LOW⚡ | …thon/ray/data/_internal/block_batching/iter_batches.py | 241 | # Step 1: Prefetch logical batches locally. | COMMENT |
| LOW⚡ | …thon/ray/data/_internal/block_batching/iter_batches.py | 244 | # Step 2: Resolve the blocks. | COMMENT |
| LOW⚡ | …thon/ray/data/_internal/block_batching/iter_batches.py | 247 | # Step 3: Batch and shuffle the resolved blocks. | COMMENT |
| LOW⚡ | …thon/ray/data/_internal/block_batching/iter_batches.py | 250 | # Step 4: Format and collate the batches in a threadpool. | COMMENT |
| LOW | …thon/ray/data/_internal/block_batching/iter_batches.py | 261 | # Step 6: Finalize the batches (e.g., move to GPU). | COMMENT |
| LOW | …ay/data/_internal/logical/rules/projection_pushdown.py | 424 | # Step 1: Iteratively fuse with upstream Project operations | COMMENT |
| LOW⚡ | …ay/data/_internal/logical/rules/projection_pushdown.py | 443 | # Step 2: Push projection into the data source if supported | COMMENT |
| 68 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/setup.py | 25 | # When the bazel version is updated, make sure to update it | COMMENT |
| LOW | python/ray/llm/_internal/serve/utils/batcher.py | 87 | # If the stream task is done, make sure to exit the read task | COMMENT |
| LOW⚡ | python/ray/util/serialization.py | 40 | # make sure to keep the API consistent. | COMMENT |
| LOW | python/ray/_common/utils.py | 403 | # Don't forget to strip() the newline: | COMMENT |
| LOW | python/ray/tests/test_reference_counting_standalone.py | 464 | # make sure to only del the last ref to let ref count go to 0 after actor B's raylet starts pulling that object. | COMMENT |
| LOW⚡ | python/ray/tests/test_placement_group_5.py | 376 | # So we should make sure to wait until actor is scheduled. | COMMENT |
| MEDIUM | python/ray/tests/test_cli_patterns/test_no_head.yaml | 55 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/tests/test_cli_patterns/test_no_head.yaml | 56 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/tests/test_cli_patterns/test_no_head.yaml | 104 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | python/ray/tests/test_cli_patterns/test_no_workers.yaml | 56 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/tests/test_cli_patterns/test_no_workers.yaml | 57 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/tests/test_cli_patterns/test_no_workers.yaml | 105 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | python/ray/_private/node.py | 1019 | # This should work for most cases, especitally | COMMENT |
| MEDIUM | …/client/public/speedscope-1.5.3/speedscope.75eb7d8e.js | 9 | "use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.__DO_NOT_USE__ActionTypes=exports.compose=ex | CODE |
| LOW | python/ray/rllib/algorithms/algorithm.py | 3826 | # way, we make sure to never miss a single stats/counter/timer | COMMENT |
| LOW | python/ray/rllib/algorithms/ppo/ppo.py | 265 | # Don't forget to remove .use_critic from algorithm config. | COMMENT |
| LOW | python/ray/rllib/utils/checkpoints.py | 245 | # provided by the user, make sure to use filesystem. | COMMENT |
| MEDIUM | …llib/examples/metrics/custom_metrics_in_env_runners.py | 31 | For demonstration purposes only, we log the following custom metrics: | STRING |
| MEDIUM | python/ray/rllib/examples/algorithms/classes/vpg.py | 125 | # Just for demonstration purposes, log the number of time steps sampled in this | COMMENT |
| MEDIUM | …hon/ray/rllib/examples/evaluation/custom_evaluation.py | 14 | For demonstration purposes only, we define a simple custom evaluation method that does | STRING |
| MEDIUM | …hon/ray/rllib/examples/evaluation/custom_evaluation.py | 129 | # For demonstration purposes, run through some number of evaluation | COMMENT |
| MEDIUM | python/ray/rllib/examples/ray_tune/custom_experiment.py | 160 | # However, for demonstration purposes, we show here how you can add other, arbitrary | COMMENT |
| MEDIUM | python/ray/rllib/examples/ray_tune/custom_experiment.py | 160 | # However, for demonstration purposes, we show here how you can add other, arbitrary | COMMENT |
| MEDIUM | …ray/rllib/examples/envs/async_gym_env_vectorization.py | 17 | - uses an artificially slow CartPole-v1 environment for demonstration purposes. | STRING |
| MEDIUM | python/ray/rllib/examples/envs/classes/mock_env.py | 65 | # Just generate a random image here for demonstration purposes. | COMMENT |
| MEDIUM | python/ray/train/base_trainer.py | 326 | # Define some dummy inputs for demonstration purposes | STRING |
| LOW | python/ray/train/tests/test_checkpoint.py | 40 | # the pyarrow.fs.MockFileSystem, so we must make sure to return | COMMENT |
| MEDIUM | python/ray/autoscaler/vsphere/defaults.yaml | 37 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/vsphere/defaults.yaml | 38 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/vsphere/example-minimal.yaml | 15 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/vsphere/example-minimal.yaml | 16 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/vsphere/example-full.yaml | 37 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/vsphere/example-full.yaml | 38 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/aliyun/defaults.yaml | 39 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/aliyun/defaults.yaml | 40 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/aliyun/example-full.yaml | 47 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/aliyun/example-full.yaml | 48 | # If you do so, make sure to also set "key_name". | COMMENT |
| MEDIUM | python/ray/autoscaler/aliyun/example-linux.yaml | 46 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/aliyun/example-linux.yaml | 47 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/azure/defaults.yaml | 135 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | python/ray/autoscaler/azure/example-full.yaml | 166 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | python/ray/autoscaler/gcp/defaults.yaml | 32 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/gcp/defaults.yaml | 33 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/gcp/defaults.yaml | 135 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | python/ray/autoscaler/gcp/example-full.yaml | 47 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/gcp/example-full.yaml | 48 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/gcp/example-full.yaml | 161 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | python/ray/autoscaler/gcp/example-gpu-docker.yaml | 41 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/gcp/example-gpu-docker.yaml | 42 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/_private/cli_logger_demoall.py | 4 | # function for demonstration purposes. Primarily useful for tuning color and | COMMENT |
| LOW | python/ray/autoscaler/_private/autoscaler.py | 498 | # Sort based on last used to make sure to keep min_workers that | COMMENT |
| LOW | python/ray/autoscaler/_private/vsphere/node_provider.py | 96 | # make sure to mark newly created nodes as ready | COMMENT |
| LOW | python/ray/autoscaler/_private/gcp/config.py | 575 | # We need to make sure to _create_ the file with the right | COMMENT |
| LOW | python/ray/autoscaler/_private/aws/config.py | 422 | # We need to make sure to _create_ the file with the right | COMMENT |
| MEDIUM | python/ray/autoscaler/local/example-full.yaml | 115 | # has your Ray repo pre-cloned. Then, you can replace the pip installs | COMMENT |
| MEDIUM | …on/ray/autoscaler/local/example-minimal-automatic.yaml | 31 | # If Ray is not already installed on your cluster, you can use setup | COMMENT |
| MEDIUM | python/ray/autoscaler/local/example-minimal-manual.yaml | 18 | # If Ray is not already installed on your cluster, you can use setup | COMMENT |
| MEDIUM | python/ray/autoscaler/aws/defaults.yaml | 37 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| LOW | python/ray/autoscaler/aws/defaults.yaml | 38 | # If you do so, make sure to also set "KeyName" in the head and worker node | COMMENT |
| MEDIUM | python/ray/autoscaler/aws/example-full.yaml | 52 | # By default Ray creates a new private keypair, but you can also use your own. | COMMENT |
| 19 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/ray/tune/tests/tutorial.py | 26 | # In this example, we don't change the model architecture | COMMENT |
| HIGH | python/ray/tune/tests/test_logger.py | 300 | # In this example, this is `self.test_dir`. | COMMENT |
| HIGH | doc/source/rllib/offline.md | 163 | # Define the output path and format. In this example you | COMMENT |
| HIGH | doc/source/rllib/offline.md | 403 | # Define the output path and format. In this example you | COMMENT |
| HIGH | …urce/train/examples/jax/intro-to-jax-trainer/README.md | 612 | # In this example, we use 2 GPUs. | COMMENT |
| HIGH⚡ | doc/source/kuberay/ecosystem/ingress.md | 101 | # 3. In this example, you need to select public subnets (subnets that "Auto-assign public IPv4 address" is Yes on AWS | COMMENT |
| HIGH | …al/pytorch_tutorials_hyperparameter_tuning_tutorial.py | 87 | # In this example, we can specify | COMMENT |
| HIGH | …al/pytorch_tutorials_hyperparameter_tuning_tutorial.py | 369 | # In this example, the ``l1`` and ``l2`` parameters | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | python/ray/data/dataset.py | 6617 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | python/ray/data/dataset.py | 6617 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | python/ray/data/dataset.py | 6628 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | python/ray/data/dataset.py | 6628 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | …/ray/data/_internal/datasource/turbopuffer_datasink.py | 101 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | …/ray/data/_internal/datasource/turbopuffer_datasink.py | 101 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | …/ray/data/_internal/datasource/turbopuffer_datasink.py | 114 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | …/ray/data/_internal/datasource/turbopuffer_datasink.py | 114 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | …/ray/data/_internal/datasource/turbopuffer_datasink.py | 127 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | …/ray/data/_internal/datasource/turbopuffer_datasink.py | 127 | api_key="<YOUR_API_KEY>", | STRING |
| HIGH | doc/source/train/user-guides/experiment-tracking.md | 46 | ray.init(runtime_env={"env_vars": {"WANDB_API_KEY": "your_api_key"}}) | CODE |
| HIGH | doc/source/train/user-guides/experiment-tracking.md | 144 | # This is equivalent to `os.environ["WANDB_API_KEY"] = "your_api_key"` | COMMENT |
| HIGH | doc/source/train/user-guides/experiment-tracking.md | 145 | wandb.login(key="your_api_key") | CODE |
| HIGH | doc/source/train/user-guides/experiment-tracking.md | 197 | ray.init(runtime_env={"env_vars": {"SOME_API_KEY": "your_api_key"}}) | CODE |
| HIGH | doc/source/train/user-guides/experiment-tracking.md | 352 | wandb: ERROR api_key not configured (no-tty). call wandb.login(key=[your_api_key]). | CODE |
| HIGH | doc/source/serve/tutorials/video-analysis/README.md | 97 | PEXELS_API_KEY = os.environ.get("PEXELS_API_KEY") # Or set directly: "your-api-key" | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …/tests/batch/gpu/stages/test_serve_deployment_stage.py | 192 | CODE | |
| MEDIUM | …/tests/batch/gpu/stages/test_serve_deployment_stage.py | 231 | CODE | |
| MEDIUM | …/tests/batch/gpu/stages/test_serve_deployment_stage.py | 350 | CODE | |
| MEDIUM | …/tests/batch/gpu/stages/test_serve_deployment_stage.py | 387 | CODE | |
| MEDIUM | …thon/ray/llm/tests/batch/cpu/stages/test_stage_base.py | 242 | CODE | |
| MEDIUM | …ts/prefill_decode_disagg/test_prefill_decode_disagg.py | 881 | CODE | |
| MEDIUM | python/ray/dag/tests/experimental/actor_defs.py | 78 | CODE | |
| MEDIUM | python/ray/tests/test_basic.py | 1209 | CODE | |
| MEDIUM | python/ray/tests/test_runtime_env_working_dir.py | 369 | CODE | |
| MEDIUM | …hon/ray/tests/test_streaming_generator_backpressure.py | 1439 | CODE | |
| MEDIUM | python/ray/tests/test_baseexceptionandgroup.py | 69 | CODE | |
| MEDIUM | python/ray/tests/test_gcs_fault_tolerance.py | 457 | CODE | |
| MEDIUM | python/ray/tests/test_generators.py | 893 | CODE | |
| MEDIUM | python/ray/tests/test_generators.py | 917 | CODE | |
| MEDIUM | python/ray/tests/test_generators.py | 942 | CODE | |
| MEDIUM | python/ray/tests/test_streaming_generator.py | 317 | CODE | |
| MEDIUM | python/ray/tests/test_streaming_generator.py | 713 | CODE | |
| MEDIUM | python/ray/tests/test_streaming_generator.py | 717 | CODE | |
| MEDIUM | …hon/ray/rllib/core/learner/tests/test_learner_group.py | 190 | CODE | |
| MEDIUM | …hon/ray/rllib/core/learner/tests/test_learner_group.py | 192 | CODE | |
| MEDIUM | python/ray/serve/tests/test_grpc.py | 1231 | CODE | |
| MEDIUM | python/ray/serve/tests/test_grpc.py | 1273 | CODE | |
| MEDIUM | python/ray/serve/tests/test_fastapi.py | 421 | CODE | |
| MEDIUM | python/ray/serve/_private/local_testing_mode.py | 392 | CODE | |
| MEDIUM | python/ray/data/tests/test_map.py | 298 | CODE | |
| MEDIUM | …ray-observability/doc_code/ray-distributed-debugger.py | 24 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …thon/ray/experimental/channel/serialization_context.py | 155 | "placeholder", | CODE |
| LOW | python/ray/llm/examples/sglang/query_example.py | 13 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW⚡ | python/ray/tests/chaos/streaming_llm.py | 53 | words = "Lorem ipsum dolor sit amet".split() | CODE |
| LOW⚡ | python/ray/tests/chaos/streaming_llm.py | 53 | words = "Lorem ipsum dolor sit amet".split() | CODE |
| LOW | python/ray/tests/kuberay/test_kuberay_node_provider.py | 396 | def _mock_token_file(token: str = "fake-token", exists: bool = True): | CODE |
| LOW | python/ray/tests/kuberay/test_kuberay_node_provider.py | 419 | assert headers == {"Authorization": "Bearer fake-token"} | CODE |
| LOW | python/ray/tests/kuberay/test_kuberay_node_provider.py | 433 | assert headers == {"Authorization": "Bearer fake-token"} | CODE |
| LOW | python/ray/tests/kuberay/test_kuberay_node_provider.py | 443 | assert headers == {"Authorization": "Bearer fake-token"} | CODE |
| LOW | python/ray/tests/kuberay/test_kuberay_node_provider.py | 497 | "headers": {"Authorization": "Bearer fake-token"}, | CODE |
| LOW | python/ray/tests/kuberay/test_kuberay_node_provider.py | 518 | "Authorization": "Bearer fake-token", | CODE |
| LOW | python/ray/tests/kuberay/test_kuberay_node_provider.py | 567 | assert kwargs["headers"]["Authorization"] == "Bearer fake-token" | CODE |
| LOW | …/train/v2/tests/test_async_checkpointing_validation.py | 494 | .build_checkpoint_path_from_name("placeholder") | CODE |
| LOW | python/ray/serve/llm/__init__.py | 204 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | STRING |
| LOW | python/ray/serve/llm/__init__.py | 293 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | STRING |
| LOW | python/ray/serve/_private/test_utils.py | 713 | actor_options={"name": "placeholder"}, | CODE |
| LOW | python/ray/data/tests/test_with_column.py | 205 | "expected_first": "John Doe", | CODE |
| LOW | release/llm_tests/serve/test_utils.py | 199 | os.environ["OPENAI_API_KEY"] = api_token or "fake-key" | CODE |
| LOW | release/llm_tests/serve/test_utils.py | 251 | return OpenAI(base_url=f"{server_url}/v1", api_key="fake-key") | CODE |
| LOW | release/llm_tests/serve/test_llm_serve_sglang.py | 71 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | release/llm_tests/serve/test_llm_serve_sglang.py | 355 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | release/llm_tests/serve/test_llm_serve_sglang.py | 425 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | release/llm_tests/serve/test_llm_serve_sglang.py | 490 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | release/llm_tests/serve/test_llm_serve_sglang.py | 559 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW⚡ | release/llm_tests/serve/test_llm_serve_sleep_wakeup.py | 203 | client = OpenAI(base_url=f"{BASE_URL}/v1", api_key="fake-key") | CODE |
| LOW⚡ | release/llm_tests/serve/test_llm_serve_pause_resume.py | 113 | client = OpenAI(base_url=f"{BASE_URL}/v1", api_key="fake-key") | CODE |
| LOW⚡ | release/llm_tests/serve/test_llm_serve_rlhf.py | 129 | client = OpenAI(base_url=f"{BASE_URL}/v1", api_key="fake-key") | CODE |
| LOW | release/ray_release/tests/test_glue.py | 256 | self.command_runner_return["get_last_logs_ex"] = "Lorem ipsum" | CODE |
| LOW | …/doc_code/serve/transcription/transcription_example.py | 85 | client = openai.OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | …urce/llm/doc_code/serve/sglang/sglang_query_example.py | 4 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | doc/source/serve/llm/quick-start.md | 93 | -H "Authorization: Bearer fake-key" \ | CODE |
| LOW | doc/source/serve/llm/quick-start.md | 108 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | doc/source/serve/llm/user-guides/multi-lora.md | 140 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | …ource/serve/llm/user-guides/data-parallel-attention.md | 107 | -H "Authorization: Bearer fake-key" \ | CODE |
| LOW | …ource/serve/llm/user-guides/data-parallel-attention.md | 125 | api_key="fake-key" | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 59 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 78 | -H "Authorization: Bearer fake-key" \ | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 116 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 138 | -H "Authorization: Bearer fake-key" \ | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 191 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 236 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 323 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 403 | client = OpenAI(base_url="http://localhost:8000/v1", api_key="fake-key") | CODE |
| LOW | doc/source/serve/llm/user-guides/vllm-compatibility.md | 424 | -H "Authorization: Bearer fake-key" \ | CODE |
| LOW | doc/source/serve/doc_code/fake_email_creator.yaml | 21 | image: shrekrisanyscale/serve-fake-email-example:example | CODE |
| LOW | doc/source/serve/doc_code/fake_email_creator.yaml | 47 | image: shrekrisanyscale/serve-fake-email-example:example | CODE |
| LOW | doc/source/serve/production-guide/docker.md | 110 | A pre-built version of this image is available at [shrekrisanyscale/serve-fake-email-example](https://hub.docker.com/r/s | CODE |
| LOW | doc/source/serve/tutorials/serve-deepseek.md | 117 | -H "Authorization: Bearer fake-key" \ | CODE |
| LOW | doc/source/serve/tutorials/serve-deepseek.md | 139 | -H "Authorization: Bearer fake-key" \ | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …/cpu/deployments/llm/multiplex/test_multiplex_utils.py | 147 | def test_function(x, y): | CODE |
| LOW | python/ray/util/dask/scheduler_utils.py | 122 | def execute_task(key, task_info, dumps, loads, get_id, pack_exception): | CODE |
| LOW | python/ray/tests/test_basic.py | 1012 | def test_function(fn, remote_fn): | STRING |
| LOW | python/ray/tests/test_basic.py | 1040 | def test_function(fn, remote_fn): | STRING |
| LOW | python/ray/tests/test_basic.py | 1097 | def test_function(fn, remote_fn): | STRING |
| LOW | python/ray/tests/test_args.py | 18 | def test_function(fn, remote_fn): | CODE |
| LOW | python/ray/tests/test_args.py | 50 | def test_function(fn, remote_fn): | CODE |
| LOW | python/ray/tests/test_task_metrics.py | 128 | def my_function(): | CODE |
| LOW⚡ | python/ray/tests/chaos/streaming_llm.py | 45 | async def handle_request(self, prompt: str) -> StreamingResponse: | CODE |
| LOW | python/ray/rllib/utils/actor_manager.py | 225 | def do_something(self): | STRING |
| LOW | python/ray/tune/tests/test_api.py | 640 | def run_task(config): | CODE |
| LOW | python/ray/serve/tests/test_handle_1.py | 363 | async def handle_request(self, request: str): | CODE |
| LOW | python/ray/serve/tests/test_handle_1.py | 406 | async def handle_request(self, request: str): | CODE |
| LOW | python/ray/serve/tests/test_handle_1.py | 439 | async def handle_request(self, request: str): | CODE |
| LOW | python/ray/serve/tests/test_handle_1.py | 477 | async def handle_request(self, request: str): | CODE |
| LOW | python/ray/serve/tests/test_handle_1.py | 527 | async def handle_request(self, request: str): | CODE |
| LOW | python/ray/serve/tests/test_task_processor.py | 612 | def process_data(self, payload): | CODE |
| LOW | python/ray/serve/tests/test_task_processor.py | 681 | def process_data(self, data): | CODE |
| LOW | python/ray/serve/tests/test_actor_replica_wrapper.py | 112 | async def handle_request( | CODE |
| LOW | …rve/tests/test_config_files/ingress_router_fallback.py | 13 | async def handle_request(self, request: Request): | CODE |
| LOW⚡ | …on/ray/serve/tests/typing_files/check_handle_typing.py | 129 | def my_method(self, x: int) -> str: | CODE |
| LOW | python/ray/serve/_private/tracing_utils.py | 179 | def my_function(obj): | STRING |
| LOW | python/ray/serve/_private/replica.py | 1682 | async def handle_request( | CODE |
| LOW | python/ray/serve/_private/replica.py | 3547 | async def handle_request( | CODE |
| LOW⚡ | ci/ray_ci/doc/test_api_param_coverage.py | 384 | def helper(alpha): | STRING |
| LOW | …ve_tests/workloads/multi_deployment_1k_noop_replica.py | 98 | async def handle_request(self, body: bytes, depth: int): | CODE |
| LOW | doc/source/core/doc_code/tasks.py | 16 | def my_function(): | CODE |
| LOW | doc/source/core/doc_code/tasks.py | 115 | def my_function(): | CODE |
| LOW | doc/source/core/doc_code/actor_checkpointing.py | 15 | def execute_task(self, crash=False): | CODE |
| LOW | doc/source/serve/doc_code/streaming_tutorial.py | 39 | def handle_request(self, prompt: str) -> StreamingResponse: | CODE |
| LOW | doc/source/serve/doc_code/streaming_tutorial.py | 126 | async def handle_request(self, ws: WebSocket) -> None: | CODE |
| LOW | doc/source/serve/doc_code/streaming_tutorial.py | 267 | async def handle_request(self, prompt: str) -> StreamingResponse: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/rllib/utils/tests/run_memory_leak_tests.py | 6 | # Example usage: | COMMENT |
| LOW | python/ray/serve/_private/constants.py | 144 | # Example usage: | COMMENT |
| LOW | doc/source/cluster/doc_code/slurm-launch.py | 2 | # Usage: | COMMENT |
| LOW | src/ray/util/shared_lru.h | 20 | // Example usage: | COMMENT |
| LOW | src/ray/util/thread_checker.h | 17 | // Example usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | python/ray/train/__init__.py | 114 | # TODO: consider implementing these in v1 and raising ImportError instead. | COMMENT |
| LOW | …ray/serve/tests/test_deployment_scheduler_downscale.py | 159 | # TODO: Add test for downscale placement group fallback_strategy when it's added to deployment options. | COMMENT |