From 91a39d0fb7de8da3f9d0c8ad1bce0bb862ba8403 Mon Sep 17 00:00:00 2001 From: Jer Miller Date: Tue, 14 Oct 2025 14:29:11 -0600 Subject: [PATCH] refactor(supervisor): migrate from hear/see runners to observe services MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Replaced start_runners() with start_observers() to launch the new unified observe-gnome (audio/screencast capture) and observe-sense (file processing) services instead of the legacy hear-runner and see-runner processes. Updated CLI flag from --no-runners to --no-observers. Health monitoring remains backward compatible as observe-gnome maintains the same heartbeat file interface (hear.up, see.up). 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude --- think/supervisor.py | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/think/supervisor.py b/think/supervisor.py index 118f18310..ed946717c 100644 --- a/think/supervisor.py +++ b/think/supervisor.py @@ -329,12 +329,12 @@ def check_scheduled_agents() -> None: state["start_time"] = time.time() -def start_runners() -> list[ManagedProcess]: - """Launch hear and see runners with output logging.""" +def start_observers() -> list[ManagedProcess]: + """Launch observe-gnome and observe-sense with output logging.""" procs: list[ManagedProcess] = [] commands = { - "hear": ["hear-runner", "-v"], - "see": ["see-runner", "-v"], + "observer": ["observe-gnome", "-v"], + "sense": ["observe-sense", "-v"], } for name, cmd in commands.items(): procs.append(_launch_process(name, cmd, restart=True)) @@ -551,9 +551,9 @@ def parse_args() -> argparse.ArgumentParser: help="Command used to send desktop notification", ) parser.add_argument( - "--no-runners", + "--no-observers", action="store_true", - help="Do not automatically start hear and see runners", + help="Do not automatically start observe-gnome and observe-sense", ) parser.add_argument( "--no-daily", @@ -614,8 +614,8 @@ def main() -> None: logging.info("Supervisor starting...") procs: list[ManagedProcess] = [] - if not args.no_runners: - procs.extend(start_runners()) + if not args.no_observers: + procs.extend(start_observers()) if not args.no_cortex: procs.append(start_cortex_server()) if not args.no_convey: -- 2.51.2