Skip to content

Commit

Permalink
fix max file when using many cores
Browse files Browse the repository at this point in the history
  • Loading branch information
danilexn committed Oct 3, 2024
1 parent 18a48bb commit a2ceaed
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 4 deletions.
5 changes: 2 additions & 3 deletions openst/preprocessing/flowcell_map.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,9 +21,8 @@

# for the last merge sort, in gigabytes
MEM_PER_CORE = 4
MAX_FILES = 7_488
CHUNK_SIZE = 10_000_000
MAX_FILES = 4_000
MAX_FILES = 50_000

log_lock = threading.Lock()

Expand Down Expand Up @@ -252,7 +251,7 @@ def merge_intermediate_files(output_folder, num_processes):
# Get unique base names across all temp folders
base_names = set()
for folder in temp_folders:
if not os.path.exists(temp_folders):
if not os.path.exists(folder):
logging.error(f"The temporary folder 'temp_{i}' does not exist")
break
base_names.update(name.rsplit('.', 2)[0] for name in os.listdir(folder))
Expand Down
2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ build-backend = "poetry.core.masonry.api"

[tool.poetry]
name = "openst"
version = "0.2.0"
version = "0.2.1"
description = "The computational pipeline for the Open-ST method."
license = "GPL-2.0"
authors = [
Expand Down

0 comments on commit a2ceaed

Please sign in to comment.