thomas/monutil
1
0
Fork 0
Code Issues 3 Pull requests Projects Releases Packages Wiki Activity Actions

Updated retry timeouts

Browse source
This commit is contained in:
Thomas Williams 2024-08-16 13:21:42 +01:00
parent c20f9572b9
commit 7d8f58cab7
Signed by: thomas
GPG key ID: EB8F975CF60BCBFF
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
main.py
View file

@ -70,7 +70,7 @@ def loadUrl(url):
headers = { 'User-Agent': 'Monutil monitor' } headers = { 'User-Agent': 'Monutil monitor' }
@retry(stop_max_attempt_number=3) @retry(stop_max_attempt_number=120, wait_fixed=1000)
def submitRequest(url): def submitRequest(url):
response = requests.get(url, timeout=config.urlTimeout, headers=headers) response = requests.get(url, timeout=config.urlTimeout, headers=headers)

4
rabbitmq.py
View file

@ -43,7 +43,7 @@ class rabbitMQClient:
def publish(self, message): def publish(self, message):
@retry(stop_max_attempt_number=3) @retry(stop_max_attempt_number=120, wait_fixed=1000)
def publishMessage(conn): def publishMessage(conn):
ch = conn.channel() ch = conn.channel()
@ -65,7 +65,7 @@ class rabbitMQClient:
publishMessage(conn) publishMessage(conn)
@retry(stop_max_attempt_number=3) @retry(stop_max_attempt_number=120, wait_fixed=1000)
def retrieve(self): def retrieve(self):
def callback(ch, method, properties, body): def callback(ch, method, properties, body):