Function setup_observer

src/google/adk/cli/fast_api.py:609–616

(observer: Observer, adk_web_server: ApiServer)

  if reload_agents:

    def setup_observer(observer: Observer, adk_web_server: ApiServer):
      agent_change_handler = AgentChangeEventHandler(
          agent_loader=agent_loader,
          runners_to_clean=adk_web_server.runners_to_clean,
          current_app_name_ref=adk_web_server.current_app_name_ref,
      )
      observer.schedule(agent_change_handler, agents_dir, recursive=True)
      observer.start()

    def tear_down_observer(observer: Observer, _: ApiServer):
      observer.stop()