| 26 | |
| 27 | |
| 28 | class AgentChangeEventHandler(FileSystemEventHandler): |
| 29 | |
| 30 | def __init__( |
| 31 | self, |
| 32 | agent_loader: AgentLoader, |
| 33 | runners_to_clean: set[str], |
| 34 | current_app_name_ref: SharedValue[str], |
| 35 | ): |
| 36 | self.agent_loader = agent_loader |
| 37 | self.runners_to_clean = runners_to_clean |
| 38 | self.current_app_name_ref = current_app_name_ref |
| 39 | |
| 40 | def on_modified(self, event): |
| 41 | if not event.src_path.endswith((".py", ".yaml", ".yml")): |
| 42 | return |
| 43 | logger.info("Change detected in agents directory: %s", event.src_path) |
| 44 | self.agent_loader.remove_agent_from_cache(self.current_app_name_ref.value) |
| 45 | self.runners_to_clean.add(self.current_app_name_ref.value) |
no outgoing calls