From b3f701dd9beb79101afb1a759ca6bb2edadbeabe Mon Sep 17 00:00:00 2001 From: user_client2024 Date: Mon, 4 Nov 2024 11:40:34 +0000 Subject: [PATCH] System save at 04/11/2024 17:10 by user_client2024 --- .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 5c9dde0..1bab5e3 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=\"internal\")\n", " def logic(self, **kwargs):\n", " validation_window = kwargs.get('validation_window', 300000)\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=\"trade_data_1b\",\n", " time_window_s = time_window_s)\n", " )\n", " cols = [\n", diff --git a/main.ipynb b/main.ipynb index 5c9dde0..1bab5e3 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=\"internal\")\n", " def logic(self, **kwargs):\n", " validation_window = kwargs.get('validation_window', 300000)\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=\"trade_data_1b\",\n", " time_window_s = time_window_s)\n", " )\n", " cols = [\n", diff --git a/main.py b/main.py index 6c598cd..e248678 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="internal") def logic(self, **kwargs): validation_window = kwargs.get('validation_window', 300000) 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="trade_data_1b", time_window_s = time_window_s) ) cols = [