From 367ab9adacf363f3c1affcb3639e0e7581645d53 Mon Sep 17 00:00:00 2001 From: shohamroditimemphis Date: Sun, 10 Dec 2023 09:41:23 +0200 Subject: [PATCH 1/2] creating-a-schema-from-the-sdk-doesnt-creating-new-version-if-the-schema-already-exist --- memphis/memphis.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/memphis/memphis.py b/memphis/memphis.py index 42d2216..b478899 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 exist" in create_res["error"] : raise MemphisError(create_res["error"]) From 4158cec2e9d941d768200969f33afa7df6ee48a6 Mon Sep 17 00:00:00 2001 From: shohamroditimemphis Date: Sun, 10 Dec 2023 11:07:13 +0200 Subject: [PATCH 2/2] fix --- memphis/memphis.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/memphis/memphis.py b/memphis/memphis.py index b478899..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"] != "" and not "already exist" in create_res["error"] : + if create_res["error"] != "" and not "already exists" in create_res["error"] : raise MemphisError(create_res["error"])