qatest/55
1
0
Fork 0
generated from dhairya/scenario_template
Code Issues Pull Requests Packages Projects Releases Wiki Activity

System save at 07/10/2024 12:01 by qatest

Browse Source
This commit is contained in:
qatest 2024-10-07 06:31:22 +00:00
parent d39722b82b
commit b7bf0bb159
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
.ipynb_checkpoints/main-checkpoint.ipynb
View File

@ -84,13 +84,13 @@
"from tms_data_interface import SQLQueryInterface\n", "from tms_data_interface import SQLQueryInterface\n",
"\n", "\n",
"class Scenario:\n", "class Scenario:\n",
" seq = SQLQueryInterface(schema=\"trade_schema\")\n", " seq = SQLQueryInterface(schema=\"test_the_schema\")\n",
" def logic(self, **kwargs):\n", " def logic(self, **kwargs):\n",
" validation_window = kwargs.get('validation_window')\n", " validation_window = kwargs.get('validation_window')\n",
" time_window_s = int(validation_window/1000)\n", " time_window_s = int(validation_window/1000)\n",
" query_start_time = datetime.now()\n", " query_start_time = datetime.now()\n",
" print(\"Query start time :\",query_start_time)\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", " time_window_s = time_window_s)\n",
" )\n", " )\n",
" cols = [\n", " cols = [\n",

4
main.ipynb
View File

@ -84,13 +84,13 @@
"from tms_data_interface import SQLQueryInterface\n", "from tms_data_interface import SQLQueryInterface\n",
"\n", "\n",
"class Scenario:\n", "class Scenario:\n",
" seq = SQLQueryInterface(schema=\"trade_schema\")\n", " seq = SQLQueryInterface(schema=\"test_the_schema\")\n",
" def logic(self, **kwargs):\n", " def logic(self, **kwargs):\n",
" validation_window = kwargs.get('validation_window')\n", " validation_window = kwargs.get('validation_window')\n",
" time_window_s = int(validation_window/1000)\n", " time_window_s = int(validation_window/1000)\n",
" query_start_time = datetime.now()\n", " query_start_time = datetime.now()\n",
" print(\"Query start time :\",query_start_time)\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", " time_window_s = time_window_s)\n",
" )\n", " )\n",
" cols = [\n", " cols = [\n",

4
main.py
View File

@ -81,13 +81,13 @@ FROM
from tms_data_interface import SQLQueryInterface from tms_data_interface import SQLQueryInterface
class Scenario: class Scenario:
seq = SQLQueryInterface(schema="trade_schema") seq = SQLQueryInterface(schema="test_the_schema")
def logic(self, **kwargs): def logic(self, **kwargs):
validation_window = kwargs.get('validation_window') validation_window = kwargs.get('validation_window')
time_window_s = int(validation_window/1000) time_window_s = int(validation_window/1000)
query_start_time = datetime.now() query_start_time = datetime.now()
print("Query start time :",query_start_time) 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) time_window_s = time_window_s)
) )
cols = [ cols = [