Jitendra12421 commited on
Commit
59e0f57
·
verified ·
1 Parent(s): 771e904

Upload 2 files

Browse files
Files changed (2) hide show
  1. debug_t1.py +38 -0
  2. test_accuracy.py +13 -0
debug_t1.py ADDED
@@ -0,0 +1,38 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ import sys
2
+ from pathlib import Path
3
+ sys.path.append(str(Path("backend").resolve()))
4
+ from nifty_backend.runtime import update_live_accuracy, TPLUS1_LATEST_PATH, NIFTY_1M_PATH, latest_parquet_date, NIFTY_1D_PATH
5
+ import pandas as pd
6
+ from datetime import date
7
+
8
+ latest_date = latest_parquet_date(NIFTY_1D_PATH)
9
+ session_iso = latest_date.isoformat()
10
+ print(f"session_iso: {session_iso}")
11
+ try:
12
+ t1_row = pd.read_csv(TPLUS1_LATEST_PATH).iloc[-1].to_dict()
13
+ print("t1_row target:", str(t1_row.get("target_date", ""))[:10])
14
+ if str(t1_row.get("target_date", ""))[:10] == session_iso:
15
+ pred = str(t1_row.get("prediction", "")).upper()
16
+ input_date_str = str(t1_row.get("input_date", ""))[:10]
17
+ input_day = date.fromisoformat(input_date_str)
18
+ print("input day:", input_day)
19
+ minute = pd.read_parquet(NIFTY_1M_PATH, columns=["date", "close"])
20
+ minute["dt"] = pd.to_datetime(minute["date"], errors="coerce")
21
+ minute = minute.dropna(subset=["dt"])
22
+ minute["session_date"] = minute["dt"].dt.normalize()
23
+ minute["time_str"] = minute["dt"].dt.strftime("%H:%M")
24
+ window = minute[
25
+ (minute["session_date"].dt.date == input_day)
26
+ & (minute["time_str"] >= "14:00")
27
+ & (minute["time_str"] <= "14:20")
28
+ ].sort_values("dt")
29
+ print("window len:", len(window))
30
+ if not window.empty:
31
+ w_close = float(window.iloc[-1]["close"])
32
+ print("w_close:", w_close)
33
+ else:
34
+ print("window empty!")
35
+ print("minute dates available:", minute["session_date"].dt.date.unique())
36
+ except Exception as e:
37
+ import traceback
38
+ traceback.print_exc()
test_accuracy.py ADDED
@@ -0,0 +1,13 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ import sys
2
+ from pathlib import Path
3
+ sys.path.append(str(Path("backend").resolve()))
4
+ from nifty_backend.runtime import update_live_accuracy, load_live_accuracy, latest_parquet_date, NIFTY_1D_PATH
5
+ latest_date = latest_parquet_date(NIFTY_1D_PATH)
6
+ if latest_date:
7
+ print(f"Latest date: {latest_date}")
8
+ ledger = load_live_accuracy()
9
+ print("Before:", ledger)
10
+ res = update_live_accuracy(latest_date)
11
+ print("After:", res)
12
+ else:
13
+ print("No daily data.")