davanstrien HF staff commited on
Commit
6ac4ade
1 Parent(s): 8035330

Add asynccontextmanager and lifespan to main.py

Browse files
Files changed (1) hide show
  1. main.py +18 -10
main.py CHANGED
@@ -7,7 +7,7 @@ from huggingface_hub import HfApi
7
  import os
8
  from dotenv import load_dotenv
9
  import json
10
-
11
  from datetime import datetime
12
  from pathlib import Path
13
 
@@ -18,6 +18,23 @@ load_dotenv()
18
  HF_TOKEN = os.getenv("HF_TOKEN")
19
  hf_api = HfApi(token=HF_TOKEN)
20
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
21
  app = FastAPI()
22
  VOTES_FILE = "votes/votes.jsonl"
23
  # Configure CORS
@@ -34,15 +51,6 @@ app.add_middleware(
34
  allow_headers=["*"],
35
  )
36
 
37
- scheduler = CommitScheduler(
38
- repo_id="davanstrien/votes",
39
- repo_type="dataset",
40
- folder_path="votes",
41
- path_in_repo="data",
42
- every=1,
43
- hf_api=hf_api,
44
- )
45
-
46
 
47
  class Vote(BaseModel):
48
  dataset: str
 
7
  import os
8
  from dotenv import load_dotenv
9
  import json
10
+ from contextlib import asynccontextmanager
11
  from datetime import datetime
12
  from pathlib import Path
13
 
 
18
  HF_TOKEN = os.getenv("HF_TOKEN")
19
  hf_api = HfApi(token=HF_TOKEN)
20
 
21
+ scheduler = CommitScheduler(
22
+ repo_id="davanstrien/votes",
23
+ repo_type="dataset",
24
+ folder_path="votes",
25
+ path_in_repo="data",
26
+ every=1,
27
+ hf_api=hf_api,
28
+ )
29
+
30
+
31
+ @asynccontextmanager
32
+ async def lifespan(app: FastAPI):
33
+ Path("votes").mkdir(exist_ok=True)
34
+
35
+ yield
36
+
37
+
38
  app = FastAPI()
39
  VOTES_FILE = "votes/votes.jsonl"
40
  # Configure CORS
 
51
  allow_headers=["*"],
52
  )
53
 
 
 
 
 
 
 
 
 
 
54
 
55
  class Vote(BaseModel):
56
  dataset: str