diff --git a/communicators.py b/communicators.py index 74d25ac..25427b1 100644 --- a/communicators.py +++ b/communicators.py @@ -50,7 +50,7 @@ class ConsumerCommunicator: ip = info['ip'] try: # request synchronization - response = requests.post(f"http://{ip}/sync", json={'uuid': os.environ['LOCAL_UUID']}, timeout=5) + response = self._session.post(f"http://{ip}/sync", json={'uuid': os.environ['LOCAL_UUID']}, timeout=5) except (requests.exceptions.ConnectionError, requests.exceptions.Timeout) as e: logging.error(f"Error while syncing to {ip}: {str(e)}")