The live data layer for apps and AI agents. Create up-to-the-second views into your business, just using SQL
This report summarizes scanner evidence for MaterializeInc/materialize, a Rust project with 6,378 GitHub stars. SynthScan examined 1,612,189 lines of code across 6359 source files, recording 6855 pattern matches distributed across 25 syntactic categories. The legacy adjusted pattern signal is 5.5 (Moderate 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? 6072 finding(s).
Are imports declared and package/API names verified? 293 finding(s).
Are wrappers, guards, and repeated structures necessary? 1792 finding(s).
Which changes need focused human review? 6855 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 6855 distinct pattern matches across 25 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 | Cargo.toml | 621 | # staging (and, in an emergency, also prod). | COMMENT |
| LOW | Cargo.toml | 681 | rdkafka = { git = "https://github.com/MaterializeInc/rust-rdkafka.git" } | COMMENT |
| LOW | deny.toml | 21 | # One-time exception for base64 due to its prevalence in the crate graph. | COMMENT |
| LOW | deny.toml | 81 | # Used by launchdarkly-server-sdk-evaluation, prost-build, prost-derive and | COMMENT |
| LOW | deny.toml | 161 | { name = "sha1", version = "0.10.6" }, | COMMENT |
| LOW | pyproject.toml | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/lint/copyright.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | misc/lint/trailing-newline.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | misc/lint/test-attribute.py | 1 | #!/usr/bin/env python3 | COMMENT |
| LOW | misc/python/materialize/sqlsmith.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/rustc_flags.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/deb.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/mzbuild.py | 881 | ) | COMMENT |
| LOW | misc/python/materialize/setup.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/elf.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/test_mz_version.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | …thon/materialize/parallel_workload/worker_exception.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | …hon/materialize/parallel_workload/parallel_workload.py | 221 | read_action_list, | COMMENT |
| LOW | …hon/materialize/parallel_workload/parallel_workload.py | 441 | print(f"{thread.name} still connecting") | COMMENT |
| LOW | …hon/materialize/parallel_workload/parallel_workload.py | 461 | # takes: BackupRestoreAction sleeps up to 240s and then runs a CRDB | COMMENT |
| LOW | …hon/materialize/parallel_workload/parallel_workload.py | 661 | # "still depended upon by" is a RESTRICT drop rejecting a target with | COMMENT |
| LOW | …hon/materialize/parallel_workload/parallel_workload.py | 721 | # broken-action assertion must not fire on them: | COMMENT |
| LOW | misc/python/materialize/parallel_workload/database.py | 1121 | # statement keeps losing the race for the write timestamp. That is a | COMMENT |
| LOW | misc/python/materialize/parallel_workload/database.py | 1861 | COMMENT | |
| LOW | misc/python/materialize/parallel_workload/__init__.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/parallel_workload/action.py | 421 | Scenario.Kill, | COMMENT |
| LOW | misc/python/materialize/parallel_workload/action.py | 1061 | "timeout: error trying to connect", | COMMENT |
| LOW | misc/python/materialize/parallel_workload/action.py | 2281 | # Sealing is transitive: a view reading from a REFRESH AT view seals | COMMENT |
| LOW | misc/python/materialize/parallel_workload/action.py | 3501 | # which the workload does not expect. | COMMENT |
| LOW | misc/python/materialize/parallel_workload/action.py | 4121 | # `mz_now()` is the timestamp the read itself ran at, and comparing | COMMENT |
| LOW | misc/python/materialize/parallel_workload/action.py | 4181 | # ALTER back to the realized shape, Cancelled; | COMMENT |
| LOW | misc/python/materialize/parallel_workload/action.py | 6581 | # TODO: Reenable once altering a connection that sinks or sources depend | COMMENT |
| LOW | misc/python/materialize/parallel_workload/settings.py | 41 | # Scenarios that need durable state across restarts/promotions and therefore run | COMMENT |
| LOW | misc/python/materialize/parallel_workload/settings.py | 61 | # 64 MiB, down from the 1 GiB default. A peek's result is materialized in | COMMENT |
| LOW | …lize/parallel_workload/negative_accumulation_errors.py | 21 | # that may appear in an error surfaced to the client. When the underlying | COMMENT |
| LOW | misc/python/materialize/parallel_workload/expression.py | 341 | # ] | COMMENT |
| LOW | misc/python/materialize/cargo_bench/__init__.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/workload_replay/__init__.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/data_ingest/__init__.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/mzcompose/__init__.py | 41 | "mydata:/var/lib/mysql-files", | COMMENT |
| LOW | misc/python/materialize/mzcompose/loader.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/mzcompose/composition.py | 1841 | """ | COMMENT |
| LOW | misc/python/materialize/mzcompose/helpers/__init__.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/mzcompose/services/clusterd.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/checks/__init__.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/checks/features.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | …n/materialize/checks/all_checks/builtin_version_pin.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | …n/materialize/checks/all_checks/builtin_version_pin.py | 21 | # builtin table at VERSION 0. Once a later binary has converted that builtin | COMMENT |
| LOW | misc/python/materialize/checks/all_checks/subscribe.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | …/materialize/checks/all_checks/upsert_unordered_key.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | …/python/materialize/checks/all_checks/source_errors.py | 101 | # relaxation once we have enough new releasees that there won't | COMMENT |
| LOW | misc/python/materialize/checks/all_checks/pg_cdc.py | 281 | @externally_idempotent(False) | COMMENT |
| LOW | misc/python/materialize/checks/all_checks/__init__.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | …erialize/checks/all_checks/read_then_write_frontier.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | …lize/checks/all_checks/custom_type_resolution_bound.py | 61 | # the new bound and aborts the process. | COMMENT |
| LOW | misc/python/materialize/cli/ci_annotate_errors.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/cli/run.py | 381 | # and then kills `command`'s process group. This avoids leaking "grandchild" | COMMENT |
| LOW | misc/python/materialize/cli/__init__.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/cli/mz_workload_anonymize.py | 421 | word_originals.add(original) | COMMENT |
| LOW | misc/python/materialize/cli/mz_workload_anonymize.py | 461 | # needs valid. Exempt the value literal in the same option position, mirroring | COMMENT |
| 3987 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | misc/python/materialize/source_table_migration.py | 15 | def verify_sources_after_source_table_migration( | CODE |
| LOW | misc/python/materialize/git.py | 180 | def get_tags_of_current_commit(include_tags: YesNoOnce = YesNoOnce.ONCE) -> list[str]: | CODE |
| LOW | misc/python/materialize/git.py | 311 | def try_get_remote_name_by_url(url: str) -> str | None: | CODE |
| LOW | misc/python/materialize/git.py | 335 | def get_common_ancestor_commit(remote: str, branch: str) -> str: | CODE |
| LOW | misc/python/materialize/git.py | 380 | def get_tagged_release_version( | CODE |
| LOW | misc/python/materialize/terminal.py | 28 | def with_conditional_formatting(text: str, formatting: str, condition: bool) -> str: | CODE |
| LOW | misc/python/materialize/mz_0dt_upgrader.py | 42 | def generate_materialized_upgrade_args( | CODE |
| LOW | misc/python/materialize/mz_0dt_upgrader.py | 71 | def generate_random_upgrade_path( | CODE |
| LOW | misc/python/materialize/mz_0dt_upgrader.py | 110 | def create_upgrade_steps_list(self) -> list[UpgradeStep]: | CODE |
| LOW | misc/python/materialize/util.py | 84 | def decompress_zst_to_directory( | CODE |
| LOW | misc/python/materialize/linear.py | 101 | def get_known_issues_from_linear( | STRING |
| LOW | misc/python/materialize/cargo.py | 237 | def transitive_path_dependencies( | CODE |
| LOW | misc/python/materialize/mz_env_util.py | 42 | def connect_and_print_environment_id( | CODE |
| LOW | misc/python/materialize/file_util.py | 23 | def resolve_path_with_wildcard(path: str, root_dir: str | Path = MZ_ROOT) -> set[str]: | CODE |
| LOW | misc/python/materialize/file_util.py | 27 | def resolve_paths_with_wildcard( | CODE |
| LOW | misc/python/materialize/file_util.py | 38 | def _file_list_output_to_list(output: str) -> list[str]: | CODE |
| LOW | misc/python/materialize/docker.py | 36 | def image_of_release_version_exists(version: MzVersion, quiet: bool = False) -> bool: | CODE |
| LOW | misc/python/materialize/docker.py | 51 | def mz_image_tag_exists_cmdline(image_name: str) -> bool: | CODE |
| LOW⚡ | misc/python/materialize/docker.py | 180 | def release_version_to_image_tag(version: MzVersion) -> str: | CODE |
| LOW⚡ | misc/python/materialize/docker.py | 184 | def is_image_tag_of_release_version(image_tag: str) -> bool: | CODE |
| LOW⚡ | misc/python/materialize/docker.py | 192 | def get_version_from_image_tag(image_tag: str) -> str: | CODE |
| LOW⚡ | misc/python/materialize/docker.py | 199 | def get_mz_version_from_image_tag(image_tag: str) -> MzVersion: | CODE |
| LOW | misc/python/materialize/docker.py | 231 | def _resolve_image_name_by_commit_hash(commit_hash: str) -> str: | CODE |
| LOW | misc/python/materialize/docker.py | 254 | def _search_docker_hub_for_image_name( | CODE |
| LOW | misc/python/materialize/docker.py | 292 | def _select_image_name_from_candidates( | CODE |
| LOW | misc/python/materialize/console_version_matrix.py | 21 | def get_console_test_versions() -> dict[str, MzVersion]: | CODE |
| LOW | misc/python/materialize/mzbuild.py | 67 | def run_and_detect_retryable_build_failure( | CODE |
| LOW | misc/python/materialize/mzbuild.py | 262 | def rewrite_builder_path_for_host(self, path: Path) -> Path: | CODE |
| LOW | misc/python/materialize/mzbuild.py | 675 | def generate_cargo_build_command( | CODE |
| LOW | misc/python/materialize/mzbuild.py | 1243 | def is_published_if_necessary(self) -> bool: | CODE |
| LOW | misc/python/materialize/mzbuild.py | 1774 | def _precompute_image_context_files(self) -> None: | CODE |
| LOW | misc/python/materialize/mysql_util.py | 22 | def retrieve_ssl_context_for_mysql(c: Composition) -> MySqlSslContext: | CODE |
| LOW | misc/python/materialize/mysql_util.py | 41 | def retrieve_invalid_ssl_context_for_mysql(c: Composition) -> MySqlSslContext: | CODE |
| LOW | misc/python/materialize/buildkite.py | 81 | def is_pull_request_marker_set() -> bool: | CODE |
| LOW | misc/python/materialize/buildkite.py | 92 | def get_pull_request_base_branch(fallback: str = "main"): | CODE |
| LOW | misc/python/materialize/buildkite.py | 96 | def get_pipeline_default_branch(fallback: str = "main"): | CODE |
| LOW | misc/python/materialize/buildkite.py | 189 | def _upload_shard_info_metadata(items: list[str]) -> None: | CODE |
| LOW | misc/python/materialize/buildkite.py | 207 | def notify_qa_team_about_failure(failure: str) -> None: | CODE |
| LOW | misc/python/materialize/buildkite.py | 254 | def _validate_parallelism_configuration() -> None: | CODE |
| LOW | misc/python/materialize/buildkite.py | 324 | def get_job_url_from_build_url(build_url: str, build_job_id: str) -> str: | CODE |
| LOW | misc/python/materialize/buildkite.py | 328 | def get_job_url_from_pipeline_and_build( | CODE |
| LOW | misc/python/materialize/github.py | 124 | def get_known_issues_from_github( | STRING |
| LOW | misc/python/materialize/test_mz_version.py | 26 | def test_docker_tag_round_trips(tag: str) -> None: | CODE |
| LOW | misc/python/materialize/test_mz_version.py | 31 | def test_docker_tag_suffix_is_build_metadata(tag: str) -> None: | CODE |
| LOW | misc/python/materialize/test_mz_version.py | 52 | def test_docker_tag_against_dev_gate(tag: str, meets_gate: bool) -> None: | CODE |
| LOW | misc/python/materialize/test_mz_version.py | 57 | def test_release_sorts_above_its_prereleases() -> None: | CODE |
| LOW | misc/python/materialize/test_mz_version.py | 75 | def test_drop_dev_suffix_ignores_build_metadata() -> None: | CODE |
| LOW | misc/python/materialize/test_mz_version.py | 82 | def test_dev_version_with_hash() -> None: | CODE |
| LOW | misc/python/materialize/version_ancestor_overrides.py | 18 | def get_ancestor_overrides_for_performance_regressions( | CODE |
| LOW | misc/python/materialize/version_list.py | 41 | def fetch_self_managed_versions() -> list[SelfManagedVersion]: | CODE |
| LOW | misc/python/materialize/version_list.py | 58 | def get_all_self_managed_versions() -> list[MzVersion]: | CODE |
| LOW | misc/python/materialize/version_list.py | 62 | def get_self_managed_versions( | CODE |
| LOW | misc/python/materialize/version_list.py | 83 | def get_compatible_upgrade_from_versions() -> list[MzVersion]: | CODE |
| LOW | misc/python/materialize/version_list.py | 112 | def keep_latest_patch_per_minor(versions: list[MzVersion]) -> list[MzVersion]: | CODE |
| LOW | misc/python/materialize/version_list.py | 173 | def resolve_ancestor_image_tag(ancestor_overrides: dict[str, MzVersion]) -> str | None: | CODE |
| LOW | misc/python/materialize/version_list.py | 199 | def _create_ancestor_image_resolution( | CODE |
| LOW | misc/python/materialize/version_list.py | 208 | def _manual_ancestor_specification_to_image_tag(ancestor_spec: str) -> str: | CODE |
| LOW | misc/python/materialize/version_list.py | 222 | def _get_override_commit_instead_of_version( | CODE |
| LOW | misc/python/materialize/version_list.py | 245 | def _resolve_image_tag_of_previous_release( | CODE |
| LOW | misc/python/materialize/version_list.py | 272 | def _resolve_image_tag_of_previous_release_from_current( | CODE |
| 1220 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | misc/python/materialize/scratch.py | 326 | "npx -q -y skills add MaterializeInc/agent-skills -g -a claude-code --copy -y --skill mz-docs 2>/dev/null || tru | CODE |
| HIGH | misc/python/materialize/scratch.py | 334 | "npx -q -y skills add MaterializeInc/agent-skills -g -a codex --copy -y --skill mz-docs 2>/dev/null || true", | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/jsonb_type.py | 19 | > INSERT INTO jsonb_type_table VALUES ('{"object_element":{"a":"b"},"array_element": [1,2], "string_element" | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/jsonb_type.py | 28 | WITH cte AS (SELECT '{"object_element":{"a":"b"},"array_element": [1,2], "string_element":"abc", "nu | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/jsonb_type.py | 31 | '{"object_element":{"a":"b"},"array_element": [1,2], "string_element":"abc", "number_element":123. | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/jsonb_type.py | 37 | jsonb_col || '{"another_null": null}'::jsonb AS c8, | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/jsonb_type.py | 47 | WITH cte AS (SELECT '{"object_element":{"a":"b"},"array_element": [1,2], "string_element":"abc", "nu | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/jsonb_type.py | 50 | '{"object_element":{"a":"b"},"array_element": [1,2], "string_element":"abc", "number_element":123. | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/jsonb_type.py | 56 | jsonb_col || '{"another_null": null}'::jsonb AS c8, | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/jsonb_type.py | 70 | "{\\"array_element\\":[1,2],\\"boolean_element\\":true,\\"null_element\\":null,\\"number_element\\":123. | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/jsonb_type.py | 71 | "{\\"array_element\\":[1,2],\\"boolean_element\\":true,\\"null_element\\":null,\\"number_element\\":123. | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/jsonb_type.py | 72 | "{\\"array_element\\":[1,2],\\"boolean_element\\":true,\\"null_element\\":null,\\"number_element\\":123. | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/jsonb_type.py | 75 | "{\\"array_element\\":[1,2],\\"boolean_element\\":true,\\"null_element\\":null,\\"number_element\\":123. | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/jsonb_type.py | 76 | "{\\"array_element\\":[1,2],\\"boolean_element\\":true,\\"null_element\\":null,\\"number_element\\":123. | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/jsonb_type.py | 77 | "{\\"array_element\\":[1,2],\\"boolean_element\\":true,\\"null_element\\":null,\\"number_element\\":123. | CODE |
| HIGH | misc/python/materialize/checks/all_checks/webhook.py | 68 | [{"good": "bye"}, 42, null] | CODE |
| HIGH | misc/python/materialize/checks/all_checks/webhook.py | 100 | "[{\\"good\\":\\"bye\\"},42,null]" | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 931 | # {{"before": null, "after": {{"row":{{"f1": 1}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 932 | # {{"before": null, "after": {{"row":{{"f1": 2}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 933 | # {{"before": null, "after": {{"row":{{"f1": 3}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 936 | # {{"before": null, "after": {{"row":{{"f1": 1}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 937 | # {{"before": null, "after": {{"row":{{"f1": 2}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 938 | # {{"before": null, "after": {{"row":{{"f1": 3}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 941 | # {{"before": null, "after": {{"row":{{"f1": 1}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 942 | # {{"before": null, "after": {{"row":{{"f1": 2}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 943 | # {{"before": null, "after": {{"row":{{"f1": 3}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 300 | {"key1": "U2${kafka-ingest.iteration}"} {"f1": {"string": "A${kafka-ingest.iteration}"}, "f2": null} | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 303 | {"key1": "D2${kafka-ingest.iteration}"} {"f1": null, "f2": {"long": ${kafka-ingest.iteration}}} | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 306 | {"key1": "U3${kafka-ingest.iteration}"} {"f1": {"string": "A${kafka-ingest.iteration}"}, "f2": null} | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 309 | {"key1": "D3${kafka-ingest.iteration}"} {"f1": null, "f2": {"long": ${kafka-ingest.iteration}}} | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 371 | {"type":"record","name":"envelope","fields":[{"name":"before","type":["null",{"type":"record","name":"ro | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 374 | {"type":"record","name":"envelope","fields":[{"name":"before","type":["null",{"type":"record","name":"ro | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 377 | {"type":"record","name":"envelope","fields":[{"name":"before","type":["null",{"type":"record","name":"ro | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 537 | {"key1": "U2${kafka-ingest.iteration}"} {"f1": {"string": "A${kafka-ingest.iteration}"}, "f2": null} | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 540 | {"key1": "D2${kafka-ingest.iteration}"} {"f1": null, "f2": {"long": ${kafka-ingest.iteration}}} | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 543 | {"key1": "U3${kafka-ingest.iteration}"} {"f1": {"string": "A${kafka-ingest.iteration}"}, "f2": null} | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 546 | {"key1": "D3${kafka-ingest.iteration}"} {"f1": null, "f2": {"long": ${kafka-ingest.iteration}}} | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 625 | {"type":"record","name":"row","doc":"comment on view sink_source_comments_view","fields":[{"name":"l_v2" | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 628 | {"type":"record","name":"row","doc":"comment on view sink_source_comments_view","fields":[{"name":"l_v2" | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 631 | {"type":"record","name":"row","doc":"comment on view sink_source_comments_view","fields":[{"name":"l_v2" | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 634 | {"type":"record","name":"envelope","fields":[{"name":"before","type":["null",{"type":"record","name":"ro | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 637 | {"type":"record","name":"envelope","fields":[{"name":"before","type":["null",{"type":"record","name":"ro | CODE |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 640 | {"type":"record","name":"envelope","fields":[{"name":"before","type":["null",{"type":"record","name":"ro | CODE |
| HIGH | misc/python/materialize/checks/all_checks/kafka_sink.py | 337 | {"key1": "I2${kafka-ingest.iteration}"} {"f1": {"string": "B${kafka-ingest.iteration}"}, "f2": null} | CODE |
| HIGH | misc/python/materialize/checks/all_checks/kafka_sink.py | 338 | {"key1": "U2${kafka-ingest.iteration}"} {"f1": null, "f2": {"long": ${kafka-ingest.iteration}}} | CODE |
| HIGH | misc/python/materialize/checks/all_checks/kafka_sink.py | 354 | {"key1": "I2${kafka-ingest.iteration}"} {"f1": {"string": "B${kafka-ingest.iteration}"}, "f2": null} | CODE |
| HIGH | misc/python/materialize/checks/all_checks/kafka_sink.py | 355 | {"key1": "U2${kafka-ingest.iteration}"} {"f1": null, "f2": {"long": ${kafka-ingest.iteration}}} | CODE |
| HIGH | misc/python/materialize/checks/all_checks/kafka_sink.py | 581 | {"key1": "I2${kafka-ingest.iteration}"} {"f1": {"string": "B${kafka-ingest.iteration}"}, "f2": null} | CODE |
| HIGH | misc/python/materialize/checks/all_checks/kafka_sink.py | 582 | {"key1": "U2${kafka-ingest.iteration}"} {"f1": null, "f2": {"long": ${kafka-ingest.iteration}}} | CODE |
| HIGH | misc/python/materialize/checks/all_checks/kafka_sink.py | 603 | {"key1": "I2${kafka-ingest.iteration}"} {"f1": {"string": "B${kafka-ingest.iteration}"}, "f2": null} | CODE |
| HIGH | misc/python/materialize/checks/all_checks/kafka_sink.py | 604 | {"key1": "U2${kafka-ingest.iteration}"} {"f1": null, "f2": {"long": ${kafka-ingest.iteration}}} | CODE |
| HIGH | …ython/materialize/checks/all_checks/table_functions.py | 159 | (1, '{"arr": [1, 2], "obj": {"a": 1, "n": null}}') | CODE |
| HIGH⚡ | …thon/materialize/checks/all_checks/alter_connection.py | 179 | # {{"before": null, "after": {{"row":{{"f1": 1}}}}}} | COMMENT |
| HIGH⚡ | …thon/materialize/checks/all_checks/alter_connection.py | 180 | # {{"before": null, "after": {{"row":{{"f1": 2}}}}}} | COMMENT |
| HIGH⚡ | …thon/materialize/checks/all_checks/alter_connection.py | 181 | # {{"before": null, "after": {{"row":{{"f1": 3}}}}}} | COMMENT |
| HIGH | misc/python/materialize/checks/all_checks/ranges.py | 85 | i8_range && INT8RANGE(4,12) AS i8_overlap, | CODE |
| HIGH | …/python/materialize/checks/all_checks/upsert_enrich.py | 32 | {"name":"f1", "type": ["null", "string"], "default": null } | CODE |
| HIGH | …/python/materialize/checks/all_checks/upsert_enrich.py | 48 | {{"key1": "A${{kafka-ingest.iteration}}"}} {{"f1": null}} | CODE |
| HIGH | …/python/materialize/checks/all_checks/upsert_enrich.py | 85 | {{"key1": "B${{kafka-ingest.iteration}}"}} {{"f1": null}} | CODE |
| HIGH | …consistency/input_data/values/jsonb_values_provider.py | 39 | JSONB_DATA_TYPE_WITH_VALUES.add_raw_value("""'{"a": 1,"b": null}'""", "VAL_1C", set()) | CODE |
| 67 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | misc/python/materialize/cargo.py | 93 | except KeyError: | CODE |
| HIGH | misc/python/materialize/cargo.py | 188 | except KeyError: | CODE |
| HIGH | misc/python/materialize/scratch.py | 537 | except ClientError: | CODE |
| HIGH | misc/python/materialize/parallel_workload/action.py | 4861 | except: | CODE |
| HIGH | misc/python/materialize/parallel_workload/action.py | 4865 | except: | CODE |
| HIGH | misc/python/materialize/parallel_workload/action.py | 1835 | except ValueError: | CODE |
| HIGH | misc/python/materialize/parallel_workload/action.py | 2128 | except QueryError: | CODE |
| HIGH | misc/python/materialize/parallel_workload/action.py | 3731 | except ValueError: | CODE |
| HIGH | misc/python/materialize/parallel_workload/action.py | 4856 | except: | CODE |
| HIGH | misc/python/materialize/parallel_workload/action.py | 4976 | except QueryError: | CODE |
| HIGH | misc/python/materialize/parallel_workload/action.py | 192 | except Exception: | CODE |
| HIGH | misc/python/materialize/parallel_workload/action.py | 2869 | except QueryError: | CODE |
| HIGH | misc/python/materialize/parallel_workload/action.py | 5472 | except QueryError: | CODE |
| HIGH | misc/python/materialize/parallel_workload/action.py | 5574 | except QueryError: | CODE |
| HIGH | misc/python/materialize/parallel_workload/action.py | 5680 | except QueryError: | CODE |
| HIGH | misc/python/materialize/parallel_workload/executor.py | 296 | except psycopg.DataError: | CODE |
| HIGH | misc/python/materialize/workload_replay/replay.py | 53 | except Exception: | CODE |
| HIGH | misc/python/materialize/workload_replay/replay.py | 146 | except psycopg.errors.QueryCanceled: | CODE |
| HIGH | misc/python/materialize/workload_replay/executor.py | 419 | except: | CODE |
| HIGH | misc/python/materialize/workload_replay/executor.py | 385 | except: | CODE |
| HIGH | misc/python/materialize/data_ingest/executor.py | 377 | except Exception: | CODE |
| HIGH | misc/python/materialize/mzcompose/composition.py | 1052 | except Exception: | CODE |
| HIGH | misc/python/materialize/mzcompose/composition.py | 1793 | except: | CODE |
| HIGH | misc/python/materialize/mzcompose/composition.py | 1038 | except OSError: | CODE |
| HIGH | misc/python/materialize/mzcompose/composition.py | 1385 | except Exception: | CODE |
| HIGH | misc/python/materialize/cli/run.py | 402 | except ProcessLookupError: | CODE |
| HIGH | misc/python/materialize/cli/orchestratord.py | 185 | except subprocess.CalledProcessError: | CODE |
| HIGH | misc/python/materialize/cli/orchestratord.py | 250 | except subprocess.CalledProcessError: | CODE |
| HIGH | misc/python/materialize/cli/mzcompose.py | 215 | except ValueError: | CODE |
| HIGH | misc/python/materialize/cli/gen-lints.py | 289 | except: | CODE |
| HIGH | misc/python/materialize/cli/scratch/claude.py | 104 | except ValueError: | CODE |
| HIGH | misc/python/materialize/cli/scratch/__init__.py | 70 | except ValueError: | CODE |
| HIGH | misc/python/materialize/cli/scratch/go.py | 90 | except RuntimeError: | CODE |
| HIGH | misc/python/materialize/benches/avro_ingest.py | 168 | except ProgrammingError: | CODE |
| HIGH | …thon/materialize/cloudtest/k8s/api/k8s_cluster_role.py | 34 | except ApiException: | CODE |
| HIGH | …thon/materialize/cloudtest/k8s/api/k8s_role_binding.py | 37 | except ApiException: | CODE |
| HIGH | …python/materialize/cloudtest/k8s/api/k8s_config_map.py | 33 | except ApiException: | CODE |
| HIGH | misc/python/materialize/cloudtest/k8s/api/k8s_secret.py | 37 | except ApiException: | CODE |
| HIGH | …/python/materialize/cloudtest/k8s/api/k8s_configmap.py | 33 | except ApiException: | CODE |
| HIGH | misc/python/materialize/mzexplore/common.py | 120 | except KeyError: | CODE |
| HIGH | misc/python/materialize/mzexplore/common.py | 128 | except ValueError: | CODE |
| HIGH | misc/mcp-materialize/mcp_materialize/mz_client.py | 98 | except (TimeoutError, asyncio.CancelledError): | CODE |
| HIGH | misc/dbt-materialize/tests/adapter/test_deploy.py | 1526 | except psycopg2.Error: | CODE |
| HIGH | test/cluster-spec-sheet/mzcompose.py | 3663 | except Exception: | CODE |
| HIGH | test/cluster-spec-sheet/mzcompose.py | 3835 | except Exception: | CODE |
| HIGH | test/terraform/mzcompose.py | 185 | except subprocess.CalledProcessError: | CODE |
| HIGH | test/terraform/mzcompose.py | 259 | except: | CODE |
| HIGH | test/terraform/mzcompose.py | 1549 | except subprocess.CalledProcessError: | CODE |
| HIGH | test/terraform/mzcompose.py | 1689 | except subprocess.CalledProcessError: | CODE |
| HIGH | test/terraform/mzcompose.py | 1937 | except subprocess.CalledProcessError: | CODE |
| HIGH | test/cluster/mzcompose.py | 5172 | except DivisionByZero: | CODE |
| HIGH | test/cluster/mzcompose.py | 4575 | except DatabaseError: | CODE |
| HIGH | test/cluster/mzcompose.py | 4584 | except DatabaseError: | CODE |
| HIGH | test/cluster/mzcompose.py | 6078 | except DatabaseError: | CODE |
| HIGH | test/orchestratord/mzcompose.py | 303 | except: | CODE |
| HIGH | test/orchestratord/mzcompose.py | 307 | except: | CODE |
| HIGH | test/orchestratord/mzcompose.py | 393 | except: | CODE |
| HIGH | test/orchestratord/mzcompose.py | 4955 | except StopIteration: | CODE |
| HIGH | test/orchestratord/mzcompose.py | 5260 | except subprocess.CalledProcessError: | CODE |
| HIGH | test/orchestratord/mzcompose.py | 488 | except: | CODE |
| 59 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | misc/python/materialize/cli/optbench.py | 27 | # --------------------- | COMMENT |
| MEDIUM | misc/python/materialize/cli/optbench.py | 300 | # --------------- | COMMENT |
| MEDIUM | misc/python/materialize/cli/mzexplore.py | 22 | # --------------------- | COMMENT |
| MEDIUM | misc/python/materialize/cli/mzexplore.py | 422 | # ---------- | COMMENT |
| MEDIUM | misc/python/materialize/optbench/sql.py | 147 | # ----------------- | COMMENT |
| MEDIUM | misc/python/materialize/mzexplore/sql.py | 142 | # ----------------- | COMMENT |
| MEDIUM | misc/python/materialize/mzexplore/extract.py | 78 | # ------------------------------------- | STRING |
| MEDIUM | misc/python/materialize/mzexplore/extract.py | 378 | # ------------------------------------- | STRING |
| MEDIUM | misc/python/materialize/mzexplore/extract.py | 450 | # --------------- | STRING |
| MEDIUM | misc/python/materialize/mzexplore/clone.py | 66 | # -------------------- | STRING |
| MEDIUM⚡ | misc/dbt-materialize/tests/adapter/test_strict_mode.py | 472 | # ============================================================================= | COMMENT |
| MEDIUM⚡ | misc/dbt-materialize/tests/adapter/test_strict_mode.py | 474 | # ============================================================================= | COMMENT |
| MEDIUM | test/canary-environment/mzcompose.py | 291 | # ── 1. Upstream RDS/MySQL setup (outside Materialize) ───────────────── | COMMENT |
| MEDIUM | test/canary-environment/mzcompose.py | 362 | # ── 2. BigLake namespace ────────────────────────────────────────────── | STRING |
| MEDIUM | test/canary-environment/mzcompose.py | 375 | # ── 3. mz-deploy: setup + apply infrastructure ──────────────────────── | STRING |
| MEDIUM | test/canary-environment/mzcompose.py | 383 | # ── 4. testdrive-managed objects ────────────────────────────────────── | STRING |
| MEDIUM | test/canary-environment/mzcompose.py | 496 | # ── 5. mz-deploy: deploy views/MVs blue-green ───────────────────────── | STRING |
| MEDIUM | test/mz-deploy/mzcompose.py | 274 | # ── 1. Initial apply ───────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 334 | # ── 2. Idempotent re-apply ──────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 371 | # ── 3. Incremental apply: add table ─────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 423 | # ── 4. Modify connection ────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 440 | # ── 5. Grant changes ───────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 457 | # ── 6. Run unit tests ───────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 488 | # ── 7. Stage ────────────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 513 | # ── 8. Wait ────────────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 519 | # ── 9. Promote ─────────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 564 | # ── 10. Log ────────────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 570 | # ── 11-12. Stage v2 ─────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 587 | # ── 13. Abort v2 ───────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 601 | # ── 14. Re-stage v2 + promote ───────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 642 | # ── 15-16. Stage v3 ─────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 655 | # ── 17. Abort v3 ───────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 669 | # ── 18. Re-stage v3 + promote ───────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 716 | # ── 1. Apply default profile ────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 810 | # ── 3. Apply staging profile ────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 926 | # ── 5. Idempotent re-apply for both profiles ────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 1449 | # ── Happy path: lock with system-schema deps ────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 1469 | # ── Stage path: a project that reads a system catalog must deploy ───── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 1490 | # ── Negative case: 2-part non-system dep is rejected ────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2079 | # ── 1. Initial baseline apply ──────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2211 | # ── 1. Apply infrastructure ────────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2226 | # ── 2. Stage v1: sink is deferred ──────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2254 | # ── 3. Promote v1: deferred sink is created ────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2291 | # ── 4. Stage v2 (MV definition changed) ────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2302 | # ── 5. Promote v2: sink is repointed, not recreated ────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2402 | # ── 2. Stage v2: only the stable MV changed ────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2427 | # ── 3. Promote v2: APPLY REPLACEMENT, no swap, no repoint ──────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2491 | # ── 1. Baseline: deploy v1 so subsequent stages diff against it ────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2507 | # ── 2. Stage both deployments side by side ─────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2542 | # ── 3. Promote ca, then cb — no conflicts, no --force ──────────── | COMMENT |
| MEDIUM | src/mz-deploy/src/cli/executor.rs | 21 | //! ┌──────────────────┼───────────────────┐ | COMMENT |
| MEDIUM⚡ | src/mz-deploy/src/client/deployment_ops.rs | 21 | //! ┌──────────┐ all objects hydrated ┌───────┐ | COMMENT |
| MEDIUM⚡ | src/mz-deploy/src/client/deployment_ops.rs | 22 | //! │ Hydrating │ ────────────────────────▶ │ Ready │ | COMMENT |
| MEDIUM⚡ | src/mz-deploy/src/client/deployment_ops.rs | 23 | //! └──────────┘ & lag ≤ threshold └───────┘ | COMMENT |
| MEDIUM⚡ | src/mz-deploy/src/client/deployment_ops.rs | 25 | //! │ lag > threshold ┌─────────┐ | COMMENT |
| MEDIUM⚡ | src/mz-deploy/src/client/deployment_ops.rs | 26 | //! └────────────────────────────────▶ │ Lagging │ | COMMENT |
| MEDIUM⚡ | src/mz-deploy/src/client/deployment_ops.rs | 27 | //! └─────────┘ | COMMENT |
| MEDIUM⚡ | src/mz-deploy/src/client/deployment_ops.rs | 30 | //! ┌─────────┐ | COMMENT |
| MEDIUM⚡ | src/mz-deploy/src/client/deployment_ops.rs | 32 | //! └─────────┘ | COMMENT |
| MEDIUM | src/catalog/src/builtin/ontology.rs | 213 | // ── View builders ──────────────────────────────────────────── | COMMENT |
| 81 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | misc/python/materialize/mzbuild.py | 1092 | profile = self.image.rd.profile.name.lower() | CODE |
| CRITICAL | src/row-spine/src/lib.rs | 288 | from_chunks.0.storage.keys.has_codec() && from_chunks.0.storage.vals.vals.has_codec(), | CODE |
| CRITICAL | src/persist-client/src/cache.rs | 424 | self.metrics.pubsub_client.receiver.diff_applied.inc(); | CODE |
| CRITICAL | src/persist-client/src/read.rs | 1734 | subscribe.listen.handle.machine.applier.seqno_since(), | CODE |
| CRITICAL | src/persist-client/src/read.rs | 1741 | let mut seqno_since = subscribe.listen.handle.machine.applier.seqno_since(); | CODE |
| CRITICAL | src/persist-client/src/read.rs | 1796 | let new_seqno_since = subscribe.listen.handle.machine.applier.seqno_since(); | CODE |
| CRITICAL | src/persist-client/src/schema.rs | 124 | self.maps.key_by_id.metrics.computed_count.inc(); | CODE |
| CRITICAL | src/persist-client/src/schema.rs | 130 | self.maps.val_by_id.metrics.computed_count.inc(); | CODE |
| CRITICAL | src/persist-client/src/schema.rs | 195 | self.applier.metrics.schema.cache_fetch_state_count.inc(); | CODE |
| CRITICAL | src/persist-client/src/rpc.rs | 708 | self.metrics.pubsub_client.sender.push.succeeded.inc(); | CODE |
| CRITICAL⚡ | src/persist-client/src/internal/encoding.rs | 964 | applier_version: self.state.state.collections.version.to_string(), | CODE |
| CRITICAL⚡ | src/persist-client/src/internal/encoding.rs | 973 | last_gc_req: self.state.state.collections.last_gc_req.into_proto(), | CODE |
| CRITICAL⚡ | src/persist-client/src/internal/encoding.rs | 974 | active_rollup: self.state.state.collections.active_rollup.into_proto(), | CODE |
| CRITICAL⚡ | src/persist-client/src/internal/encoding.rs | 975 | active_gc: self.state.state.collections.active_gc.into_proto(), | CODE |
| CRITICAL | src/persist-client/src/internal/encoding.rs | 1017 | trace: Some(self.state.state.collections.trace.into_proto()), | CODE |
| CRITICAL | src/persist-client/src/internal/gc.rs | 160 | machine.applier.metrics.gc.started.inc(); | CODE |
| CRITICAL | src/persist-client/src/internal/gc.rs | 172 | machine.applier.metrics.gc.finished.inc(); | CODE |
| CRITICAL | src/persist-client/src/internal/gc.rs | 265 | machine.applier.metrics.gc.noop.inc(); | CODE |
| CRITICAL | src/persist-client/src/internal/metrics.rs | 3314 | self.metrics.blob.set.bytes.inc_by(u64::cast_from(bytes)); | CODE |
| CRITICAL | src/persist-client/src/internal/metrics.rs | 3329 | self.metrics.blob.delete.bytes.inc_by(u64::cast_from(bytes)); | CODE |
| CRITICAL | src/persist-client/src/internal/machine.rs | 565 | self.applier.metrics.cmds.compare_and_append_noop.inc(); | CODE |
| CRITICAL | src/persist-client/src/internal/machine.rs | 934 | Wake::Watch(_) => self.applier.metrics.watch.wait_woken_via_watch.inc(), | CODE |
| CRITICAL | src/persist-client/src/internal/machine.rs | 936 | self.applier.metrics.watch.wait_woken_via_sleep.inc(); | CODE |
| CRITICAL | src/persist-client/src/internal/machine.rs | 951 | Wake::Watch(_) => self.applier.metrics.watch.wait_resolved_via_watch.inc(), | CODE |
| CRITICAL | src/persist-client/src/internal/machine.rs | 952 | Wake::Sleep(_) => self.applier.metrics.watch.wait_resolved_via_sleep.inc(), | CODE |
| CRITICAL | src/persist-client/src/cli/admin.rs | 752 | machine.applier.metrics.compaction.requested.inc(); | CODE |
| CRITICAL | src/persist-client/src/cli/admin.rs | 767 | machine.applier.metrics.compaction.admin_count.inc(); | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 66 | {# Step 1: Only run validation when strict_mode is enabled #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 69 | {# Step 2: Initialize list to collect conflicting objects #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 72 | {# Step 3: Iterate through all nodes in the dbt manifest #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 75 | {# Step 4: Get this node's cluster (explicit or default) #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 78 | {# Step 5: Check if this node is on the same cluster #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 81 | {# Step 6: Record any object that isn't the current source #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 120 | {# Step 1: Only run validation when strict_mode is enabled #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 123 | {# Step 2: Initialize list to collect conflicting objects #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 126 | {# Step 3: Iterate through all nodes in the dbt manifest #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 129 | {# Step 4: Get this node's cluster (explicit or default) #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 132 | {# Step 5: Check if this node is on the same cluster #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 137 | {# Step 6: Record any non-sink object #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 145 | {# Step 7: If any conflicts were found, raise a compiler error #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 172 | {# Step 1: Only run validation when strict_mode is enabled #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 175 | {# Step 2: Initialize flags to track isolated types #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 179 | {# Step 3: Iterate through all nodes in the dbt manifest #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 182 | {# Step 4: Get this node's cluster (explicit or default) #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 185 | {# Step 5: Check if this node is on the same cluster #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 188 | {# Step 6: Check if this node is a source or sink #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 198 | {# Step 7: If cluster contains sources, block creation #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 207 | {# Step 8: If cluster contains sinks, block creation #} | CODE |
| LOW | …aterialize/macros/utils/validate_cluster_isolation.sql | 93 | {# Step 7: If any conflicts were found, raise a compiler error #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 51 | {# Step 1: Only run validation when strict_mode is enabled #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 54 | {# Step 2: Initialize list to collect forbidden materialization types #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 60 | {# Step 3: Iterate through all nodes in the dbt manifest #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 63 | {# Step 4: Check if this node is in the same schema and database #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 68 | {# Step 5: If the node's materialization type is not allowed, record it #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 76 | {# Step 6: Remove duplicates from the list #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 79 | {# Step 7: If any forbidden types were found, raise a compiler error #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 105 | {# Step 1: Only run validation when strict_mode is enabled #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 108 | {# Step 2: Initialize list to collect forbidden materialization types #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 111 | {# Step 3: Iterate through all nodes in the dbt manifest #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 114 | {# Step 4: Check if this node is in the same schema and database #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 119 | {# Step 5: If the node is not a sink, record its type #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 127 | {# Step 6: Remove duplicates from the list #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 130 | {# Step 7: If any forbidden types were found, raise a compiler error #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 156 | {# Step 1: Only run validation when strict_mode is enabled #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 159 | {# Step 2: Initialize list to collect forbidden materialization types #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 162 | {# Step 3: Iterate through all nodes in the dbt manifest #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 165 | {# Step 4: Check if this node is in the same schema and database #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 170 | {# Step 5: If the node is not a source, record its type #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 178 | {# Step 6: Remove duplicates from the list #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 181 | {# Step 7: If any forbidden types were found, raise a compiler error #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 208 | {# Step 1: Only run validation when strict_mode is enabled #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 211 | {# Step 2: Initialize flags to track if we find isolated types #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 216 | {# Step 3: Iterate through all nodes in the dbt manifest #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 219 | {# Step 4: Check if this node is in the same schema and database #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 222 | {# Step 5: Check if this node is a source, sink, or source_table #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 234 | {# Step 6: If schema contains sources, block creation of this object #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 243 | {# Step 7: If schema contains sinks, block creation of this object #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 252 | {# Step 8: If schema contains source_tables, block creation of this object #} | CODE |
| LOW⚡ | test/orchestratord/mzcompose.py | 3330 | # Step 5: Server-side apply a partial v1 manifest that does not contain | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3064 | # Step 1: Deploy with v1, complete initial rollout. | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3081 | # Step 2: Re-apply the same spec at v1 (no changes). | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3100 | # Step 3: Apply at v1 with a spec change (extra env var). | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3232 | # Step 1: Deploy at v1alpha1 with client-side apply and complete the | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3264 | # Step 2: Server-side apply the same spec at v1. Reconciling the | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3295 | # Step 3: Server-side re-apply the unchanged v1 spec (the routine GitOps | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3306 | # Step 4: Server-side apply a partial v1 manifest under a dedicated field | COMMENT |
| LOW⚡ | test/cloudtest/test_privatelink_connection.py | 290 | # Step 1: Deploy a single Toxiproxy instance | STRING |
| 138 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | misc/python/materialize/cargo.py | 56 | CODE | |
| LOW | misc/python/materialize/cargo.py | 160 | CODE | |
| LOW | misc/python/materialize/cargo.py | 191 | CODE | |
| LOW | misc/python/materialize/cargo.py | 214 | CODE | |
| LOW | misc/python/materialize/scratch.py | 275 | CODE | |
| LOW | misc/python/materialize/docker.py | 89 | CODE | |
| LOW | misc/python/materialize/docker.py | 203 | CODE | |
| LOW | misc/python/materialize/mzbuild.py | 67 | CODE | |
| LOW | misc/python/materialize/mzbuild.py | 291 | CODE | |
| LOW | misc/python/materialize/mzbuild.py | 372 | CODE | |
| LOW | misc/python/materialize/mzbuild.py | 819 | CODE | |
| LOW | misc/python/materialize/mzbuild.py | 955 | CODE | |
| LOW | misc/python/materialize/mzbuild.py | 1209 | CODE | |
| LOW | misc/python/materialize/mzbuild.py | 1431 | CODE | |
| LOW | misc/python/materialize/mzbuild.py | 1579 | CODE | |
| LOW | misc/python/materialize/sqlancer.py | 121 | CODE | |
| LOW | misc/python/materialize/sqlancer.py | 180 | CODE | |
| LOW | misc/python/materialize/buildkite.py | 126 | CODE | |
| LOW | misc/python/materialize/version_list.py | 620 | CODE | |
| LOW | misc/python/materialize/parallel_workload/worker.py | 163 | CODE | |
| LOW | …hon/materialize/parallel_workload/parallel_workload.py | 94 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 123 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 163 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 528 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 1124 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 1269 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 1326 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 1575 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 2412 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 2624 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 3638 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 3920 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 4550 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 4818 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 5430 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 5530 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 5636 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 634 | CODE | |
| LOW | misc/python/materialize/parallel_workload/expression.py | 363 | CODE | |
| LOW | misc/python/materialize/parallel_workload/executor.py | 143 | CODE | |
| LOW | misc/python/materialize/parallel_workload/executor.py | 195 | CODE | |
| LOW | misc/python/materialize/parallel_workload/executor.py | 216 | CODE | |
| LOW | misc/python/materialize/parallel_workload/executor.py | 232 | CODE | |
| LOW | misc/python/materialize/workload_replay/ingest.py | 401 | CODE | |
| LOW | misc/python/materialize/workload_replay/replay.py | 73 | CODE | |
| LOW | misc/python/materialize/workload_replay/replay.py | 193 | CODE | |
| LOW | misc/python/materialize/workload_replay/objects.py | 44 | CODE | |
| LOW | misc/python/materialize/workload_replay/objects.py | 577 | CODE | |
| LOW | misc/python/materialize/workload_replay/data.py | 59 | CODE | |
| LOW | misc/python/materialize/workload_replay/data.py | 105 | CODE | |
| LOW | misc/python/materialize/workload_replay/data.py | 271 | CODE | |
| LOW | misc/python/materialize/workload_replay/data.py | 330 | CODE | |
| LOW | misc/python/materialize/workload_replay/data.py | 489 | CODE | |
| LOW | misc/python/materialize/workload_replay/data.py | 517 | CODE | |
| LOW | misc/python/materialize/workload_replay/data.py | 615 | CODE | |
| LOW | misc/python/materialize/workload_replay/data.py | 700 | CODE | |
| LOW | misc/python/materialize/workload_replay/column.py | 60 | CODE | |
| LOW | misc/python/materialize/workload_replay/column.py | 123 | CODE | |
| LOW | misc/python/materialize/workload_replay/column.py | 150 | CODE | |
| LOW | misc/python/materialize/workload_replay/column.py | 282 | CODE | |
| 191 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | misc/python/materialize/mzbuild.py | 72 | """This function is complex since it prints out each line immediately to | STRING |
| MEDIUM | misc/python/materialize/github.py | 285 | # Creating a release for a nonexistent tag would silently create the tag | COMMENT |
| MEDIUM | misc/python/materialize/mzcompose/helpers/iceberg.py | 269 | # Create a dedicated database for Polaris so its internal tables don't | COMMENT |
| MEDIUM | misc/python/materialize/checks/all_checks/pg_cdc.py | 102 | # Create a view with a complex dependency structure | COMMENT |
| MEDIUM | …/python/materialize/checks/all_checks/password_auth.py | 25 | # Create a user with a password `user1` and grant them privileges to select from table materialize.schem | COMMENT |
| MEDIUM | …python/materialize/checks/all_checks/sql_server_cdc.py | 100 | # Create a view with a complex dependency structure | COMMENT |
| MEDIUM | …n/materialize/checks/all_checks/cluster_unification.py | 40 | # Create the other type of object as a second object in the cluster that | STRING |
| MEDIUM | misc/python/materialize/release/auto_cut_release.py | 63 | # Create the release page in the docs for the next version after the one | COMMENT |
| MEDIUM | misc/python/materialize/parallel_benchmark/scenarios.py | 510 | # Create the schema, tables, and roles as mz_system so it owns them and can grant on them, | COMMENT |
| MEDIUM | misc/python/materialize/scalability/__init__.py | 10 | # This file is needed as otherwise pytest --doctest-module can not | COMMENT |
| MEDIUM | …erialize/feature_benchmark/scenarios/benchmark_main.py | 1610 | # Create a fresh source table and sink for each run. | STRING |
| MEDIUM⚡ | misc/dbt-materialize/mzcompose.py | 93 | # Create a topic that some tests rely on | COMMENT |
| MEDIUM | misc/dbt-materialize/tests/adapter/test_ci.py | 75 | # Create the cluster for the first time | COMMENT |
| MEDIUM | misc/dbt-materialize/tests/adapter/test_ci.py | 140 | # Create a cluster and add an object to it | COMMENT |
| MEDIUM | test/cluster-spec-sheet/mzcompose.py | 3625 | # Create a temporary override of the materialized service with updated CPU limits. | COMMENT |
| MEDIUM | test/terraform/aws-upgrade/main.tf | 141 | # Create a generic nodeclass and nodepool for system workloads | COMMENT |
| MEDIUM | test/terraform/aws-upgrade/main.tf | 176 | # Create a dedicated nodeclass and nodepool for Materialize pods | COMMENT |
| MEDIUM | test/terraform/aws-persistent/main.tf | 141 | # Create a generic nodeclass and nodepool for system workloads | COMMENT |
| MEDIUM | test/terraform/aws-persistent/main.tf | 176 | # Create a dedicated nodeclass and nodepool for Materialize pods | COMMENT |
| MEDIUM | test/terraform/aws-temporary/main.tf | 141 | # Create a generic nodeclass and nodepool for system workloads | COMMENT |
| MEDIUM | test/terraform/aws-temporary/main.tf | 176 | # Create a dedicated nodeclass and nodepool for Materialize pods | COMMENT |
| MEDIUM | test/sql-server-resumption-old-syntax/mzcompose.py | 95 | # Create a custom SqlServer service that runs as root to fix disk permissions for backup. | COMMENT |
| MEDIUM | test/dyncfg/mzcompose.py | 35 | # Create a ConfigMap with the system parameters in JSON format | COMMENT |
| MEDIUM | test/mysql-cdc/mzcompose.py | 277 | # Create the source. | STRING |
| MEDIUM | test/cluster/mzcompose.py | 169 | # Create a cluster and verify that tests pass. | COMMENT |
| MEDIUM | test/cluster/mzcompose.py | 3534 | # Create a cluster and wait for it to come up. | COMMENT |
| MEDIUM | test/cluster/mzcompose.py | 3699 | # Create a managed cluster with a custom replica name. | COMMENT |
| MEDIUM | test/cluster/mzcompose.py | 4135 | # Create an MV reading from an index. Make sure it doesn't produce its | COMMENT |
| MEDIUM | test/cluster/mzcompose.py | 3621 | # Create a managed cluster and wait for it to come up. | STRING |
| MEDIUM | test/cluster/mzcompose.py | 5868 | # Create a REFRESH MV and wait for it to refresh once, then take down | STRING |
| MEDIUM | test/cluster/mzcompose.py | 5943 | # Create an unmanaged cluster that isn't restarted together with materialized, | STRING |
| MEDIUM | test/cluster/mzcompose.py | 7316 | # Create a pause-able cluster, with indexes with different kinds of inputs. | STRING |
| MEDIUM | test/cluster/mzcompose.py | 7737 | # Create a postgres source and wait until it's caught up. | STRING |
| MEDIUM | test/cluster/mzcompose.py | 7964 | # Create a replacement. It's as-of will be derived from mv2's since. | STRING |
| MEDIUM | test/cluster/mzcompose.py | 7998 | # Create a materialized view and a replacement. | STRING |
| MEDIUM | test/cluster/mzcompose.py | 8054 | # Create a materialized view and a replacement. | STRING |
| MEDIUM | test/cluster/mzcompose.py | 8304 | # Create a cluster with an optimizer feature override, to test that | STRING |
| MEDIUM | test/cluster/mzcompose.py | 8421 | # Create a materialized view to generate compute activity. | STRING |
| MEDIUM | test/orchestratord/mzcompose.py | 1291 | # Create a configmap with system parameters | COMMENT |
| MEDIUM | test/orchestratord/mzcompose.py | 2291 | # Create the secret with ca.crt, tls.crt, and tls.key | COMMENT |
| MEDIUM | test/sql-server-cdc/mzcompose.py | 345 | # Create a concurrent workload with 2 variaties of updates | STRING |
| MEDIUM | test/launchdarkly/mzcompose.py | 112 | # Create a LaunchDarkly client that simulates somebody interacting | COMMENT |
| MEDIUM | test/launchdarkly/mzcompose.py | 131 | # Create a test feature flag unique for this test run. Based on the | COMMENT |
| MEDIUM | test/canary-environment/mzcompose.py | 292 | # Create the replicated tables, publication, and the cron/event jobs that | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2620 | # Creating the cluster from the definition file carries the policy. | COMMENT |
| MEDIUM | test/restart/mzcompose.py | 404 | # Creating a new replica of the disabled size is rejected. | COMMENT |
| MEDIUM | test/restart/mzcompose.py | 1074 | # Create a schema with a custom type, then exercise every object kind that | COMMENT |
| MEDIUM | test/restart/mzcompose.py | 797 | # Create a replica and wait for metrics data to arrive. | STRING |
| MEDIUM | test/lang/python/smoketest.py | 129 | # Create a table with one row of data. | COMMENT |
| MEDIUM | test/lang/python/smoketest.py | 174 | # Create a table with one row of data. | COMMENT |
| MEDIUM | test/lang/python/smoketest.py | 227 | # Create a table with one row of data. | COMMENT |
| MEDIUM | test/lang/python/smoketest.py | 288 | # Create a dummy subscribe that we know will only ever | COMMENT |
| MEDIUM | test/source-sink-errors/mzcompose.py | 95 | # Create a source and a sink | COMMENT |
| MEDIUM | test/source-sink-errors/mzcompose.py | 163 | # Create a source and a sink | STRING |
| MEDIUM | test/source-sink-errors/mzcompose.py | 265 | # Create a source and a sink | STRING |
| MEDIUM | test/source-sink-errors/mzcompose.py | 361 | # Create a source and a sink | STRING |
| MEDIUM⚡ | test/aws-localstack/mzcompose.py | 131 | # Create an orphaned secret that should get deleted when starting environmentd. | COMMENT |
| MEDIUM⚡ | test/aws-localstack/mzcompose.py | 139 | # Create an orphaned secret without the correct tags, so it should be ignored. | COMMENT |
| MEDIUM⚡ | test/aws-localstack/mzcompose.py | 146 | # Create a secret for a different environment, so it should be ignored. | COMMENT |
| MEDIUM | test/aws/mzcompose.py | 125 | # Create a user with an access key. | STRING |
| 21 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | misc/lint/copyright.py | 66 | except Exception as e: | CODE |
| LOW | misc/python/materialize/source_table_migration.py | 55 | except Exception as e: | CODE |
| LOW | misc/python/materialize/git.py | 212 | except Exception as e: | CODE |
| LOW | misc/python/materialize/git.py | 349 | except Exception as e: | CODE |
| LOW | misc/python/materialize/mz_env_util.py | 38 | except Exception as e: | CODE |
| LOW | misc/python/materialize/mz_env_util.py | 59 | except Exception as e: | CODE |
| LOW | misc/python/materialize/parallel_task.py | 81 | except Exception as e: | CODE |
| LOW | misc/python/materialize/docker.py | 227 | except Exception: | CODE |
| MEDIUM | misc/python/materialize/mzbuild.py | 360 | print(f"Error checking Docker image: {e}") | CODE |
| MEDIUM | misc/python/materialize/mzbuild.py | 421 | print(f"Error checking Docker image: {e}") | CODE |
| MEDIUM | misc/python/materialize/mzbuild.py | 446 | print(f"Error requesting {url}: {e}") | CODE |
| LOW | misc/python/materialize/mzbuild.py | 359 | except Exception as e: | CODE |
| LOW | misc/python/materialize/mzbuild.py | 420 | except Exception as e: | CODE |
| LOW | misc/python/materialize/mzbuild.py | 1460 | except Exception: | CODE |
| LOW | misc/python/materialize/mzbuild.py | 1526 | except Exception: | CODE |
| LOW | misc/python/materialize/sqlancer.py | 128 | except Exception: | CODE |
| LOW | misc/python/materialize/parallel_workload/worker.py | 113 | except Exception: | CODE |
| LOW | misc/python/materialize/parallel_workload/worker.py | 198 | except Exception as e: | CODE |
| LOW | …hon/materialize/parallel_workload/parallel_workload.py | 516 | except Exception as e: | CODE |
| LOW | …hon/materialize/parallel_workload/parallel_workload.py | 545 | except Exception as e: | CODE |
| LOW | misc/python/materialize/parallel_workload/action.py | 192 | except Exception: | CODE |
| LOW | misc/python/materialize/parallel_workload/action.py | 1554 | except Exception: | CODE |
| LOW | misc/python/materialize/parallel_workload/action.py | 3594 | except Exception as e: | CODE |
| LOW | misc/python/materialize/parallel_workload/action.py | 4885 | except Exception as e: | CODE |
| LOW | misc/python/materialize/parallel_workload/action.py | 4927 | except Exception as e: | CODE |
| LOW | misc/python/materialize/parallel_workload/action.py | 4937 | except Exception as e: | CODE |
| LOW | misc/python/materialize/parallel_workload/executor.py | 134 | except Exception as e: | CODE |
| LOW | misc/python/materialize/parallel_workload/executor.py | 148 | except Exception as e: | CODE |
| LOW | misc/python/materialize/parallel_workload/executor.py | 209 | except Exception as e: | CODE |
| LOW | misc/python/materialize/parallel_workload/executor.py | 225 | except Exception as e: | CODE |
| LOW | misc/python/materialize/parallel_workload/executor.py | 288 | except Exception as e: | CODE |
| LOW | misc/python/materialize/workload_replay/replay.py | 53 | except Exception: | CODE |
| LOW | misc/python/materialize/workload_replay/replay.py | 180 | except Exception as e: | CODE |
| LOW | misc/python/materialize/workload_replay/replay.py | 266 | except Exception as e: | CODE |
| LOW | misc/python/materialize/workload_replay/data.py | 564 | except Exception as e: | CODE |
| LOW | misc/python/materialize/workload_replay/data.py | 651 | except Exception as e: | CODE |
| LOW | misc/python/materialize/workload_replay/data.py | 739 | except Exception as e: | CODE |
| LOW | misc/python/materialize/data_ingest/workload.py | 361 | except Exception as e: | CODE |
| LOW | misc/python/materialize/data_ingest/executor.py | 129 | except Exception as e: | CODE |
| LOW | misc/python/materialize/data_ingest/executor.py | 146 | except Exception as e: | CODE |
| LOW | misc/python/materialize/data_ingest/executor.py | 377 | except Exception: | CODE |
| LOW | misc/python/materialize/mzcompose/__init__.py | 1054 | except Exception as e: | CODE |
| LOW | misc/python/materialize/mzcompose/composition.py | 736 | except Exception as e: | CODE |
| LOW | misc/python/materialize/mzcompose/composition.py | 1052 | except Exception: | CODE |
| LOW | misc/python/materialize/mzcompose/composition.py | 1385 | except Exception: | CODE |
| LOW | misc/python/materialize/mzcompose/composition.py | 1944 | except Exception as e: | CODE |
| LOW | misc/python/materialize/mzcompose/composition.py | 1964 | except Exception as e: | CODE |
| LOW | misc/python/materialize/mzcompose/helpers/iceberg.py | 86 | except Exception as e: | CODE |
| LOW | …erialize/output_consistency/output_consistency_test.py | 346 | except Exception as e: | CODE |
| LOW | …terialize/output_consistency/execution/sql_executor.py | 136 | except Exception: | CODE |
| LOW | misc/python/materialize/cli/ci_annotate_errors.py | 481 | except Exception as e: | CODE |
| LOW | misc/python/materialize/cli/ci_annotate_errors.py | 834 | except Exception as e: | CODE |
| LOW | misc/python/materialize/cli/ci_annotate_errors.py | 1056 | except Exception as e: | CODE |
| LOW | misc/python/materialize/cli/ci_annotate_errors.py | 1064 | except Exception as e: | CODE |
| LOW | misc/python/materialize/cli/optbench.py | 188 | except Exception as e: | CODE |
| LOW | misc/python/materialize/cli/optbench.py | 254 | except Exception as e: | CODE |
| LOW | misc/python/materialize/cli/optbench.py | 295 | except Exception as e: | CODE |
| LOW | misc/python/materialize/cli/mzexplore.py | 200 | except Exception as e: | CODE |
| LOW | misc/python/materialize/cli/mzexplore.py | 259 | except Exception as e: | CODE |
| LOW | misc/python/materialize/cli/mzexplore.py | 309 | except Exception as e: | CODE |
| 114 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | misc/python/materialize/data_ingest/executor.py | 0 | $ sql-server-connect name=sql-server server=tcp:sql-server,1433;integratedsecurity=true;trustservercertificate=true;user | STRING |
| HIGH | misc/python/materialize/zippy/sql_server_actions.py | 0 | $ sql-server-connect name=sql-server server=tcp:sql-server,1433;integratedsecurity=true;trustservercertificate=true;user | STRING |
| HIGH | …erialize/feature_benchmark/scenarios/benchmark_main.py | 0 | $ sql-server-connect name=sql-server server=tcp:sql-server,1433;integratedsecurity=true;trustservercertificate=true;user | STRING |
| HIGH | test/sql-server-cdc/mzcompose.py | 0 | $ sql-server-connect name=sql-server server=tcp:sql-server,1433;integratedsecurity=true;trustservercertificate=true;user | STRING |
| HIGH | misc/python/materialize/mzcompose/service.py | 0 | the implementation of the mzcompose system for docker compositions. for an overview of what mzcompose is and why it exis | STRING |
| HIGH | misc/python/materialize/mzcompose/__init__.py | 0 | the implementation of the mzcompose system for docker compositions. for an overview of what mzcompose is and why it exis | STRING |
| HIGH | misc/python/materialize/mzcompose/composition.py | 0 | the implementation of the mzcompose system for docker compositions. for an overview of what mzcompose is and why it exis | STRING |
| HIGH | …_filter/internal_output_inconsistency_ignore_filter.py | 0 | allows specifying and excluding expressions with known output inconsistencies | STRING |
| HIGH | …nsistency/ignore_filter/inconsistency_ignore_filter.py | 0 | allows specifying and excluding expressions with known output inconsistencies | STRING |
| HIGH | …stency/ignore_filter/pg_inconsistency_ignore_filter.py | 0 | allows specifying and excluding expressions with known output inconsistencies | STRING |
| HIGH | misc/python/materialize/zippy/postgres_actions.py | 0 | performs an insert, delete or update against a table. | STRING |
| HIGH | misc/python/materialize/zippy/mysql_actions.py | 0 | performs an insert, delete or update against a table. | STRING |
| HIGH | misc/python/materialize/zippy/table_actions.py | 0 | performs an insert, delete or update against a table. | STRING |
| HIGH | test/sql-server-resumption-old-syntax/mzcompose.py | 0 | confirm that mz does not reingest the entire snapshot on restart by revoking its select privileges | STRING |
| HIGH | test/mysql-cdc-resumption-old-syntax/mzcompose.py | 0 | confirm that mz does not reingest the entire snapshot on restart by revoking its select privileges | STRING |
| HIGH | test/pg-cdc-resumption-old-syntax/mzcompose.py | 0 | confirm that mz does not reingest the entire snapshot on restart by revoking its select privileges | STRING |
| HIGH | test/pg-cdc-resumption/mzcompose.py | 0 | confirm that mz does not reingest the entire snapshot on restart by revoking its select privileges | STRING |
| HIGH | test/mysql-cdc-resumption/mzcompose.py | 0 | confirm that mz does not reingest the entire snapshot on restart by revoking its select privileges | STRING |
| HIGH | test/mysql-cdc/mzcompose.py | 0 | the goal is to test a large scale kafka upsert instance and to make sure that we can successfully ingest data from it qu | STRING |
| HIGH | test/pg-cdc/mzcompose.py | 0 | the goal is to test a large scale kafka upsert instance and to make sure that we can successfully ingest data from it qu | STRING |
| HIGH | test/sql-server-cdc/mzcompose.py | 0 | the goal is to test a large scale kafka upsert instance and to make sure that we can successfully ingest data from it qu | STRING |
| HIGH | test/upsert/mzcompose.py | 0 | the goal is to test a large scale kafka upsert instance and to make sure that we can successfully ingest data from it qu | STRING |
| HIGH | test/cluster/mzcompose.py | 0 | test creating sources in a remote clusterd process. | STRING |
| HIGH | test/kafka-resumption/mzcompose.py | 0 | test creating sources in a remote clusterd process. | STRING |
| HIGH | test/upsert/mzcompose.py | 0 | test creating sources in a remote clusterd process. | STRING |
| HIGH | test/mysql-cdc-resumption-old-syntax/mzcompose.py | 0 | test postgres direct replication's failure handling by disrupting replication at various stages using toxiproxy or servi | STRING |
| HIGH | test/mysql-cdc-resumption/mzcompose.py | 0 | test postgres direct replication's failure handling by disrupting replication at various stages using toxiproxy or servi | STRING |
| HIGH | test/pg-cdc-resumption-old-syntax/mzcompose.py | 0 | test postgres direct replication's failure handling by disrupting replication at various stages using toxiproxy or servi | STRING |
| HIGH | test/pg-cdc-resumption/mzcompose.py | 0 | test postgres direct replication's failure handling by disrupting replication at various stages using toxiproxy or servi | STRING |
| HIGH | test/pg-rtr/mzcompose.py | 0 | functional test for kafka with real-time recency enabled. queries should block until results are available instead of re | STRING |
| HIGH | test/pg-rtr-old-syntax/mzcompose.py | 0 | functional test for kafka with real-time recency enabled. queries should block until results are available instead of re | STRING |
| HIGH | test/mysql-rtr/mzcompose.py | 0 | functional test for kafka with real-time recency enabled. queries should block until results are available instead of re | STRING |
| HIGH | test/mysql-rtr-old-syntax/mzcompose.py | 0 | functional test for kafka with real-time recency enabled. queries should block until results are available instead of re | STRING |
| HIGH | test/kafka-rtr/mzcompose.py | 0 | functional test for kafka with real-time recency enabled. queries should block until results are available instead of re | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 66 | {# Step 1: Only run validation when strict_mode is enabled #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 69 | {# Step 2: Initialize list to collect conflicting objects #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 72 | {# Step 3: Iterate through all nodes in the dbt manifest #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 75 | {# Step 4: Get this node's cluster (explicit or default) #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 78 | {# Step 5: Check if this node is on the same cluster #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 81 | {# Step 6: Record any object that isn't the current source #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 120 | {# Step 1: Only run validation when strict_mode is enabled #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 123 | {# Step 2: Initialize list to collect conflicting objects #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 126 | {# Step 3: Iterate through all nodes in the dbt manifest #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 129 | {# Step 4: Get this node's cluster (explicit or default) #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 132 | {# Step 5: Check if this node is on the same cluster #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 137 | {# Step 6: Record any non-sink object #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 145 | {# Step 7: If any conflicts were found, raise a compiler error #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 172 | {# Step 1: Only run validation when strict_mode is enabled #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 175 | {# Step 2: Initialize flags to track isolated types #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 179 | {# Step 3: Iterate through all nodes in the dbt manifest #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 182 | {# Step 4: Get this node's cluster (explicit or default) #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 185 | {# Step 5: Check if this node is on the same cluster #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 188 | {# Step 6: Check if this node is a source or sink #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 198 | {# Step 7: If cluster contains sources, block creation #} | CODE |
| LOW⚡ | …aterialize/macros/utils/validate_cluster_isolation.sql | 207 | {# Step 8: If cluster contains sinks, block creation #} | CODE |
| LOW | …aterialize/macros/utils/validate_cluster_isolation.sql | 93 | {# Step 7: If any conflicts were found, raise a compiler error #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 51 | {# Step 1: Only run validation when strict_mode is enabled #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 54 | {# Step 2: Initialize list to collect forbidden materialization types #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 60 | {# Step 3: Iterate through all nodes in the dbt manifest #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 63 | {# Step 4: Check if this node is in the same schema and database #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 68 | {# Step 5: If the node's materialization type is not allowed, record it #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 76 | {# Step 6: Remove duplicates from the list #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 79 | {# Step 7: If any forbidden types were found, raise a compiler error #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 105 | {# Step 1: Only run validation when strict_mode is enabled #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 108 | {# Step 2: Initialize list to collect forbidden materialization types #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 111 | {# Step 3: Iterate through all nodes in the dbt manifest #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 114 | {# Step 4: Check if this node is in the same schema and database #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 119 | {# Step 5: If the node is not a sink, record its type #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 127 | {# Step 6: Remove duplicates from the list #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 130 | {# Step 7: If any forbidden types were found, raise a compiler error #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 156 | {# Step 1: Only run validation when strict_mode is enabled #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 159 | {# Step 2: Initialize list to collect forbidden materialization types #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 162 | {# Step 3: Iterate through all nodes in the dbt manifest #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 165 | {# Step 4: Check if this node is in the same schema and database #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 170 | {# Step 5: If the node is not a source, record its type #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 178 | {# Step 6: Remove duplicates from the list #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 181 | {# Step 7: If any forbidden types were found, raise a compiler error #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 208 | {# Step 1: Only run validation when strict_mode is enabled #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 211 | {# Step 2: Initialize flags to track if we find isolated types #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 216 | {# Step 3: Iterate through all nodes in the dbt manifest #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 219 | {# Step 4: Check if this node is in the same schema and database #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 222 | {# Step 5: Check if this node is a source, sink, or source_table #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 234 | {# Step 6: If schema contains sources, block creation of this object #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 243 | {# Step 7: If schema contains sinks, block creation of this object #} | CODE |
| LOW⚡ | …materialize/macros/utils/validate_schema_isolation.sql | 252 | {# Step 8: If schema contains source_tables, block creation of this object #} | CODE |
| LOW⚡ | test/orchestratord/mzcompose.py | 3330 | # Step 5: Server-side apply a partial v1 manifest that does not contain | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3064 | # Step 1: Deploy with v1, complete initial rollout. | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3081 | # Step 2: Re-apply the same spec at v1 (no changes). | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3100 | # Step 3: Apply at v1 with a spec change (extra env var). | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3232 | # Step 1: Deploy at v1alpha1 with client-side apply and complete the | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3264 | # Step 2: Server-side apply the same spec at v1. Reconciling the | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3295 | # Step 3: Server-side re-apply the unchanged v1 spec (the routine GitOps | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3306 | # Step 4: Server-side apply a partial v1 manifest under a dedicated field | COMMENT |
| LOW⚡ | test/cloudtest/test_privatelink_connection.py | 290 | # Step 1: Deploy a single Toxiproxy instance | STRING |
| 51 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | misc/python/materialize/mz_version.py | 12 | CODE | |
| LOW | misc/python/materialize/util.py | 12 | CODE | |
| LOW | misc/python/materialize/parallel_task.py | 12 | CODE | |
| LOW | misc/python/materialize/version_ancestor_overrides.py | 11 | CODE | |
| LOW | misc/python/materialize/version_list.py | 11 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 120 | CODE | |
| LOW | misc/python/materialize/parallel_workload/column.py | 21 | CODE | |
| LOW | misc/python/materialize/parallel_workload/executor.py | 24 | CODE | |
| LOW | misc/python/materialize/workload_replay/ingest.py | 14 | CODE | |
| LOW | misc/python/materialize/workload_replay/util.py | 14 | CODE | |
| LOW | misc/python/materialize/workload_replay/replay_test.py | 12 | CODE | |
| LOW | misc/python/materialize/workload_replay/replay.py | 14 | CODE | |
| LOW | misc/python/materialize/workload_replay/stats.py | 14 | CODE | |
| LOW | misc/python/materialize/workload_replay/objects.py | 14 | CODE | |
| LOW | misc/python/materialize/workload_replay/data.py | 14 | CODE | |
| LOW | misc/python/materialize/workload_replay/column.py | 14 | CODE | |
| LOW | misc/python/materialize/workload_replay/executor.py | 14 | CODE | |
| LOW | misc/python/materialize/data_ingest/transaction_def.py | 29 | CODE | |
| LOW | misc/python/materialize/data_ingest/executor.py | 20 | CODE | |
| LOW | misc/python/materialize/mzcompose/test_result.py | 10 | CODE | |
| LOW | misc/python/materialize/mzcompose/helpers/iceberg.py | 20 | CODE | |
| LOW | …ython/materialize/mzcompose/services/metadata_store.py | 17 | CODE | |
| LOW | misc/python/materialize/mzcompose/services/cockroach.py | 10 | CODE | |
| LOW | misc/python/materialize/mzcompose/services/alloydb.py | 10 | CODE | |
| LOW | misc/python/materialize/mzcompose/services/postgres.py | 10 | CODE | |
| LOW | misc/python/materialize/checks/checks.py | 20 | CODE | |
| LOW | misc/python/materialize/checks/mzcompose_actions.py | 30 | CODE | |
| LOW | misc/python/materialize/checks/actions.py | 22 | CODE | |
| LOW | misc/python/materialize/checks/all_checks/aws.py | 9 | CODE | |
| LOW | …thon/materialize/checks/all_checks/alter_connection.py | 9 | CODE | |
| LOW | …alize/output_consistency/operation/return_type_spec.py | 10 | CODE | |
| LOW | …n/materialize/output_consistency/enum/enum_constant.py | 9 | CODE | |
| LOW | …output_consistency/output/reproduction_code_printer.py | 10 | CODE | |
| LOW | …/materialize/output_consistency/status/test_summary.py | 9 | CODE | |
| LOW | …nsistency/ignore_filter/inconsistency_ignore_filter.py | 11 | CODE | |
| LOW | …utput_consistency/expression/row_indices_expression.py | 9 | CODE | |
| LOW | …e/output_consistency/expression/constant_expression.py | 9 | CODE | |
| LOW | …aterialize/output_consistency/expression/expression.py | 9 | CODE | |
| LOW | …n/materialize/output_consistency/query/query_result.py | 9 | CODE | |
| LOW | …materialize/output_consistency/query/query_template.py | 9 | CODE | |
| LOW | …python/materialize/cli/ci_closed_issues_detect_test.py | 19 | CODE | |
| LOW | …c/python/materialize/cli/mz_workload_anonymize_test.py | 18 | CODE | |
| LOW | misc/python/materialize/cli/ci_annotate_errors_test.py | 10 | CODE | |
| LOW | misc/python/materialize/cli/mzcompose.py | 24 | CODE | |
| LOW | misc/python/materialize/cli/scratch/__init__.py | 10 | CODE | |
| LOW | misc/python/materialize/zippy/framework.py | 21 | CODE | |
| LOW | …thon/materialize/scalability/result/result_analyzer.py | 11 | CODE | |
| LOW | …n/materialize/scalability/result/comparison_outcome.py | 9 | CODE | |
| LOW | …n/materialize/scalability/result/scalability_change.py | 9 | CODE | |
| LOW | …aterialize/scalability/result/regression_assessment.py | 9 | CODE | |
| LOW | …c/python/materialize/scalability/df/df_wrapper_base.py | 9 | CODE | |
| LOW | misc/python/materialize/scalability/df/df_details.py | 9 | CODE | |
| LOW | misc/python/materialize/scalability/df/df_totals.py | 9 | CODE | |
| LOW | …materialize/scalability/executor/benchmark_executor.py | 33 | CODE | |
| LOW | …materialize/scalability/executor/benchmark_executor.py | 34 | CODE | |
| LOW | …materialize/scalability/executor/benchmark_executor.py | 35 | CODE | |
| LOW | …materialize/scalability/executor/benchmark_executor.py | 36 | CODE | |
| LOW | …ialize/scalability/workload/workloads/ddl_workloads.py | 21 | CODE | |
| LOW | …/scalability/workload/workloads/self_test_workloads.py | 16 | CODE | |
| LOW | …scalability/workload/workloads/connection_workloads.py | 17 | CODE | |
| 36 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …hon/materialize/parallel_workload/parallel_workload.py | 867 | # Mirror the mzcompose harness's scenario-to-backend mapping so that | COMMENT |
| MEDIUM | misc/python/materialize/parallel_workload/database.py | 1244 | # harness guarantees: the workload creates and drops its own clusters, | COMMENT |
| MEDIUM | misc/python/materialize/mzcompose/__init__.py | 83 | """Settings we need in order to have tests run at all, but otherwise stay | STRING |
| MEDIUM⚡ | misc/dbt-materialize/mzcompose.py | 105 | # Give the test harness permission to modify the built-in | STRING |
| MEDIUM | test/cluster/mzcompose.py | 5205 | # its own. It pins the harness, since rows lost here would mean the | COMMENT |
| MEDIUM | test/cluster/mzcompose.py | 7825 | # robust to the source exposing extra, transient readers as it restarts | STRING |
| MEDIUM | test/parallel-benchmark/mzcompose.py | 545 | # harness time, and a scenario with a qps guarantee has less | COMMENT |
| LOW | ci/test/cargo-test/mzcompose.py | 271 | # resolves `cargo` through the `PATH` it just set, which is what puts the | COMMENT |
| LOW | ci/test/cargo-test/mzcompose.py | 292 | # Can't just use --workspace because of https://github.com/rust-lang/cargo/issues/7160 | COMMENT |
| LOW | ci/nightly/pipeline.template.yml | 10 | # Default priority, just set to be explicit | COMMENT |
| LOW | doc/user/data/explain_plan_operators.yml | 422 | Indicates a point that will become an [arrangement](/fundamentals/concepts/arrangements/#arrangements) in the data | CODE |
| MEDIUM | src/mz/src/bin/mz/upgrader.rs | 43 | /// and ensure a seamless experience. | COMMENT |
| MEDIUM | src/metrics-catalog/src/main.rs | 900 | /// stays robust to grammar tweaks. Document that leniency here. | COMMENT |
| MEDIUM | src/prof-http/src/http/static/js/flamegraph.js | 189 | // be robust in case there isn't | COMMENT |
| MEDIUM | src/expr/src/interpret.rs | 165 | /// only need the "single known value" case: it's robust against future | COMMENT |
| MEDIUM | src/orchestrator-process/src/lib.rs | 1074 | // anything more robust given the Unix APIs available to us, and the | COMMENT |
| MEDIUM | src/compute/src/render/top_k.rs | 440 | /// To provide a robust incremental orderby-limit experience, we want to avoid grouping *all* | COMMENT |
| MEDIUM | src/compute/src/render/top_k.rs | 442 | /// robust approach forms groups of bounded size and applies the offset and limit to each, | COMMENT |
| MEDIUM | src/compute/src/sink/materialized_view.rs | 63 | //! The persist sink is written to be robust to the presence of other conflicting instances (e.g. | COMMENT |
| MEDIUM | src/avro/src/lib.rs | 60 | //! Or in case you want to leverage the **Snappy** codec: | COMMENT |
| MEDIUM | src/avro/src/lib.rs | 280 | //! interface to leverage all Avro features. Please read the API reference in case you are | COMMENT |
| MEDIUM | src/ore/src/panic.rs | 213 | // out. To make this string munging as robust as possible, if we | COMMENT |
| MEDIUM | src/persist-client/Cargo.toml | 18 | # Disable the ability to use benches in the library because the bench harness | COMMENT |
| MEDIUM | src/transform/src/analysis.rs | 1587 | /// But see also expr/src/scalar.rs for `FilterCharacteristics::worst_case_scaling_factor()` for a more nuanced take | COMMENT |
| MEDIUM | src/transform/src/equivalence_propagation.rs | 29 | //! equivalence was independent of the expression (e.g. through a more nuanced expression traversal) we could imaging re | COMMENT |
| MEDIUM | src/persist/Cargo.toml | 16 | # Disable the ability to use benches in the library because the bench harness | COMMENT |
| MEDIUM | src/repr/src/scalar.rs | 3669 | /// castable from `self` and offer a means to leverage Materialize's type | COMMENT |
| MEDIUM | src/repr/src/adt/jsonb.rs | 15 | //! minimal allocations. It also provides seamless interop with APIs that | COMMENT |
| MEDIUM | src/sql/src/plan/transform_hir.rs | 866 | // robust against future code changes.) | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | src/compute-client/src/as_of_selection.rs | 559 | /// Apply as-of constraints to ensure indexes contain historical data as requested by their | COMMENT |
| HIGH | src/expr/src/relation.rs | 3649 | /// The maximum allowed result size, as requested by the client. | COMMENT |
| HIGH | src/orchestrator-process/src/lib.rs | 615 | // The service might already exist. If it has the same config as requested (currently we | COMMENT |
| HIGH | src/storage/src/render/sinks.rs | 50 | /// that represent the sink and its errors as requested | COMMENT |
| HIGH | src/storage/src/render/sources.rs | 51 | /// as requested by the original `CREATE SOURCE` statement, | COMMENT |
| HIGH | src/compute/src/server.rs | 1148 | // All other commands we apply as requested. | COMMENT |
| HIGH | src/pgwire/src/protocol.rs | 1832 | // them to the user as requested. Its command tag is always FETCH <num rows | COMMENT |
| HIGH | src/pgwire/src/protocol.rs | 1996 | // return those as requested (if, say, an Execute message was sent with a | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …python/materialize/cli/ci_closed_issues_detect_test.py | 61 | monkeypatch.setenv("LINEAR_READ_ONLY_TOKEN", "dummy-token") | CODE |
| LOW | …python/materialize/cli/ci_closed_issues_detect_test.py | 75 | monkeypatch.setenv("LINEAR_READ_ONLY_TOKEN", "dummy-token") | CODE |
| LOW | test/iceberg/mzcompose.py | 349 | dummy_id = snap_id + 10_000_000 + stats["modifications"] | CODE |
| LOW | test/iceberg/mzcompose.py | 351 | "snapshot-id": dummy_id, | CODE |
| LOW | test/iceberg/mzcompose.py | 375 | "snapshot-id": dummy_id, | CODE |
| LOW | …content/security/patterns/protect-sensitive-columns.md | 118 | GRANT admin TO "admin@example.com"; | CODE |
| LOW⚡ | doc/user/content/serve-results/connection-pooling.md | 32 | "user@example.com" "mypassword-or-scram-secret" | CODE |
| LOW | doc/user/content/serve-results/connection-pooling.md | 44 | "foo@bar.com" "mypassword" | CODE |
| LOW | console/src/platform/roles/RemoveUserModal.test.tsx | 30 | memberName: "user@example.com", | CODE |
| LOW | console/src/platform/roles/RemoveUserModal.test.tsx | 46 | expect(screen.getByText("user@example.com")).toBeVisible(); | CODE |
| LOW | console/src/platform/roles/EditRolesModal.test.tsx | 36 | userName: "user@example.com", | CODE |
| LOW | console/src/platform/roles/EditRolesModal.test.tsx | 135 | expect(screen.getByText("user@example.com")).toBeInTheDocument(); | CODE |
| LOW | …urces/create/shared/NewDatabaseConnectionForm.test.tsx | 205 | expect(portInput).toHaveProperty("placeholder", "5432"); | CODE |
| LOW | …urces/create/shared/NewDatabaseConnectionForm.test.tsx | 220 | expect(portInput).toHaveProperty("placeholder", "3306"); | CODE |
| LOW | …urces/create/shared/NewDatabaseConnectionForm.test.tsx | 246 | expect(portInput).toHaveProperty("placeholder", "1433"); | CODE |
| LOW | console/src/components/CommandBlock/Editor.tsx | 58 | "lineNumbers" | "placeholder" | "onCommand" | "onKeyDown" | CODE |
| LOW | console/src/components/connect/connectOptions.test.ts | 46 | user: "user@example.com", | CODE |
| LOW | console/src/components/connect/connectOptions.test.ts | 298 | expect(buildBase64TokenCommand("user@example.com")).toEqual( | CODE |
| LOW | console/src/components/connect/connectOptions.test.ts | 304 | expect(buildBase64TokenCommand("user@example.com", "<id-token>")).toEqual( | CODE |
| LOW | …materialize/query-history/queryHistoryList.test.sql.ts | 107 | toSqlStringValue(values.authenticatedUser, "user@example.com"), | CODE |
| LOW | …materialize/query-history/queryHistoryList.test.sql.ts | 153 | authenticatedUser: "user@example.com", | CODE |
| LOW | …materialize/query-history/queryHistoryList.test.sql.ts | 191 | `> ${insertActivityLog({ authenticatedUser: "admin@example.com", sql: "SELECT 3" })}`, | CODE |
| LOW | …materialize/query-history/queryHistoryList.test.sql.ts | 198 | user: "admin@example.com", | CODE |
| LOW | …materialize/query-history/queryHistoryList.test.sql.ts | 557 | 'admin@example.com', | CODE |
| LOW | …le/src/external-library-wrappers/__mocks__/frontegg.ts | 47 | email: "user@example.com", | CODE |
| LOW | src/catalog/src/durable/upgrade/v83_to_v84.rs | 1307 | let user = stale_role_kind_with_dropped_field(110, "user@example.com", 30110); | CODE |
| LOW | src/catalog/src/durable/upgrade/v83_to_v84.rs | 1310 | "user@example.com", | CODE |
| LOW | src/catalog/src/durable/upgrade/v80_to_v81.rs | 174 | make_role(1, "user@example.com"), | CODE |
| LOW | src/catalog/src/durable/upgrade/v80_to_v81.rs | 188 | make_role(1, "user@example.com"), | CODE |
| LOW | src/catalog/src/durable/upgrade/v80_to_v81.rs | 200 | make_role(1, "user@example.com"), | CODE |
| LOW | src/environmentd/tests/auth.rs | 1362 | let oidc_user = "user@example.com"; | CODE |
| LOW | src/environmentd/tests/auth.rs | 1554 | let oidc_user = "user@example.com"; | CODE |
| LOW | src/environmentd/tests/auth.rs | 1709 | let oidc_user = "user@example.com"; | CODE |
| LOW | src/environmentd/tests/auth.rs | 1793 | let oidc_user = "user@example.com"; | CODE |
| LOW | src/environmentd/tests/auth.rs | 1915 | let oidc_user = "user@example.com"; | CODE |
| LOW | src/environmentd/tests/auth.rs | 2056 | let email_user = "user@example.com"; | CODE |
| LOW | src/environmentd/tests/auth.rs | 2146 | let oidc_user = "user@example.com"; | CODE |
| LOW | src/environmentd/tests/auth.rs | 2209 | let oidc_user = "user@example.com"; | CODE |
| LOW | src/environmentd/tests/auth.rs | 2304 | let oidc_user = "user@example.com"; | CODE |
| LOW | src/environmentd/tests/auth.rs | 5408 | let oidc_user = "user@example.com"; | CODE |
| LOW | src/frontegg-mock/tests/local.rs | 52 | let email = "user@example.com".to_string(); | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | clippy.toml | 34 | # These are banned because we want to ensure people don't forget to use .name(...), so we require the use of `mz_ore | COMMENT |
| LOW | clippy.toml | 34 | # These are banned because we want to ensure people don't forget to use .name(...), so we require the use of `mz_ore | COMMENT |
| LOW | …sc/python/materialize/checks/all_checks/alter_table.py | 23 | # Note(parkmycar): We want to make sure to ALTER a table in the initialize to exercise | COMMENT |
| MEDIUM | test/cluster-spec-sheet/mzcompose.py | 3631 | # If you'd like to avoid going over your machine's core count, you can use `--max-scale`. | COMMENT |
| LOW | src/storage-client/src/storage_collections.rs | 2421 | // Destructure `self` here so we don't forget to consider dumping newly added fields. | COMMENT |
| LOW | src/compute-client/src/controller.rs | 526 | // Destructure `self` here so we don't forget to consider dumping newly added fields. | COMMENT |
| LOW | src/compute-client/src/controller.rs | 1388 | // Destructure `self` here so we don't forget to consider dumping newly added fields. | COMMENT |
| LOW | src/compute-client/src/controller/instance.rs | 871 | // Destructure `self` here so we don't forget to consider dumping newly added fields. | COMMENT |
| LOW | src/compute-client/src/controller/instance.rs | 3224 | // Destructure `self` here so we don't forget to consider dumping newly added fields. | COMMENT |
| LOW | src/storage-controller/src/lib.rs | 2686 | // Destructure `self` here so we don't forget to consider dumping newly added fields. | COMMENT |
| LOW | src/controller/src/lib.rs | 283 | // Destructure `self` here so we don't forget to consider dumping newly added fields. | COMMENT |
| MEDIUM | src/environmentd/tests/sql.rs | 1490 | // Feel free to modify this test if that product requirement changes, | COMMENT |
| LOW | src/persist-client/src/internal/compact.rs | 1126 | // intentionally deconstruct so we don't forget to consider each field | COMMENT |
| LOW | src/persist-client/src/internal/state.rs | 2071 | // Don't forget to update the downgrade_since when this gets | COMMENT |
| LOW | src/persist-client/src/internal/state.rs | 2104 | // Don't forget to update the downgrade_since when this gets | COMMENT |
| LOW | src/sql/src/session/vars/definitions.rs | 2449 | // then assigning them to their respective system vars, to ensure we don't forget to update | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | misc/python/materialize/util.py | 176 | def _set_linger(conn: psycopg.Connection) -> None: | CODE |
| LOW | misc/python/materialize/ui.py | 174 | def set_hint(self, hint: str) -> None: | CODE |
| LOW | misc/python/materialize/parallel_workload/database.py | 1899 | def update_sqlsmith_state(self, composition: Composition) -> None: | CODE |
| LOW | misc/python/materialize/parallel_workload/action.py | 3606 | def set_cluster_compression(self, conn: Connection, cluster: Cluster) -> None: | CODE |
| LOW | misc/python/materialize/parallel_workload/column.py | 27 | def set_naughty_identifiers(value: bool) -> None: | CODE |
| LOW | misc/python/materialize/parallel_workload/executor.py | 101 | def set_isolation(self, level: str) -> None: | CODE |
| LOW | misc/python/materialize/workload_replay/util.py | 199 | def update_captured_workloads_repo() -> None: | CODE |
| LOW | misc/python/materialize/cli/run.py | 66 | def update_sqlite_repo() -> None: | STRING |
| LOW | …e/test_analytics/connector/test_analytics_connector.py | 73 | def set_read_only(self) -> None: | CODE |
| LOW | …e/test_analytics/connector/test_analytics_connector.py | 125 | def set_read_only(self) -> None: | CODE |
| LOW | …e/test_analytics/connector/test_analytics_connector.py | 221 | def set_read_only(self) -> None: | CODE |
| LOW | …sc/python/materialize/scalability/workload/workload.py | 65 | def set_endpoint(self, endpoint: Endpoint) -> None: | CODE |
| LOW | …sc/python/materialize/scalability/workload/workload.py | 68 | def set_schema(self, schema: Schema) -> None: | CODE |
| LOW⚡ | …ture_flag_consistency/feature_flag_consistency_test.py | 106 | def set_configuration_pair_by_name(self, name: str) -> None: | CODE |
| LOW | …n/materialize/cloudtest/app/materialize_application.py | 172 | def set_environmentd_failpoints(self, failpoints: str) -> None: | CODE |
| LOW | misc/python/materialize/cloudtest/k8s/toxiproxy.py | 166 | def set_proxy_enabled(self, name: str, upstream: str, enabled: bool) -> None: | CODE |
| LOW | test/canary-load/mzcompose.py | 378 | def update_data(c: Composition, i: int) -> None: | STRING |
| LOW | ci/mkpipeline.py | 790 | def set_retry_on_agent_lost(pipeline: Any) -> None: | CODE |
| LOW | ci/mkpipeline.py | 811 | def set_default_agents_queue(pipeline: Any) -> None: | CODE |
| LOW | ci/mkpipeline.py | 823 | def set_parallelism_name(pipeline: Any) -> None: | CODE |
| LOW | ci/deploy/npm.py | 29 | logger = logging.getLogger(__name__) | CODE |
| LOW | ci/deploy/npm.py | 176 | def set_npm_credentials(package_path: Path) -> None: | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | zizmor.yml | 21 | # Concurrency groups would cancel or queue independent runs of event-driven | COMMENT |
| MEDIUM | misc/helm-charts/operator/values.yaml | 10 | # Operator configuration for orchestrating Materialize | COMMENT |
| MEDIUM | doc/developer/design/20240609_error_handling.md | 372 | of errors. See [Guardrails](#guardrails) below for further discussion. | CODE |
| MEDIUM | src/mz-deploy/src/cli/commands/new_project.rs | 36 | /// `mz-deploy new <name>` — create a new directory and scaffold into it. | COMMENT |
| MEDIUM | src/mz-deploy/src/cli/commands/new_project.rs | 57 | /// `mz-deploy init` — scaffold the current directory as an mz-deploy project. | COMMENT |
| MEDIUM | src/mz-deploy/src/cli/commands/new_project.rs | 264 | /// Writes a scaffold file, leaving any file that already exists untouched. | COMMENT |
| MEDIUM | src/transform/src/analysis/equivalences.rs | 745 | /// required additional guardrails to ensure we reach a fixed point. | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | misc/python/materialize/redpanda_cloud.py | 24 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 4434 | CODE | |
| LOW | misc/python/materialize/mzcompose/composition.py | 361 | CODE | |
| LOW | misc/python/materialize/mzcompose/composition.py | 785 | CODE | |
| LOW | misc/python/materialize/mzcompose/composition.py | 819 | CODE | |
| LOW | misc/python/materialize/mzcompose/composition.py | 895 | CODE | |
| LOW | misc/python/materialize/mzcompose/composition.py | 1086 | CODE | |
| LOW | misc/python/materialize/mzcompose/services/balancerd.py | 20 | CODE | |
| LOW | misc/python/materialize/mzcompose/services/clusterd.py | 26 | CODE | |
| LOW | …/python/materialize/mzcompose/services/materialized.py | 85 | CODE | |
| LOW | misc/python/materialize/mzcompose/services/testdrive.py | 51 | CODE | |
| LOW | misc/python/materialize/mzcompose/services/cockroach.py | 33 | CODE | |
| LOW | misc/python/materialize/mzcompose/services/frontegg.py | 20 | CODE | |
| LOW | …thon/materialize/mzcompose/services/schema_registry.py | 16 | CODE | |
| LOW | misc/python/materialize/mzcompose/services/kafka.py | 27 | CODE | |
| LOW | misc/python/materialize/mzcompose/services/postgres.py | 28 | CODE | |
| LOW | misc/python/materialize/mzcompose/services/azurite.py | 19 | CODE | |
| LOW | misc/python/materialize/checks/mzcompose_actions.py | 40 | CODE | |
| LOW | …/materialize/output_consistency/operation/operation.py | 38 | CODE | |
| LOW | …/materialize/output_consistency/operation/operation.py | 196 | CODE | |
| LOW | misc/python/materialize/cloudtest/k8s/testdrive.py | 52 | CODE | |
| LOW | misc/python/materialize/cloudtest/k8s/environmentd.py | 172 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | misc/python/materialize/cargo.py | 27 | A Cargo crate. A crate directory must contain a `Cargo.toml` file with `package.name` and `package.version` key | STRING |
| HIGH | misc/python/materialize/cargo.py | 240 | Collects the transitive path dependencies of the requested crate. Note that only _path_ dependencies are collec | STRING |
| HIGH | misc/python/materialize/spawn.py | 95 | Capture the output of a subprocess. Args: args: A list of strings or paths describing the program to run an | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | misc/python/materialize/parallel_workload/action.py | 336 | "unknown cluster 'dont_exist'", # Set intentionally to find panics | CODE |
| LOW | misc/python/materialize/mzexplore/extract.py | 432 | if print_results: # Print results if requested. | STRING |
| LOW⚡ | misc/dbt-materialize/mzcompose.py | 99 | # Set enable_create_table_from_source to true | STRING |
| LOW | …dbt/include/materialize/macros/deploy/deploy_await.sql | 57 | {# Check if all clusters are ready #} | CODE |
| LOW | misc/helm-charts/publish.sh | 106 | # Check if version already exists | COMMENT |
| LOW | test/terraform/mzcompose.py | 1077 | # Check if all pods are using the expected image | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 463 | # Check if process is still running | COMMENT |
| LOW | test/console/mzcompose.py | 176 | # Check if it's a direct version string (starts with 'v') | COMMENT |
| LOW | ci/test/cargo-test/mzcompose.py | 80 | # Check if image exists locally before pulling | COMMENT |
| LOW | .github/workflows/cla.yml | 22 | # Check if PR authors have signed the Materialize CLA, and if not have them sign | COMMENT |
| LOW | .github/workflows/update-generated-docs.yml | 51 | # Check if there's already an open PR from this branch | COMMENT |
| LOW | src/storage/src/upsert/types.rs | 454 | /// ## Return value | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | doc/user/content/ingest-data/kafka/confluent-cloud.md | 94 | CREATE SECRET confluent_username AS '<your-api-key>'; | CODE |
| HIGH | doc/user/content/ingest-data/kafka/confluent-cloud.md | 158 | CREATE SECRET confluent_username AS '<your-api-key>'; | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | doc/user/data/cluster_details.yml | 4 | # Usage: | COMMENT |
| LOW | doc/user/data/hydration-details.yml | 4 | # Usage: | COMMENT |
| LOW | src/persist-cli/src/maelstrom.rs | 25 | /// Example usage: | COMMENT |
| LOW | src/aws-glue-schema-registry/src/lib.rs | 43 | //! ## Example usage | COMMENT |
| LOW | src/ccsr/src/lib.rs | 19 | //! ## Example usage | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | src/tracing/src/lib.rs | 50 | // TODO: implement Clone on `EnvFilter` upstream | COMMENT |
| LOW | src/ore/src/tracing.rs | 592 | // TODO: implement `would_enable` on `EnvFilter` or equivalent | COMMENT |