From e4ee298aae397b151b924a4afe93975d794d7d59 Mon Sep 17 00:00:00 2001 From: Forrest Collman Date: Fri, 24 Oct 2025 06:03:30 -0700 Subject: [PATCH 1/2] fixing precomputed properties when not valid column exists --- materializationengine/blueprints/client/api2.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/materializationengine/blueprints/client/api2.py b/materializationengine/blueprints/client/api2.py index 65a7e8e6..0503ecd7 100644 --- a/materializationengine/blueprints/client/api2.py +++ b/materializationengine/blueprints/client/api2.py @@ -1992,6 +1992,7 @@ def get_precomputed_properties_and_relationships(datastack_name, table_name): continue elif c.endswith("pt_root_id"): continue + elif c.endswith("superceded_by") if c in geometry_columns: continue elif c in unique_values.keys(): @@ -2565,6 +2566,8 @@ def format_df_to_bytes(df, datastack_name, table_name, encode_single=False): geometry_columns[1] + "_y", geometry_columns[1] + "_z", ] + else: + abort("400", "Unsupported annotation type {}".format(anntype)) for p in properties: if p.enum_values is not None: df[p.id].replace( @@ -2578,7 +2581,7 @@ def format_df_to_bytes(df, datastack_name, table_name, encode_single=False): for r in relationships: if r in df.columns: kwargs[r] = df.loc[i, r] - if row["valid"]: + if row.get("valid", True): if anntype == "point": point = df.loc[i, point_cols].tolist() writer.add_point(point, id=df.loc[i, "id"], **kwargs) From 6dfc327146bd46fcd574bd83d67e9d962b8417b5 Mon Sep 17 00:00:00 2001 From: Forrest Collman Date: Fri, 24 Oct 2025 06:41:35 -0700 Subject: [PATCH 2/2] remove unneeded line --- materializationengine/blueprints/client/api2.py | 1 - 1 file changed, 1 deletion(-) diff --git a/materializationengine/blueprints/client/api2.py b/materializationengine/blueprints/client/api2.py index 0503ecd7..2934123b 100644 --- a/materializationengine/blueprints/client/api2.py +++ b/materializationengine/blueprints/client/api2.py @@ -1992,7 +1992,6 @@ def get_precomputed_properties_and_relationships(datastack_name, table_name): continue elif c.endswith("pt_root_id"): continue - elif c.endswith("superceded_by") if c in geometry_columns: continue elif c in unique_values.keys():