Subham9126 commited on
Commit
c8c95c6
·
verified ·
1 Parent(s): 0c90277

Upload 11 files

Browse files
Files changed (2) hide show
  1. README.md +4 -4
  2. gateway.py +5 -8
README.md CHANGED
@@ -1,8 +1,8 @@
1
  ---
2
- title: Data Clickhouse
3
- emoji: 📈
4
- colorFrom: gray
5
- colorTo: purple
6
  sdk: docker
7
  pinned: false
8
  ---
 
1
  ---
2
+ title: Clickhouseohlc
3
+ emoji: 📚
4
+ colorFrom: purple
5
+ colorTo: blue
6
  sdk: docker
7
  pinned: false
8
  ---
gateway.py CHANGED
@@ -37,8 +37,8 @@ class GatewayHandler(BaseHTTPRequestHandler):
37
  try:
38
  start = time.time()
39
  result = subprocess.run(
40
- ["bash", REFRESH_SCRIPT, "full"],
41
- capture_output=True, text=True, timeout=300,
42
  )
43
  elapsed = round(time.time() - start, 2)
44
 
@@ -60,7 +60,7 @@ class GatewayHandler(BaseHTTPRequestHandler):
60
  self._json_response(200, body)
61
 
62
  except subprocess.TimeoutExpired:
63
- self._json_response(504, {"error": "refresh timed out after 300s"})
64
  except Exception as e:
65
  self._json_response(500, {"error": str(e)})
66
 
@@ -175,13 +175,10 @@ if __name__ == "__main__":
175
 
176
  # Run initial full refresh (clone repos + create views)
177
  print("[gateway] Running initial data sync + view creation...")
178
- result = subprocess.run(
179
  ["python3", REFRESH_SCRIPT, "full"],
180
- capture_output=True, text=True, timeout=300,
181
  )
182
- print(result.stdout)
183
- if result.stderr:
184
- print(f"[gateway] stderr: {result.stderr}", file=sys.stderr)
185
 
186
  # Start gateway
187
  server = ThreadingHTTPServer(("0.0.0.0", GATEWAY_PORT), GatewayHandler)
 
37
  try:
38
  start = time.time()
39
  result = subprocess.run(
40
+ ["python3", REFRESH_SCRIPT, "full"],
41
+ capture_output=True, text=True, timeout=1200,
42
  )
43
  elapsed = round(time.time() - start, 2)
44
 
 
60
  self._json_response(200, body)
61
 
62
  except subprocess.TimeoutExpired:
63
+ self._json_response(504, {"error": "refresh timed out after 1200s"})
64
  except Exception as e:
65
  self._json_response(500, {"error": str(e)})
66
 
 
175
 
176
  # Run initial full refresh (clone repos + create views)
177
  print("[gateway] Running initial data sync + view creation...")
178
+ subprocess.run(
179
  ["python3", REFRESH_SCRIPT, "full"],
180
+ timeout=1200,
181
  )
 
 
 
182
 
183
  # Start gateway
184
  server = ThreadingHTTPServer(("0.0.0.0", GATEWAY_PORT), GatewayHandler)