upstream/borgbackup
1
0
Fork 0
mirror of https://github.com/borgbackup/borg.git synced 2026-02-03 20:40:16 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

cockpit: start the Borg runner after all widgets are mounted

Browse source
This commit is contained in:
Thomas Waldmann 2026-01-29 17:43:48 +01:00
parent d6b7a722f3
commit dfa9308dca
No known key found for this signature in database
GPG key ID: 243ACFA951F78E01
1 changed files with 12 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
src/borg/cockpit/app.py
View file

@ -53,22 +53,27 @@ class BorgCockpitApp(App):
def on_mount(self) -> None:
"""Initialize components."""
from .runner import BorgRunner
self.query_one("#logo").styles.animate("opacity", 1, duration=1)
self.query_one("#slogan").styles.animate("opacity", 1, duration=1)
# Delay runner start until after widgets are fully mounted
self.call_after_refresh(self.start_runner)
def start_runner(self) -> None:
"""Start the Borg runner after all widgets are mounted."""
from .runner import BorgRunner
# Speed tracking
self.total_lines_processed = 0
self.last_lines_processed = 0
self.speed_timer = self.set_interval(1.0, self.compute_speed)
self.start_time = time.monotonic()
self.process_running = True
args = getattr(self, "borg_args", ["--version"]) # Default to safe command if none passed
self.runner = BorgRunner(args, self.handle_log_event)
self.runner_task = asyncio.create_task(self.runner.start())
# Speed tracking
self.total_lines_processed = 0
self.last_lines_processed = 0
self.speed_timer = self.set_interval(1.0, self.compute_speed)
def compute_speed(self) -> None:
"""Calculate and update speed (lines per second)."""
current_lines = self.total_lines_processed