JoaquinVanschoren commited on
Commit
f65aaaf
·
1 Parent(s): e360100

Add authentication

Browse files
Files changed (2) hide show
  1. app.py +14 -0
  2. 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