version + nits

latchbio · Aug 5, 2024 · 203ea4e · 203ea4e
1 parent 74d035b
commit 203ea4e
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 3 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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(),