File tree Expand file tree Collapse file tree 1 file changed +7
-4
lines changed Expand file tree Collapse file tree 1 file changed +7
-4
lines changed Original file line number Diff line number Diff line change @@ -102,13 +102,13 @@ def teardown(self) -> None:
102
102
# upon supervisor restart or upgrade.
103
103
pass
104
104
105
- def calculate_available_disk (self ):
105
+ def calculate_available_disk (self ) -> int :
106
106
"""Disk available for the creation of new VM.
107
107
108
- This take into account the disk request (but not used) for Volume of executions in the pool
108
+ This takes into account the disk request (but not used) for Volume of executions in the pool
109
109
Result in bytes."""
110
110
free_space = shutil .disk_usage (str (settings .PERSISTENT_VOLUMES_DIR )).free
111
- # Free disk space reported by system
111
+ # Free disk space reported by the system
112
112
113
113
# Calculate the reservation
114
114
total_delta = 0
@@ -118,12 +118,15 @@ def calculate_available_disk(self):
118
118
delta = execution .resources .get_disk_usage_delta ()
119
119
logger .debug ("Disk usage delta: %d for %s" , delta , execution .vm_hash )
120
120
total_delta += delta
121
- available_space = free_space - total_delta
121
+ available_space = free_space + total_delta
122
+
122
123
logger .info (
123
124
"Disk: freespace : %.f Mb, available space (non reserved) %.f Mb" ,
124
125
free_space / 1024 ** 2 ,
125
126
available_space / 1024 ** 2 ,
126
127
)
128
+ available_space = max (available_space , 0 )
129
+ # floor value to zero to avoid negative values
127
130
return available_space
128
131
129
132
async def create_a_vm (
You can’t perform that action at this time.
0 commit comments