|
|
@ -480,7 +480,7 @@ class Agora(object):
|
|
|
|
Slow ad equation update utilising exponential backoff in order to guarantee all ads are updated.
|
|
|
|
Slow ad equation update utilising exponential backoff in order to guarantee all ads are updated.
|
|
|
|
:param ads: our list of ads
|
|
|
|
:param ads: our list of ads
|
|
|
|
"""
|
|
|
|
"""
|
|
|
|
self.log.info("Beginning slow ad update for {num} ads", num=len(ads))
|
|
|
|
# self.log.info("Beginning slow ad update for {num} ads", num=len(ads))
|
|
|
|
iterations = 0
|
|
|
|
iterations = 0
|
|
|
|
throttled = 0
|
|
|
|
throttled = 0
|
|
|
|
assets = set()
|
|
|
|
assets = set()
|
|
|
@ -512,16 +512,16 @@ class Agora(object):
|
|
|
|
self.log.error("Error updating ad {ad_id}: {response}", ad_id=ad_id, response=rtrn["response"])
|
|
|
|
self.log.error("Error updating ad {ad_id}: {response}", ad_id=ad_id, response=rtrn["response"])
|
|
|
|
continue
|
|
|
|
continue
|
|
|
|
iterations += 1
|
|
|
|
iterations += 1
|
|
|
|
if iterations == 0:
|
|
|
|
# if iterations == 0:
|
|
|
|
self.log.info("Slow ad update finished, no ads to update")
|
|
|
|
# self.log.info("Slow ad update finished, no ads to update")
|
|
|
|
# self.irc.sendmsg("Slow ad update finished, no ads to update")
|
|
|
|
# self.irc.sendmsg("Slow ad update finished, no ads to update")
|
|
|
|
else:
|
|
|
|
# else:
|
|
|
|
self.log.info(
|
|
|
|
# self.log.info(
|
|
|
|
"Slow ad update completed with {iterations} iterations: [{assets}] | [{currencies}]",
|
|
|
|
# "Slow ad update completed with {iterations} iterations: [{assets}] | [{currencies}]",
|
|
|
|
iterations=iterations,
|
|
|
|
# iterations=iterations,
|
|
|
|
assets=", ".join(assets),
|
|
|
|
# assets=", ".join(assets),
|
|
|
|
currencies=", ".join(currencies),
|
|
|
|
# currencies=", ".join(currencies),
|
|
|
|
)
|
|
|
|
# )
|
|
|
|
# self.irc.sendmsg(f"Slow ad update completed with {iterations} iterations: [{', '.join(assets)}] | [{', '.join(currencies)}]")
|
|
|
|
# self.irc.sendmsg(f"Slow ad update completed with {iterations} iterations: [{', '.join(assets)}] | [{', '.join(currencies)}]")
|
|
|
|
|
|
|
|
|
|
|
|
@handle_exceptions
|
|
|
|
@handle_exceptions
|
|
|
|