use correct stocks_details table

.vscode/launch.json

@@ -0,0 +1,30 @@
+{
+    // Use IntelliSense to learn about possible attributes.
+    // Hover to view descriptions of existing attributes.
+    // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "name": "Python: Current File",
+            "type": "python",
+            "request": "launch",
+            "program": "${file}",
+            "console": "integratedTerminal",
+            "justMyCode": true
+        },
+        {
+            "name": "panel serve",
+            "type": "python",
+            "request": "launch",
+            "program": "-m",
+            "args": [
+                "panel",
+                "serve",
+                "${relativeFile}",
+                "--show"
+            ],
+            "console": "integratedTerminal",
+            "justMyCode": true
+        },
+    ]
+}

instance/local.db

@@ -1,3 +1,3 @@
 version https://git-lfs.github.com/spec/v1
-oid sha256:a2632f2fc19c31d921f35ffccc198fed0f6fa32e43f93f0bdbd80d1024884366
-size 2236416
+oid sha256:8fd14d31ea743ba8f323922dafbc3e49c2b577a7c84a4c95959e8c8ef3c8effa
+size 2240512

pipeline.py

@@ -14,7 +14,7 @@ import utils
 import api
 import numpy as np
 import pytz
-import table_schema as table_s
+import table_schema as ts
 # fetch new stock price
 stock_price_stream = Stream()
 
@@ -113,11 +113,11 @@ def update_stocks_details_to_db():
     '''
     df = api.get_all_stocks_detail()
     # validation
-    if not _validate_schema(df, table_s.STOCKS_DETAILS_TABLE_SCHEMA):
+    if not _validate_schema(df, ts.STOCKS_DETAILS_TABLE_SCHEMA):
         raise ValueError(
             'df has different schema than STOCKS_DETAILS_TABLE_SCHEMA')
     with create_engine(db_url).connect() as conn:
-        df.to_sql(table_s.STOCKS_DETAILS_TABLE, con=conn,
+        df.to_sql(ts.STOCKS_DETAILS_TABLE, con=conn,
                   if_exists='replace', index=False)
 
 
@@ -174,7 +174,7 @@ def processing():
 
 def add_details_to_stock_df(stock_df):
     with create_engine(db_url).connect() as conn:
-        detail_df = pd.read_sql('stocks_details', con=conn)
+        detail_df = pd.read_sql(ts.STOCKS_DETAILS_TABLE, con=conn)
         merged_df = pd.merge(stock_df, detail_df[
             ['sector', 'name',
              'aggregate_sector',
@@ -222,15 +222,15 @@ def save_stock_price_to_db(df: pd.DataFrame):
 def update_portfolio_profile_to_db(portfolio_df):
     '''overwrite the portfolio profile table in db'''
 
-    if (_validate_schema(portfolio_df, table_s.PORTFOLIO_TABLE_SCHEMA)):
+    if (_validate_schema(portfolio_df, ts.PORTFOLIO_TABLE_SCHEMA)):
         raise ValueError(
             'portfoliijuo_df has different schema than PORTFOLIO_DB_SCHEMA')
 
     with create_engine(db_url).connect() as conn:
         print("updating profile to db")
         try:
-            portfolio_df[table_s.PORTFOLIO_TABLE_SCHEMA.keys()].to_sql(
-                table_s.PORTFOLIO_TABLE, con=conn, if_exists='append', index=False)
+            portfolio_df[ts.PORTFOLIO_TABLE_SCHEMA.keys()].to_sql(
+                ts.PORTFOLIO_TABLE, con=conn, if_exists='append', index=False)
             return True
         except:
             return False