diff --git a/memphis/memphis.py b/memphis/memphis.py
index 42d2216..e746a8c 100644
--- a/memphis/memphis.py
+++ b/memphis/memphis.py
@@ -997,7 +997,7 @@ async def create_schema(self, schema_name, schema_type, schema_path, timeout_ret
 
         create_res = create_res.data.decode("utf-8")
         create_res = json.loads(create_res)
-        if create_res["error"] != "":
+        if create_res["error"] != "" and not "already exists" in create_res["error"] :
             raise MemphisError(create_res["error"])