From b7bf0bb1591f421c6a8482d5e6f88dda8f0a9bd0 Mon Sep 17 00:00:00 2001 From: qatest Date: Mon, 7 Oct 2024 06:31:22 +0000 Subject: [PATCH] System save at 07/10/2024 12:01 by qatest --- .ipynb_checkpoints/main-checkpoint.ipynb | 4 ++-- main.ipynb | 4 ++-- main.py | 4 ++-- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/.ipynb_checkpoints/main-checkpoint.ipynb b/.ipynb_checkpoints/main-checkpoint.ipynb index 872d3a5..e3219f3 100644 --- a/.ipynb_checkpoints/main-checkpoint.ipynb +++ b/.ipynb_checkpoints/main-checkpoint.ipynb @@ -84,13 +84,13 @@ "from tms_data_interface import SQLQueryInterface\n", "\n", "class Scenario:\n", - " seq = SQLQueryInterface(schema=\"trade_schema\")\n", + " seq = SQLQueryInterface(schema=\"test_the_schema\")\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_the_table\",\n", " time_window_s = time_window_s)\n", " )\n", " cols = [\n", diff --git a/main.ipynb b/main.ipynb index 872d3a5..e3219f3 100644 --- a/main.ipynb +++ b/main.ipynb @@ -84,13 +84,13 @@ "from tms_data_interface import SQLQueryInterface\n", "\n", "class Scenario:\n", - " seq = SQLQueryInterface(schema=\"trade_schema\")\n", + " seq = SQLQueryInterface(schema=\"test_the_schema\")\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_the_table\",\n", " time_window_s = time_window_s)\n", " )\n", " cols = [\n", diff --git a/main.py b/main.py index b085628..364edde 100644 --- a/main.py +++ b/main.py @@ -81,13 +81,13 @@ FROM from tms_data_interface import SQLQueryInterface class Scenario: - seq = SQLQueryInterface(schema="trade_schema") + seq = SQLQueryInterface(schema="test_the_schema") 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_the_table", time_window_s = time_window_s) ) cols = [