github/OpenHands
1
0
Fork 0
mirror of https://github.com/OpenHands/OpenHands.git synced 2025-12-26 05:48:36 +08:00
Code Issues Packages Projects Releases Wiki Activity

(enh) Update Docker pull data in place (#3910)

Browse Source 
Signed-off-by: Yi Lin <teroincn@gmail.com>
This commit is contained in:
niliy01 2024-09-17 16:22:07 +08:00 committed by GitHub
parent 52c5abccbf
commit 07a094e701
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 18 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
openhands/runtime/builder/docker.py
View File

@ -1,3 +1,5 @@
import sys
import docker
from openhands.core.logger import openhands_logger as logger
@ -84,15 +86,14 @@ class DockerRuntimeBuilder(RuntimeBuilder):
)
layers = {}
previous_layer_count = 0
for line in self.docker_client.api.pull(
image_name, stream=True, decode=True
):
if 'id' in line and 'progressDetail' in line:
layer_id = line['id']
if layer_id not in layers:
layers[layer_id] = {
'last_logged': -10
} # Initialize last logged at -10%
layers[layer_id] = {'last_logged': 0}
if (
'total' in line['progressDetail']
@ -102,8 +103,13 @@ class DockerRuntimeBuilder(RuntimeBuilder):
current = line['progressDetail']['current']
percentage = (current / total) * 100
# Log if percentage is at least 10% higher than last logged
if percentage - layers[layer_id]['last_logged'] >= 10:
# refresh process bar in console if stdout is a tty
if sys.stdout.isatty():
layers[layer_id]['last_logged'] = percentage
self._output_pull_progress(layers, previous_layer_count)
previous_layer_count = len(layers)
# otherwise Log only if percentage is at least 10% higher than last logged
elif percentage - layers[layer_id]['last_logged'] >= 10:
logger.info(
f'Layer {layer_id}: {percentage:.0f}% downloaded'
)
@ -126,3 +132,10 @@ class DockerRuntimeBuilder(RuntimeBuilder):
msg += f'{ex_msg}'
logger.warning(msg)
return False
def _output_pull_progress(self, layers: dict, previous_layer_count: int) -> None:
sys.stdout.write('\033[F' * previous_layer_count)
for lid, layer_data in sorted(layers.items()):
sys.stdout.write('\033[K')
print(f'Layer {lid}: {layer_data["last_logged"]:.0f}% downloaded')
sys.stdout.flush()