diff --git a/src/forge/observability/metric_actors.py b/src/forge/observability/metric_actors.py
index d01617ba3..e74826d0c 100644
--- a/src/forge/observability/metric_actors.py
+++ b/src/forge/observability/metric_actors.py
@@ -437,12 +437,12 @@ def extract_values_from_valuemesh(results) -> list[dict[str, Any]]:
                 await backend.log_batch(reduced_metrics, global_step)
 
     @endpoint
-    def has_fetcher(self, proc_id: str) -> bool:
+    async def has_fetcher(self, proc_id: str) -> bool:
         """Check if a fetcher is registered with the given proc_id."""
         return proc_id in self.fetchers
 
     @endpoint
-    def get_fetcher_count(self) -> int:
+    async def get_fetcher_count(self) -> int:
         return len(self.fetchers)
 
     @endpoint