diff --git a/ai-hub/app/core/grpc/services/grpc_server.py b/ai-hub/app/core/grpc/services/grpc_server.py index f187e48..1271a50 100644 --- a/ai-hub/app/core/grpc/services/grpc_server.py +++ b/ai-hub/app/core/grpc/services/grpc_server.py @@ -292,12 +292,10 @@ except Exception as e: logger.error(f"[🔒] Failed to auto-push policy to {node_id}: {e}") - # 2. Setup Listeners - self.mesh_core.register_transport(node_id, transport) - # 2. Register in Mesh Core self.mesh_core.register_node(node_id, node.user_id, node.metadata, transport) + try: self.registry.update_stats(node_id, {"status": "streaming"})