Skip to content

Commit 73fed45

Browse files
committed
Added set_datastore_key support
1 parent 1a50011 commit 73fed45

1 file changed

Lines changed: 6 additions & 0 deletions

File tree

shuffle_sdk/shuffle_sdk.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1649,6 +1649,9 @@ def delete_cache(self, key, category=""):
16491649
def set_key(self, key, value, category=""):
16501650
return self.set_cache(key, value, category=category)
16511651

1652+
def set_datastore_key(self, key, value, category=""):
1653+
return self.set_cache(key, value, category=category)
1654+
16521655
def set_cache(self, key, value, category=""):
16531656
org_id = self.full_execution["workflow"]["execution_org"]["id"]
16541657
url = "%s/api/v1/orgs/%s/set_cache" % (self.url, org_id)
@@ -1691,6 +1694,9 @@ def set_cache(self, key, value, category=""):
16911694
def get_key(self, key, category=""):
16921695
return self.get_cache(key, category=category)
16931696

1697+
def get_datastore_key(self, key, category=""):
1698+
return self.get_cache(key, category=category)
1699+
16941700
def get_cache(self, key, category=""):
16951701
org_id = self.full_execution["workflow"]["execution_org"]["id"]
16961702
url = "%s/api/v1/orgs/%s/get_cache" % (self.url, org_id)

0 commit comments

Comments
 (0)