diff --git a/.ipynb_checkpoints/main-checkpoint.ipynb b/.ipynb_checkpoints/main-checkpoint.ipynb
index 990f86f..a8cf969 100644
--- a/.ipynb_checkpoints/main-checkpoint.ipynb
+++ b/.ipynb_checkpoints/main-checkpoint.ipynb
@@ -83,13 +83,13 @@
     "from tms_data_interface import SQLQueryInterface\n",
     "\n",
     "class Scenario:\n",
-    "    seq = SQLQueryInterface(schema=\"trade_schema\")\n",
+    "    seq = SQLQueryInterface(schema=\"test_schema_test\")\n",
     "    def logic(self, **kwargs):\n",
     "        validation_window = kwargs.get('validation_window')\n",
     "        time_window_s = int(validation_window/1000)\n",
     "        query_start_time = datetime.now()\n",
     "        print(\"Query start time :\",query_start_time)\n",
-    "        row_list = self.seq.execute_raw(query.format(trade_data_1b=\"trade_10m_v3\",\n",
+    "        row_list = self.seq.execute_raw(query.format(trade_data_1b=\"test_table_test1\",\n",
     "                                                    time_window_s = time_window_s)\n",
     "                                       )\n",
     "        cols = [\n",
@@ -111,7 +111,7 @@
     "        final_scenario_df['Risk'] = 'Low Risk'\n",
     "        final_scenario_df.dropna(inplace=True)\n",
     "        # final_scenario_df['RUN_DATE'] = final_scenario_df['END_DATE']\n",
-    "        return final_scenario_df\n"
+    "        return final_scenario_df"
    ]
   }
  ],
diff --git a/main.ipynb b/main.ipynb
index 990f86f..a8cf969 100644
--- a/main.ipynb
+++ b/main.ipynb
@@ -83,13 +83,13 @@
     "from tms_data_interface import SQLQueryInterface\n",
     "\n",
     "class Scenario:\n",
-    "    seq = SQLQueryInterface(schema=\"trade_schema\")\n",
+    "    seq = SQLQueryInterface(schema=\"test_schema_test\")\n",
     "    def logic(self, **kwargs):\n",
     "        validation_window = kwargs.get('validation_window')\n",
     "        time_window_s = int(validation_window/1000)\n",
     "        query_start_time = datetime.now()\n",
     "        print(\"Query start time :\",query_start_time)\n",
-    "        row_list = self.seq.execute_raw(query.format(trade_data_1b=\"trade_10m_v3\",\n",
+    "        row_list = self.seq.execute_raw(query.format(trade_data_1b=\"test_table_test1\",\n",
     "                                                    time_window_s = time_window_s)\n",
     "                                       )\n",
     "        cols = [\n",
@@ -111,7 +111,7 @@
     "        final_scenario_df['Risk'] = 'Low Risk'\n",
     "        final_scenario_df.dropna(inplace=True)\n",
     "        # final_scenario_df['RUN_DATE'] = final_scenario_df['END_DATE']\n",
-    "        return final_scenario_df\n"
+    "        return final_scenario_df"
    ]
   }
  ],
diff --git a/main.py b/main.py
index 04fdca1..27248a6 100644
--- a/main.py
+++ b/main.py
@@ -80,13 +80,13 @@ FROM
 from tms_data_interface import SQLQueryInterface
 
 class Scenario:
-    seq = SQLQueryInterface(schema="trade_schema")
+    seq = SQLQueryInterface(schema="test_schema_test")
     def logic(self, **kwargs):
         validation_window = kwargs.get('validation_window')
         time_window_s = int(validation_window/1000)
         query_start_time = datetime.now()
         print("Query start time :",query_start_time)
-        row_list = self.seq.execute_raw(query.format(trade_data_1b="trade_10m_v3",
+        row_list = self.seq.execute_raw(query.format(trade_data_1b="test_table_test1",
                                                     time_window_s = time_window_s)
                                        )
         cols = [