The live data layer for apps and AI agents. Create up-to-the-second views into your business, just using SQL
This report presents the forensic synthetic code analysis of MaterializeInc/materialize, a Rust project with 6,363 GitHub stars. SynthScan v2.0 examined 1,549,635 lines of code across 6179 source files, recording 6484 pattern matches distributed across 24 syntactic categories. The overall adjusted score of 5.2 places this repository in the Low AI signal band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 6484 distinct pattern matches across 24 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | Cargo.toml | 601 | lto = "thin" | COMMENT |
| LOW | Cargo.toml | 661 | # Need to upstream a few PRs related to test builders. | COMMENT |
| LOW | deny.toml | 21 | # One-time exception for base64 due to its prevalence in the crate graph. | COMMENT |
| LOW | deny.toml | 301 | # `http-types`'s `Authorization::value`/`WwwAuthenticate::value` can violate | 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 | # parse the package name from a package_id that looks like one of: | 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 | …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 | 441 | alive = [(w, t) for w, t in zip(workers, threads) if t.is_alive()] | COMMENT |
| LOW | …hon/materialize/parallel_workload/parallel_workload.py | 461 | # | COMMENT |
| LOW | …hon/materialize/parallel_workload/parallel_workload.py | 661 | # SQL or preconditions are broken. "must be owner of" and "permission | COMMENT |
| LOW | …hon/materialize/parallel_workload/parallel_workload.py | 721 | } | 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 | def run(self, exe: Executor) -> bool: | COMMENT |
| LOW | misc/python/materialize/parallel_workload/action.py | 4041 | # | COMMENT |
| LOW | misc/python/materialize/parallel_workload/action.py | 4101 | # `reshape_alter_cluster_managed` writes InProgress or, for an | COMMENT |
| LOW | misc/python/materialize/parallel_workload/action.py | 6501 | (AlterOwnerAction, 2), | 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/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/loader.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | 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 | # some tests run into stack overflows | 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 |
| LOW | misc/python/materialize/cli/ci_coverage_pr_report.py | 21 | # - None value indicates that this line is interesting, but we don't know yet | COMMENT |
| LOW | misc/python/materialize/cli/lint_pipeline_topics.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| LOW | misc/python/materialize/cli/mzcompose.py | 1041 | # commands. Instead we focus on making `--help` work perfectly. | COMMENT |
| LOW | misc/python/materialize/cli/gen-lints.py | 41 | COMMENT | |
| LOW | misc/python/materialize/cli/gen-lints.py | 61 | # in `HashMap`, because their order could change. This is a good lint in | COMMENT |
| LOW | misc/python/materialize/cli/gen-lints.py | 81 | WARN_CLIPPY_LINTS = [ | COMMENT |
| LOW | misc/python/materialize/cli/gen-lints.py | 181 | # Implementing `From` gives you `Into` for free, but the reverse is not | COMMENT |
| LOW | …materialize/test_analytics/config/sandbox_db_config.py | 1 | # Copyright Materialize, Inc. and contributors. All rights reserved. | COMMENT |
| 3839 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(version_type: type[VERSION_TYPE]) -> VERSION_TYPE | None: | 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 | 224 | 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 | 1238 | def is_published_if_necessary(self) -> bool: | CODE |
| LOW | misc/python/materialize/mzbuild.py | 1769 | 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 | 83 | def is_pull_request_marker_set() -> bool: | CODE |
| LOW | misc/python/materialize/buildkite.py | 94 | def get_pull_request_base_branch(fallback: str = "main"): | CODE |
| LOW | misc/python/materialize/buildkite.py | 98 | def get_pipeline_default_branch(fallback: str = "main"): | CODE |
| LOW | misc/python/materialize/buildkite.py | 191 | def _upload_shard_info_metadata(items: list[str]) -> None: | CODE |
| LOW | misc/python/materialize/buildkite.py | 209 | def notify_qa_team_about_failure(failure: str) -> None: | CODE |
| LOW | misc/python/materialize/buildkite.py | 253 | def _validate_parallelism_configuration() -> None: | CODE |
| LOW | misc/python/materialize/buildkite.py | 319 | def get_job_url_from_build_url(build_url: str, build_job_id: str) -> str: | CODE |
| LOW | misc/python/materialize/buildkite.py | 323 | 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/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 |
| LOW | misc/python/materialize/version_list.py | 300 | def _resolve_image_tag_of_merge_base( | CODE |
| LOW | misc/python/materialize/version_list.py | 368 | def get_latest_published_version() -> MzVersion: | CODE |
| LOW | misc/python/materialize/version_list.py | 389 | def get_previous_published_version( | CODE |
| LOW | misc/python/materialize/version_list.py | 409 | def get_published_minor_mz_versions( | CODE |
| LOW | misc/python/materialize/version_list.py | 485 | def get_all_published_mz_versions( | CODE |
| LOW | misc/python/materialize/version_list.py | 494 | def get_published_mz_versions_within_one_major_version( | CODE |
| 1144 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 materialize-docs 2>/dev/nu | CODE |
| HIGH | misc/python/materialize/scratch.py | 334 | "npx -q -y skills add MaterializeInc/agent-skills -g -a codex --copy -y --skill materialize-docs 2>/dev/null || | CODE |
| HIGH | …/python/materialize/mzcompose/services/foundationdb.py | 31 | if fdbcli -C "$CLUSTER_FILE" --exec "status minimal" --timeout 5 2>/dev/null; then | CODE |
| HIGH | …/python/materialize/mzcompose/services/foundationdb.py | 147 | "if fdbcli -C /var/fdb/fdb.cluster --exec 'status minimal' --timeout 5 2>/dev/null; then " | STRING |
| 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 | 853 | # {{"before": null, "after": {{"row":{{"f1": 1}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 854 | # {{"before": null, "after": {{"row":{{"f1": 2}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 855 | # {{"before": null, "after": {{"row":{{"f1": 3}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 858 | # {{"before": null, "after": {{"row":{{"f1": 1}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 859 | # {{"before": null, "after": {{"row":{{"f1": 2}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 860 | # {{"before": null, "after": {{"row":{{"f1": 3}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 863 | # {{"before": null, "after": {{"row":{{"f1": 1}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 864 | # {{"before": null, "after": {{"row":{{"f1": 2}}}}}} | COMMENT |
| HIGH⚡ | misc/python/materialize/checks/all_checks/kafka_sink.py | 865 | # {{"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 |
| 69 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 | 144 | # ----------------- | 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 | 272 | # ── 1. Initial apply ───────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 332 | # ── 2. Idempotent re-apply ──────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 369 | # ── 3. Incremental apply: add table ─────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 421 | # ── 4. Modify connection ────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 438 | # ── 5. Grant changes ───────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 455 | # ── 6. Run unit tests ───────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 486 | # ── 7. Stage ────────────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 511 | # ── 8. Wait ────────────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 517 | # ── 9. Promote ─────────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 562 | # ── 10. Log ────────────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 568 | # ── 11-12. Stage v2 ─────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 585 | # ── 13. Abort v2 ───────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 599 | # ── 14. Re-stage v2 + promote ───────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 640 | # ── 15-16. Stage v3 ─────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 653 | # ── 17. Abort v3 ───────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 667 | # ── 18. Re-stage v3 + promote ───────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 714 | # ── 1. Apply default profile ────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 808 | # ── 3. Apply staging profile ────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 924 | # ── 5. Idempotent re-apply for both profiles ────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 1251 | # ── Happy path: lock with system-schema deps ────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 1271 | # ── Stage path: a project that reads a system catalog must deploy ───── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 1292 | # ── Negative case: 2-part non-system dep is rejected ────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 1881 | # ── 1. Initial baseline apply ──────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2013 | # ── 1. Apply infrastructure ────────────────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2028 | # ── 2. Stage v1: sink is deferred ──────────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2056 | # ── 3. Promote v1: deferred sink is created ────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2093 | # ── 4. Stage v2 (MV definition changed) ────────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2104 | # ── 5. Promote v2: sink is repointed, not recreated ────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2204 | # ── 2. Stage v2: only the stable MV changed ────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2229 | # ── 3. Promote v2: APPLY REPLACEMENT, no swap, no repoint ──────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2293 | # ── 1. Baseline: deploy v1 so subsequent stages diff against it ────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2309 | # ── 2. Stage both deployments side by side ─────────────────────── | COMMENT |
| MEDIUM | test/mz-deploy/mzcompose.py | 2344 | # ── 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 | 1087 | profile = self.image.rd.profile.name.lower() | 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 | 2857 | self.metrics.blob.set.bytes.inc_by(u64::cast_from(bytes)); | CODE |
| CRITICAL | src/persist-client/src/internal/metrics.rs | 2872 | 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 | 3038 | # Step 5: Server-side apply a partial v1 manifest that does not contain | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 2772 | # Step 1: Deploy with v1, complete initial rollout. | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 2789 | # Step 2: Re-apply the same spec at v1 (no changes). | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 2808 | # Step 3: Apply at v1 with a spec change (extra env var). | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 2940 | # Step 1: Deploy at v1alpha1 with client-side apply and complete the | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 2972 | # Step 2: Server-side apply the same spec at v1. Reconciling the | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3003 | # Step 3: Server-side re-apply the unchanged v1 spec (the routine GitOps | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3014 | # 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 |
| 114 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | misc/python/materialize/cargo.py | 53 | CODE | |
| LOW | misc/python/materialize/cargo.py | 148 | CODE | |
| LOW | misc/python/materialize/cargo.py | 178 | CODE | |
| LOW | misc/python/materialize/cargo.py | 201 | 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 | 814 | CODE | |
| LOW | misc/python/materialize/mzbuild.py | 950 | CODE | |
| LOW | misc/python/materialize/mzbuild.py | 1204 | CODE | |
| LOW | misc/python/materialize/mzbuild.py | 1426 | CODE | |
| LOW | misc/python/materialize/mzbuild.py | 1574 | CODE | |
| LOW | misc/python/materialize/sqlancer.py | 121 | CODE | |
| LOW | misc/python/materialize/sqlancer.py | 180 | CODE | |
| LOW | misc/python/materialize/buildkite.py | 128 | 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 | 2413 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 2625 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 3559 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 3841 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 4471 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 4739 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 5349 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 5449 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 5555 | 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 | |
| 186 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 | 62 | # Create the release page in the docs for the next version after the one | COMMENT |
| MEDIUM | misc/python/materialize/parallel_benchmark/scenarios.py | 505 | # 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 | 3537 | # Create a temporary override of the materialized service with updated CPU limits. | COMMENT |
| MEDIUM | test/terraform/aws-upgrade/main.tf | 90 | # Create a generic nodeclass and nodepool for system workloads | COMMENT |
| MEDIUM | test/terraform/aws-upgrade/main.tf | 125 | # Create a dedicated nodeclass and nodepool for Materialize pods | COMMENT |
| MEDIUM | test/terraform/aws-persistent/main.tf | 90 | # Create a generic nodeclass and nodepool for system workloads | COMMENT |
| MEDIUM | test/terraform/aws-persistent/main.tf | 125 | # Create a dedicated nodeclass and nodepool for Materialize pods | COMMENT |
| MEDIUM | test/terraform/aws-temporary/main.tf | 90 | # Create a generic nodeclass and nodepool for system workloads | COMMENT |
| MEDIUM | test/terraform/aws-temporary/main.tf | 125 | # 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 | 3422 | # Create a cluster and wait for it to come up. | COMMENT |
| MEDIUM | test/cluster/mzcompose.py | 3587 | # Create a managed cluster with a custom replica name. | COMMENT |
| MEDIUM | test/cluster/mzcompose.py | 4023 | # Create an MV reading from an index. Make sure it doesn't produce its | COMMENT |
| MEDIUM | test/cluster/mzcompose.py | 3509 | # Create a managed cluster and wait for it to come up. | STRING |
| MEDIUM | test/cluster/mzcompose.py | 5698 | # Create a REFRESH MV and wait for it to refresh once, then take down | STRING |
| MEDIUM | test/cluster/mzcompose.py | 5773 | # Create an unmanaged cluster that isn't restarted together with materialized, | STRING |
| MEDIUM | test/cluster/mzcompose.py | 7041 | # Create a pause-able cluster, with indexes with different kinds of inputs. | STRING |
| MEDIUM | test/cluster/mzcompose.py | 7462 | # Create a postgres source and wait until it's caught up. | STRING |
| MEDIUM | test/cluster/mzcompose.py | 7689 | # Create a replacement. It's as-of will be derived from mv2's since. | STRING |
| MEDIUM | test/cluster/mzcompose.py | 7723 | # Create a materialized view and a replacement. | STRING |
| MEDIUM | test/cluster/mzcompose.py | 7779 | # Create a materialized view and a replacement. | STRING |
| MEDIUM | test/cluster/mzcompose.py | 8029 | # Create a cluster with an optimizer feature override, to test that | STRING |
| MEDIUM | test/cluster/mzcompose.py | 8146 | # Create a materialized view to generate compute activity. | STRING |
| MEDIUM | test/orchestratord/mzcompose.py | 1152 | # Create a configmap with system parameters | COMMENT |
| MEDIUM | test/orchestratord/mzcompose.py | 2152 | # 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 | 109 | # Create a LaunchDarkly client that simulates somebody interacting | COMMENT |
| MEDIUM | test/launchdarkly/mzcompose.py | 128 | # 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 | 2422 | # Creating the cluster from the definition file carries the policy. | COMMENT |
| MEDIUM | test/restart/mzcompose.py | 403 | # Creating a new replica of the disabled size is rejected. | COMMENT |
| MEDIUM | test/restart/mzcompose.py | 1073 | # Create a schema with a custom type, then exercise every object kind that | COMMENT |
| MEDIUM | test/restart/mzcompose.py | 796 | # Create a replica and wait for metrics data to arrive. | STRING |
| MEDIUM | test/lang/python/smoketest.py | 124 | # Create a table with one row of data. | COMMENT |
| MEDIUM | test/lang/python/smoketest.py | 169 | # Create a table with one row of data. | COMMENT |
| MEDIUM | test/lang/python/smoketest.py | 222 | # Create a table with one row of data. | COMMENT |
| MEDIUM | test/lang/python/smoketest.py | 283 | # 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 | 1455 | except Exception: | CODE |
| LOW | misc/python/materialize/mzbuild.py | 1521 | 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 | 520 | except Exception as e: | CODE |
| LOW | …hon/materialize/parallel_workload/parallel_workload.py | 549 | 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 | 3515 | except Exception as e: | CODE |
| LOW | misc/python/materialize/parallel_workload/action.py | 4806 | except Exception as e: | CODE |
| LOW | misc/python/materialize/parallel_workload/action.py | 4848 | except Exception as e: | CODE |
| LOW | misc/python/materialize/parallel_workload/action.py | 4858 | 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 | 949 | 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 | 1384 | except Exception: | CODE |
| LOW | misc/python/materialize/mzcompose/composition.py | 1895 | except Exception as e: | CODE |
| LOW | misc/python/materialize/mzcompose/composition.py | 1915 | 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 | 474 | except Exception as e: | CODE |
| LOW | misc/python/materialize/cli/ci_annotate_errors.py | 827 | except Exception as e: | CODE |
| LOW | misc/python/materialize/cli/ci_annotate_errors.py | 1049 | except Exception as e: | CODE |
| LOW | misc/python/materialize/cli/ci_annotate_errors.py | 1057 | 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 |
| 113 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 | 3038 | # Step 5: Server-side apply a partial v1 manifest that does not contain | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 2772 | # Step 1: Deploy with v1, complete initial rollout. | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 2789 | # Step 2: Re-apply the same spec at v1 (no changes). | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 2808 | # Step 3: Apply at v1 with a spec change (extra env var). | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 2940 | # Step 1: Deploy at v1alpha1 with client-side apply and complete the | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 2972 | # Step 2: Server-side apply the same spec at v1. Reconciling the | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3003 | # Step 3: Server-side re-apply the unchanged v1 spec (the routine GitOps | COMMENT |
| LOW | test/orchestratord/mzcompose.py | 3014 | # 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 | 869 | # 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 | 77 | """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 | 5106 | # its own. It pins the harness, since rows lost here would mean the | COMMENT |
| MEDIUM | test/cluster/mzcompose.py | 7550 | # 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 | 290 | # resolves `cargo` through the `PATH` it just set, which is what puts the | COMMENT |
| LOW | ci/test/cargo-test/mzcompose.py | 311 | # 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 | 408 | Indicates a point that will become an [arrangement](/get-started/arrangements/#arrangements) in the dataflow engin | CODE |
| MEDIUM | src/mz/src/bin/mz/upgrader.rs | 43 | /// and ensure a seamless experience. | COMMENT |
| MEDIUM | src/metrics-catalog/src/main.rs | 825 | /// 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 | 1038 | // anything more robust given the Unix APIs available to us, and the | COMMENT |
| MEDIUM | src/compute/src/render/top_k.rs | 420 | /// To provide a robust incremental orderby-limit experience, we want to avoid grouping *all* | COMMENT |
| MEDIUM | src/compute/src/render/top_k.rs | 422 | /// 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 | 1588 | /// 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 | 3647 | /// The maximum allowed result size, as requested by the client. | COMMENT |
| HIGH | src/orchestrator-process/src/lib.rs | 597 | // 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 | 720 | // All other commands we apply as requested. | COMMENT |
| HIGH | src/pgwire/src/protocol.rs | 1828 | // them to the user as requested. Its command tag is always FETCH <num rows | COMMENT |
| HIGH | src/pgwire/src/protocol.rs | 1968 | // 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 | 285 | dummy_id = snap_id + 10_000_000 + stats["modifications"] | CODE |
| LOW | test/iceberg/mzcompose.py | 287 | "snapshot-id": dummy_id, | CODE |
| LOW | test/iceberg/mzcompose.py | 311 | "snapshot-id": dummy_id, | CODE |
| LOW⚡ | doc/user/content/integrations/connection-pooling.md | 30 | "user@example.com" "mypassword-or-scram-secret" | CODE |
| LOW | doc/user/content/integrations/connection-pooling.md | 42 | "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 | 3543 | # 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 | 2416 | // Destructure `self` here so we don't forget to consider dumping newly added fields. | COMMENT |
| LOW | src/compute-client/src/controller.rs | 467 | // Destructure `self` here so we don't forget to consider dumping newly added fields. | COMMENT |
| LOW | src/compute-client/src/controller.rs | 1327 | // Destructure `self` here so we don't forget to consider dumping newly added fields. | COMMENT |
| LOW | src/compute-client/src/controller/instance.rs | 857 | // Destructure `self` here so we don't forget to consider dumping newly added fields. | COMMENT |
| LOW | src/compute-client/src/controller/instance.rs | 3194 | // Destructure `self` here so we don't forget to consider dumping newly added fields. | COMMENT |
| LOW | src/storage-controller/src/lib.rs | 2666 | // 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 | 2062 | // Don't forget to update the downgrade_since when this gets | COMMENT |
| LOW | src/persist-client/src/internal/state.rs | 2095 | // Don't forget to update the downgrade_since when this gets | COMMENT |
| LOW | src/sql/src/session/vars/definitions.rs | 2441 | // 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/redpanda_cloud.py | 24 | CODE | |
| LOW | misc/python/materialize/parallel_workload/action.py | 4355 | 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 | 86 | CODE | |
| LOW | misc/python/materialize/mzcompose/services/testdrive.py | 52 | CODE | |
| LOW | …/python/materialize/mzcompose/services/foundationdb.py | 183 | CODE | |
| LOW | …/python/materialize/mzcompose/services/foundationdb.py | 54 | 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 |
|---|---|---|---|---|
| LOW | misc/python/materialize/util.py | 176 | def _set_linger(conn: psycopg.Connection) -> None: | CODE |
| LOW | misc/python/materialize/ui.py | 176 | 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 | 3527 | 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/cluster/mzcompose.py | 8320 | def set_latency(toxi: str, latency_ms: int) -> None: | CODE |
| LOW | test/canary-load/mzcompose.py | 384 | def update_data(c: Composition, i: int) -> None: | STRING |
| LOW | ci/mkpipeline.py | 762 | def set_retry_on_agent_lost(pipeline: Any) -> None: | CODE |
| LOW | ci/mkpipeline.py | 792 | def set_default_agents_queue(pipeline: Any) -> None: | CODE |
| LOW | ci/mkpipeline.py | 804 | 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 | 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/parallel_workload/action.py | 336 | "unknown cluster 'dont_exist'", # Set intentionally to find panics | CODE |
| LOW | …/python/materialize/mzcompose/services/foundationdb.py | 146 | # Check if already configured | STRING |
| 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 | 933 | # 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 | 90 | # 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 | 49 | # 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 | 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 | 227 | 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 |
|---|---|---|---|---|
| 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 |