diff --git a/memphis/memphis.py b/memphis/memphis.py
index 6afe30f..a519ab1 100644
--- a/memphis/memphis.py
+++ b/memphis/memphis.py
@@ -502,7 +502,8 @@ async def get_msg_schema_updates(self, internal_station_name, iterable):
             else:
                 data = message["init"]
             self.schema_updates_data[internal_station_name] = data
-            self.parse_descriptor(internal_station_name)
+            if message["init"]["type"] == "protobuf":
+                self.parse_descriptor(internal_station_name)
 
     def parse_descriptor(self, station_name):
         try: