Module validation 

Database validation operations.

Validates that the target Materialize environment satisfies all prerequisites for deploying the project. Runs before any DDL is executed.

Validation Checklist

Check	Function	What it verifies
External databases exist	find_missing_databases	Databases referenced by external dependencies are present
External schemas exist	find_missing_schemas	Schemas referenced by external dependencies are present
Clusters exist	find_missing_clusters	All clusters in project.cluster_dependencies are present
External objects exist	find_missing_external_dependencies	Objects outside the project that are referenced exist in the catalog
Cluster isolation	validate_cluster_isolation_impl	Sources/sinks don’t share clusters with MVs/indexes (prevents accidental recreation during swap)
Privileges	validate_privileges_impl	Current role has USAGE on databases and CREATECLUSTER system privilege
Sources exist	validate_sources_exist_impl	Sources referenced by CREATE TABLE FROM SOURCE exist
Sink connections exist	validate_sink_connections_exist_impl	Connections referenced by sinks exist
Schema ownership	validate_schema_ownership_impl	Current role owns all production schemas that will be swapped
Cluster ownership	validate_cluster_ownership_impl	Current role owns all production clusters that will be swapped
Table dependencies	validate_table_dependencies_impl	Tables depended on by objects being deployed exist

Batching Strategy

Catalog lookups use IN clause queries batched in chunks of LOOKUP_BATCH_SIZE (1000) to avoid exceeding query parameter limits while minimizing round trips.

Enums

CatalogLookup 🔒

Constants

LOOKUP_BATCH_SIZE 🔒

Functions

build_compilation_errors 🔒

Converts missing external dependencies into user-facing, file-scoped errors.

build_object_paths 🔒

Reconstructs source file paths for planned objects under models/.

collect_external_dependencies 🔒

Derives the set of external database/schema prerequisites from project dependencies.

find_missing_clusters 🔒

Checks whether all cluster dependencies referenced by the project are present.

find_missing_databases 🔒

Checks catalog state for external databases that must pre-exist.

find_missing_external_dependencies 🔒

Checks whether externally-referenced objects actually exist in the target catalog.

find_missing_schemas 🔒

Checks catalog state for external schemas that must pre-exist.

query_existing_names 🔒

query_existing_object_ids 🔒

query_existing_schema_pairs 🔒

query_sources_by_cluster 🔒

Internal helper to query which sources exist on the given clusters using IN clause.

validate_cluster_isolation_impl 🔒

Internal implementation of validate_cluster_isolation.

validate_cluster_ownership_impl 🔒

Internal implementation of validate_cluster_ownership.

validate_privileges_impl 🔒

Internal implementation of validate_privileges.

validate_project_impl 🔒

Internal implementation of validate_project.

validate_schema_ownership_impl 🔒

Internal implementation of validate_schema_ownership.

validate_sink_connections_exist_impl 🔒

Internal implementation of validate_sink_connections_exist.

validate_sources_exist_impl 🔒

Internal implementation of validate_sources_exist.

validate_table_dependencies_impl 🔒

Internal implementation of validate_table_dependencies.