gigl.analytics.graph_validation.BQGraphValidator

class gigl.analytics.graph_validation.bq_graph_validator.BQGraphValidator

Bases: object

Methods

__init__
does_edge_table_have_dangling_edges	Validate that the edge table does not contain any dangling edges.

__weakref__

list of weak references to the object (if defined)

static does_edge_table_have_dangling_edges(edge_table: str, src_node_column_name: str, dst_node_column_name: str, query_labels: Dict[str, str] = {}, bq_gcp_project: str | None = None) → bool

Validate that the edge table does not contain any dangling edges. Meaining that an edge exists where either src_node and/or dst_node is null

Args:

edge_table (str): The edge table to validate src_node_column_name (str): The column name in the table that contains the source node ids dst_node_column_name (str): The column name in the table that contains the destination node ids query_labels (Dict[str, str], optional): Cloud Provider Labels to add to the Query. Defaults to {}. bq_gcp_project (Optional[str], optional): The GCP project to run the query in. If None the BQ

client will usse the default project inferred from the environment. Defaults to None.

Returns:

bool: True if the edge table has no dangling edges, False otherwise