Z mojego doświadczenia myślę, że możesz spróbować użyć poniższego kodu, aby zaimplementować logikę ponawiania.
import time
retry_flag = True
retry_count = 0
while retry_flag and retry_count < 5:
try:
cursor.execute(query, [args['type'], args['id']])
retry_flag = False
except:
print "Retry after 1 sec"
retry_count = retry_count + 1
time.sleep(1)
Mam nadzieję, że to pomoże.
