Skip to content

Commit aaf15d2

Browse files
[fix]: check_cache_contains failing due to shared cache
1 parent a70a0df commit aaf15d2

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

shuffle-tools/1.2.0/src/app.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1807,6 +1807,7 @@ def escape_html(self, input_data):
18071807

18081808
def check_cache_contains(self, key, value, append):
18091809
org_id = self.full_execution["workflow"]["execution_org"]["id"]
1810+
url = "%s/api/v1/orgs/%s/get_cache" % (self.url, org_id)
18101811
data = {
18111812
"workflow_id": self.full_execution["workflow"]["id"],
18121813
"execution_id": self.current_execution_id,
@@ -1855,6 +1856,10 @@ def check_cache_contains(self, key, value, append):
18551856
#allvalues = get_response.json()
18561857
allvalues = self.shared_cache
18571858

1859+
if "success" not in allvalues:
1860+
get_response = requests.post(url, json=data, verify=False)
1861+
allvalues = get_response.json()
1862+
18581863
try:
18591864
if allvalues["value"] == None or allvalues["value"] == "null":
18601865
allvalues["value"] = "[]"

0 commit comments

Comments
 (0)