itsulu/runboat
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Tweak comments

Browse source
This commit is contained in:
Stéphane Bidoul 2021-10-28 19:12:55 +02:00
parent 6f90869ef7
commit 8167fad5ec
No known key found for this signature in database
GPG key ID: BCAB2555446B5B92
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/runboat/controller.py
View file

@ -90,7 +90,7 @@ class Controller:
break # no capacity for now, back to sleep break # no capacity for now, back to sleep
to_start = self.db.to_start(limit=can_start) to_start = self.db.to_start(limit=can_start)
if not to_start: if not to_start:
break break # nothing startable, back to sleep
_logger.info(f"Starting {len(to_start)} builds of up to {can_start}.") _logger.info(f"Starting {len(to_start)} builds of up to {can_start}.")
for build in to_start: for build in to_start:
await build.scale(1) await build.scale(1)
@ -103,10 +103,10 @@ class Controller:
while True: while True:
can_stop = self.running - self.max_running can_stop = self.running - self.max_running
if can_stop <= 0: if can_stop <= 0:
break # nothing to top for now, back to sleep break # no need to stop for now, back to sleep
to_stop = self.db.oldest_started(limit=can_stop) to_stop = self.db.oldest_started(limit=can_stop)
if not to_stop: if not to_stop:
break break # nothing stoppable, back to sleep
_logger.info(f"Stopping {len(to_stop)} builds of up to {can_stop}.") _logger.info(f"Stopping {len(to_stop)} builds of up to {can_stop}.")
for build in to_stop: for build in to_stop:
await build.scale(0) await build.scale(0)
@ -119,10 +119,10 @@ class Controller:
while True: while True:
can_undeploy = self.deployed - self.max_deployed can_undeploy = self.deployed - self.max_deployed
if can_undeploy <= 0: if can_undeploy <= 0:
break # nothing to undeploy for now, back to sleep break # no need to undeploy for now, back to sleep
to_undeploy = self.db.oldest_stopped(limit=can_undeploy) to_undeploy = self.db.oldest_stopped(limit=can_undeploy)
if not to_undeploy: if not to_undeploy:
break break # nothing undeployable, back to sleep
_logger.info( _logger.info(
f"Undeploying {len(to_undeploy)} builds of up to {can_undeploy}." f"Undeploying {len(to_undeploy)} builds of up to {can_undeploy}."
) )