Skip to content

[832] Copy to beegfs and register in Tiled#134

Open
davramov wants to merge 23 commits intoals-computing:mainfrom
davramov:beegfs
Open

[832] Copy to beegfs and register in Tiled#134
davramov wants to merge 23 commits intoals-computing:mainfrom
davramov:beegfs

Conversation

@davramov
Copy link
Copy Markdown
Contributor

This PR adds a transfer for the bl832 workflow to copy data to beegfs, and ingest the new data into Tiled.

@davramov davramov marked this pull request as ready for review May 1, 2026 16:16
@davramov davramov requested a review from dylanmcreynolds May 1, 2026 16:16
Comment thread orchestration/tiled.py Outdated
Comment thread orchestration/tiled.py Outdated
Comment thread requirements.txt Outdated
Comment thread pyproject.toml
Comment thread orchestration/tiled.py Outdated
Comment thread orchestration/tiled.py Outdated
Comment thread orchestration/tiled.py Outdated
Comment thread orchestration/tiled.py Outdated
entry_key = path.stem
logger.info(f"Looking up entry key {entry_key!r} under {prefix!r}")
try:
_apply_tags(node[entry_key])
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

if _apply_tags is called in both if and else here...what keep this from being an infinite loop? Keyerror? SWhould you breaking out when you're setting the tag at the top of this function?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I'm moving _apply_tags to its own task. It only loops if it is a directory (i.e., TIFF stack) to apply the tag to all of the files, otherwise, it only applies the tag to the top level.

@task(name="apply-tags", task_run_name="apply-tags-{tags}")
def _apply_tags(entry_node, tags: list[str]) -> None:

But this is still where I'm having trouble with

entry_node.update_metadata(access_tags=merged_tags)

vs

entry_node.patch_metadata(
    access_blob_patch=[{"op": op, "path": "", "value": {"tags": merged_tags}}],
)

davramov added 9 commits May 5, 2026 09:47
…, cleanup. Files and tags register with tiled, and I can see them via the Tiled python api, but not in the Tiled UI for some reason (maybe a sign access tags are working...)
…le: dispatcher (async) -> move.py (sync) -> register_file_to_tiled (async). Using Prefect's built in helper from prefect.utilities.asyncutils import run_coro_as_sync to run the async Tiled register() function synchronously
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants