Spaces:
Sleeping
Sleeping
Commit
·
f65aaaf
1
Parent(s):
e360100
Add authentication
Browse files- app.py +14 -0
- validation.py +16 -0
app.py
CHANGED
|
@@ -4,6 +4,20 @@ import time
|
|
| 4 |
import traceback
|
| 5 |
from validation import validate_json, validate_croissant, validate_records, generate_validation_report
|
| 6 |
import requests
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 7 |
|
| 8 |
def process_file(file):
|
| 9 |
results = []
|
|
|
|
| 4 |
import traceback
|
| 5 |
from validation import validate_json, validate_croissant, validate_records, generate_validation_report
|
| 6 |
import requests
|
| 7 |
+
import requests, os
|
| 8 |
+
|
| 9 |
+
HF_TOKEN = os.environ.get("HF_TOKEN")
|
| 10 |
+
AUTH_HEADERS = {"Authorization": f"Bearer {HF_TOKEN}"} if HF_TOKEN else {}
|
| 11 |
+
|
| 12 |
+
_original_get = requests.get
|
| 13 |
+
def authenticated_get(url, *args, **kwargs):
|
| 14 |
+
if "headers" not in kwargs:
|
| 15 |
+
kwargs["headers"] = AUTH_HEADERS
|
| 16 |
+
else:
|
| 17 |
+
kwargs["headers"].update(AUTH_HEADERS)
|
| 18 |
+
return _original_get(url, *args, **kwargs)
|
| 19 |
+
|
| 20 |
+
requests.get = authenticated_get
|
| 21 |
|
| 22 |
def process_file(file):
|
| 23 |
results = []
|
validation.py
CHANGED
|
@@ -2,6 +2,22 @@ import json
|
|
| 2 |
import traceback
|
| 3 |
import mlcroissant as mlc
|
| 4 |
import func_timeout
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 5 |
|
| 6 |
WAIT_TIME = 10 * 60 # seconds
|
| 7 |
|
|
|
|
| 2 |
import traceback
|
| 3 |
import mlcroissant as mlc
|
| 4 |
import func_timeout
|
| 5 |
+
import os
|
| 6 |
+
import requests
|
| 7 |
+
|
| 8 |
+
HF_TOKEN = os.environ.get("HF_TOKEN")
|
| 9 |
+
AUTH_HEADERS = {"Authorization": f"Bearer {HF_TOKEN}"} if HF_TOKEN else {}
|
| 10 |
+
|
| 11 |
+
_original_get = requests.get
|
| 12 |
+
|
| 13 |
+
def authenticated_get(url, *args, **kwargs):
|
| 14 |
+
if "headers" not in kwargs:
|
| 15 |
+
kwargs["headers"] = AUTH_HEADERS
|
| 16 |
+
else:
|
| 17 |
+
kwargs["headers"].update(AUTH_HEADERS)
|
| 18 |
+
return _original_get(url, *args, **kwargs)
|
| 19 |
+
|
| 20 |
+
requests.get = authenticated_get
|
| 21 |
|
| 22 |
WAIT_TIME = 10 * 60 # seconds
|
| 23 |
|