Skip to content
Snippets Groups Projects
Unverified Commit a84cb677 authored by REIG Julien's avatar REIG Julien
Browse files

remove error connection pool

parent 2de36c77
No related branches found
No related tags found
1 merge request!20remove error connection pool
......@@ -55,6 +55,7 @@ def send_data_in_thread(address: str, data: str, source_address: str, on_error_c
update_state(Status.UPDATING, source_address, {"message": "Status code not 201", "statusCode": result.status_code, "node_failed": normalize_url(address)})
if on_error_callback:
on_error_callback()
except RandomNetworkFailure as e:
print('Address (intentional network fail)', address, e, file=sys.stderr)
external_address = normalize_url(address)
......@@ -62,17 +63,29 @@ def send_data_in_thread(address: str, data: str, source_address: str, on_error_c
if on_error_callback:
on_error_callback()
except requests.exceptions.RequestException as e:
print('Address', address, e, file=sys.stderr)
print('[RequestException]Address', address, e, file=sys.stderr)
external_address = normalize_url(address)
update_state(Status.UPDATING, source_address, {"message": e, "statusCode": 500, "node_failed": external_address})
if on_error_callback:
on_error_callback()
except Exception as e:
print('Address', address, e, file=sys.stderr)
except requests.exceptions.HTTPError as e:
print('[HTTPError]Address', address, e, file=sys.stderr)
external_address = normalize_url(address)
update_state(Status.UPDATING, source_address, {"message": e, "statusCode": 500, "node_failed": external_address})
if on_error_callback:
on_error_callback()
except requests.exceptions.Timeout as e:
print('[Timeout]Address', address, e, file=sys.stderr)
external_address = normalize_url(address)
update_state(Status.UPDATING, source_address, {"message": e, "statusCode": 500, "node_failed": external_address})
if on_error_callback:
on_error_callback()
except Exception as e:
print('[Exception]Address', address, e, file=sys.stderr)
external_address = normalize_url(address)
update_state(Status.UPDATING, source_address, {"message": 'Exception', "statusCode": 500, "node_failed": external_address})
if on_error_callback:
on_error_callback()
def send_resource_to_other_nodes(addresses: list[str], resource: Resource, source_address: str):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment