From 203ea4ec357fd4a1705186406f814549b743b8b3 Mon Sep 17 00:00:00 2001 From: Rahul Desai Date: Mon, 5 Aug 2024 16:41:59 -0700 Subject: [PATCH] version + nits --- CHANGELOG.md | 7 +++++++ latch/executions.py | 2 +- latch_cli/nextflow/workflow.py | 2 +- setup.py | 2 +- 4 files changed, 10 insertions(+), 3 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index cd98f331..4f9242f9 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -16,6 +16,13 @@ Types of changes # Latch SDK Changelog +## 2.50.1 - 2024-08-05 + +### Added + +* Nextflow + - Report workdir size on workflow completion + ## 2.50.0 - 2024-08-02 ### Added diff --git a/latch/executions.py b/latch/executions.py index fc9f02bd..f74db43a 100644 --- a/latch/executions.py +++ b/latch/executions.py @@ -137,7 +137,7 @@ def add_execution_results(results: List[str]): def report_nextflow_used_storage(used_bytes: int): - token = os.environ.get("FLYTE_INTERNAL_EXECUTION_ID", None) + token = os.environ.get("FLYTE_INTERNAL_EXECUTION_ID") if token is None: return diff --git a/latch_cli/nextflow/workflow.py b/latch_cli/nextflow/workflow.py index 6eaa3cb4..8cffc1af 100644 --- a/latch_cli/nextflow/workflow.py +++ b/latch_cli/nextflow/workflow.py @@ -169,7 +169,7 @@ def nextflow_runtime(pvc_name: str, {param_signature}) -> None: size = int(result.stdout.split()[0]) report_nextflow_used_storage(size) - print(f"Done. Workdir size: {{round(size / 1024 / 1024 / 1024, 2)}} GiB") + print(f"Done. Workdir size: {{size / 1024 / 1024 / 1024: .2f}} GiB") except subprocess.TimeoutExpired: print("Failed to compute storage size: Operation timed out after 5 minutes.") except subprocess.CalledProcessError as e: diff --git a/setup.py b/setup.py index 5fda16d1..7ff42560 100644 --- a/setup.py +++ b/setup.py @@ -13,7 +13,7 @@ setup( name="latch", - version="v2.50.0", + version="v2.50.1", author_email="kenny@latch.bio", description="The Latch SDK", packages=find_packages(),