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

Merge branch 'try_to_fix' into 'master'

remove error connection pool

See merge request !20
parents 2de36c77 a84cb677
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