From d3f1b934483d1ea57e5b5bf9565863404a01e6e2 Mon Sep 17 00:00:00 2001 From: Eugene M Date: Fri, 9 Aug 2024 16:52:15 -0400 Subject: [PATCH] FIX: parse json metadata outside of SQL engine --- .gitignore | 3 +++ .../562203c724c7_change_path_to_dataset_in_hdf5_assets.py | 7 ++----- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/.gitignore b/.gitignore index b10648632..53bf5d928 100644 --- a/.gitignore +++ b/.gitignore @@ -24,6 +24,9 @@ target/ .DS_Store *~ +#alembic +alembic.ini + #vim *.swp *.swo diff --git a/tiled/catalog/migrations/versions/562203c724c7_change_path_to_dataset_in_hdf5_assets.py b/tiled/catalog/migrations/versions/562203c724c7_change_path_to_dataset_in_hdf5_assets.py index bc3b72bdb..38efa09a6 100644 --- a/tiled/catalog/migrations/versions/562203c724c7_change_path_to_dataset_in_hdf5_assets.py +++ b/tiled/catalog/migrations/versions/562203c724c7_change_path_to_dataset_in_hdf5_assets.py @@ -27,13 +27,10 @@ def upgrade(): ) # Loop over all nodes that have 'parameters' field, choose and update those related to hdf5 files - condition = sa.text("CAST(nodes.metadata->>'parameters' AS TEXT) != ''") - cursor = connection.execute( - sa.select(nodes.c.id, nodes.c.metadata).filter(condition).select_from(nodes) - ) + cursor = connection.execute(sa.select(nodes.c.id, nodes.c.metadata).select_from(nodes)) for _id, _md in cursor: if "hdf5" in (_md.get("mimetype", "") + _md.get("spec", "")).lower(): - if isinstance(_md["parameters"], dict) and ( + if isinstance(_md.get("parameters"), dict) and ( "path" in _md["parameters"].keys() ): _md["parameters"]["dataset"] = _md["parameters"].pop("path")