Skip to content

Commit

Permalink
Fix missing variable
Browse files Browse the repository at this point in the history
  • Loading branch information
ranlu committed Mar 22, 2024
1 parent 2d0b430 commit 925af5b
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion dags/dag_utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ def check_manager_node(ntasks):
available_mem = psutil.virtual_memory().available
expected_mem = 2*ntasks*1024*1024*10 # 10MB for each postgresql connection
if available_mem < expected_mem:
slack_message(f":u7981:*ERROR: You need {humanize.naturalsize(expected_mem)} RAM to handle {ntasks} tasks, the manager node only have {humanize.naturalsize(total_mem)} RAM*")
slack_message(f":u7981:*ERROR: You need {humanize.naturalsize(expected_mem)} RAM to handle {ntasks} tasks, the manager node only have {humanize.naturalsize(available_mem)} RAM*")
return False

return True
Expand Down

0 comments on commit 925af5b

Please sign in to comment.