44import requests
55import logging
66import time
7- from config import API_BASE_URL , RUNNING_FROM_EXECUTABLE , CURRENT_OS
7+ from config import API_BASE_URL , RUNNING_FROM_EXECUTABLE , CURRENT_OS , VERIFY
88from hashlib import blake2b
99from io import BytesIO
1010from pathlib import Path
@@ -31,7 +31,7 @@ def get_blocks_to_run(worker_id: str) -> list[str] | dict[str, str]:
3131 params = {'worker_id' : worker_id }
3232
3333 try :
34- response = requests .get (url , params = params )
34+ response = requests .get (url , params = params , verify = VERIFY )
3535 response .raise_for_status () # Raise an error for non-2xx status codes
3636 tasks = response .json ().get ('blocks_to_run' , [])
3737 logging .info (f'Tasks to run: { tasks } ' )
@@ -123,7 +123,7 @@ def upload_block(worker_id: str, block_name: str, data_directory: str, slog_file
123123 data = {'block_name' : block_name , 'checksum' : checksum }
124124 files = {'file' : (zip_file_name_with_timestamp , zip_buffer , 'application/zip' )}
125125
126- response = requests .post (url , params = params , data = data , files = files )
126+ response = requests .post (url , params = params , data = data , files = files , verify = VERIFY )
127127 logging .info (f"Response Status Code: { response .status_code } " )
128128
129129 if response .status_code == 200 :
0 commit comments