Update app.py

app.py

@@ -74,10 +74,17 @@ from datasets import load_dataset
 
 #    db = sqlite3.connect(DB_FILE)
 # #created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP NOT NULL,
-def get_latest_reviews(): #db: sqlite3.Connection):
+def get_latest_reviews(celsci2): #db: sqlite3.Connection):
+    try:
+        celsci2=ecf(celsci2)
+        df=pd.DataFrame.from_dict(celsci2["videos"])
+        reviews = df.DataFrame(reviews, columns=["id", "date_created", "name", "view", "duration"])
+
+    except: # sqlite3.OperationalError:
+        df=pd.DataFrame()
+        print ("db ...")
     #reviews = db.execute("SELECT * FROM reviews ORDER BY id DESC limit 100").fetchall()
     #total_reviews = db.execute("Select COUNT(id) from reviews").fetchone()[0]
-    reviews = reviews.DataFrame(reviews, columns=["id", "date_created", "name", "view", "duration"])
     total_reviews=reviews.count()[0]
     return reviews, total_reviews
 
@@ -136,7 +143,8 @@ def run_ecs(inp):
         result=ecf(inp)
         df=pd.DataFrame.from_dict(result["videos"])
     except: # sqlite3.OperationalError:
-        print ("db error")
+        df=pd.DataFrame()
+        print ("db ...")
     
     #df=df.drop(df.columns[4], axis=1)
 
@@ -149,6 +157,9 @@ def run_ecs(inp):
     #reviews2, total_reviews2 = get_latest_reviews(db)
     #db.close()
     #print ("print000", total_reviews2,reviews2)
+    reviews2=df
+    total_reviews2=reviews2.count()[0]
+
     return reviews2, total_reviews2
     
     
@@ -179,15 +190,15 @@ with gr.Blocks(css=css) as demo:
             #run_actr()
             submit = gr.Button(value=".")            
             submit.click(ccogsphere, [name, rate, celsci], [data, count])
-            demo.load(load_data, None, [data, count])
-            #@name.change(inputs=name, outputs=celsci,_js="window.location.reload()")
-            #@rate.change(inputs=rate, outputs=name,_js="window.location.reload()")
-            @celsci.change(inputs=celsci, outputs=rate,_js="window.location.reload()")  
+            demo.load(get_latest_reviews, celsci, [data, count])
+            @name.change(inputs=name, outputs=celsci,_js="window.location.reload()")
+            @rate.change(inputs=rate, outputs=name,_js="window.location.reload()")
+            #@celsci.change(inputs=celsci, outputs=rate,_js="window.location.reload()")  
             
-            def secwork(name):
+            def secwork(celsci):
                 #if name=="abc":
                 #run_code()
-                get_latest_reviews()
+                demo.load(get_latest_reviews, celsci, [data, count])
                 #return "Hello " + name + "!"
 def backup_db():
     #shutil.copyfile(DB_FILE, "./reviews.db")