From aaf15d2b5bcc9f23f9e460b3a345476c23d4e4c3 Mon Sep 17 00:00:00 2001
From: yashsinghcodes <yash9vardhan@gmail.com>
Date: Tue, 7 Jan 2025 20:25:03 +0530
Subject: [PATCH] [fix]: check_cache_contains failing due to shared cache

---
 shuffle-tools/1.2.0/src/app.py | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/shuffle-tools/1.2.0/src/app.py b/shuffle-tools/1.2.0/src/app.py
index ad11adb1..934cd364 100644
--- a/shuffle-tools/1.2.0/src/app.py
+++ b/shuffle-tools/1.2.0/src/app.py
@@ -1807,6 +1807,7 @@ def escape_html(self, input_data):
 
     def check_cache_contains(self, key, value, append):
         org_id = self.full_execution["workflow"]["execution_org"]["id"]
+        url = "%s/api/v1/orgs/%s/get_cache" % (self.url, org_id)
         data = {
             "workflow_id": self.full_execution["workflow"]["id"],
             "execution_id": self.current_execution_id,
@@ -1855,6 +1856,10 @@ def check_cache_contains(self, key, value, append):
                 #allvalues = get_response.json()
                 allvalues = self.shared_cache
 
+            if "success" not in allvalues:
+                get_response = requests.post(url, json=data, verify=False)
+                allvalues = get_response.json()
+
             try:
                 if allvalues["value"] == None or allvalues["value"] == "null":
                     allvalues["value"] = "[]"