init function to get the table timestamp

1 files changed, 17 insertions, 5 deletions

diff --git a/wqflask/base/data_set.py b/wqflask/base/data_set.py
index 1a208050..131702b8 100644
--- a/wqflask/base/data_set.py
+++ b/wqflask/base/data_set.py
@@ -1255,6 +1255,21 @@ def geno_mrna_confidentiality(ob):
         return True
 
 
+def query_table_timestamp(dataset_type: str):
+    """function to query the update timestamp of a given dataset_type"""
+
+    # computation data and actions
+
+    query_update_time = """
+                    SELECT UPDATE_TIME FROM   information_schema.tables
+                    WHERE  TABLE_SCHEMA = 'db_webqtl'
+                    AND TABLE_NAME = 'ProbeSetData'
+                """
+
+    # store the timestamp in redis
+    return g.db.execute(query_update_time).fetchone()
+
+
 def generate_hash_file(dataset_name: str, dataset_timestamp: str):
     """given the trait_name generate a unique name for this"""
 
@@ -1268,7 +1283,6 @@ def cache_dataset_results(dataset_name: str, dataset_timestamp: str, query_resul
     # data computations actions
     # store the file path on redis
 
-
     file_name = generate_hash_file(dataset_name, dataset_timestamp)
 
     file_path = os.path.join(TMPDIR, f"{file_name}.json")
@@ -1285,10 +1299,8 @@ def fetch_cached_results(dataset_name: str):
     file_path = os.path.join(TMPDIR, f"{file_name}.json")
     try:
         with open(file_path, "r") as file_handler:
-            data = json.load(file_handler)
-            # print(file_handler)
-            # check if table has been modified
-            return data
+
+            return json.load(file_handler)
     except FileNotFoundError:
         # take actions continue to fetch dataset results and fetch results
         pass