Skip to content

Commit

Permalink
feat: use mesh dir and dynamic dir from metadata
Browse files Browse the repository at this point in the history
  • Loading branch information
akhileshh committed Dec 9, 2024
1 parent 53b8e41 commit 47f2d2f
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 14 deletions.
2 changes: 1 addition & 1 deletion .bumpversion.cfg
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
[bumpversion]
current_version = 3.0.9
current_version = 3.0.10
commit = True
tag = True

Expand Down
2 changes: 1 addition & 1 deletion pychunkedgraph/__init__.py
Original file line number Diff line number Diff line change
@@ -1 +1 @@
__version__ = "3.0.9"
__version__ = "3.0.10"
18 changes: 6 additions & 12 deletions workers/mesh_worker.py
Original file line number Diff line number Diff line change
Expand Up @@ -37,9 +37,12 @@ def callback(payload):
)

try:
mesh_dir = cg.meta.dataset_info["mesh"]
mesh_meta = cg.meta.dataset_info["mesh_metadata"]
cv_unsharded_mesh_dir = mesh_meta.get("unsharded_mesh_dir", f"dynamic_{cg.graph_id}")
mesh_meta = cg.meta.custom_data["mesh"]
mesh_dir = mesh_meta["dir"]
layer = mesh_meta["max_layer"]
mip = mesh_meta["mip"]
err = mesh_meta["max_error"]
cv_unsharded_mesh_dir = mesh_meta.get("dynamic_mesh_dir", "dynamic")
except KeyError:
logging.warning(f"No metadata found for {cg.graph_id}; ignoring...")
return
Expand All @@ -48,15 +51,6 @@ def callback(payload):
cg.meta.data_source.WATERSHED, mesh_dir, cv_unsharded_mesh_dir
)

try:
mesh_data = cg.meta.custom_data["mesh"]
layer = mesh_data["max_layer"]
mip = mesh_data["mip"]
err = mesh_data["max_error"]
except KeyError:
return


logging.log(INFO_HIGH, f"remeshing {l2ids}; graph {table_id} operation {op_id}.")
meshgen.remeshing(
cg,
Expand Down

0 comments on commit 47f2d2f

Please sign in to comment.