Libraries refactor and add some sinks #4
|
@ -480,7 +480,7 @@ class Agora(object):
|
|||
Slow ad equation update utilising exponential backoff in order to guarantee all ads are updated.
|
||||
: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
|
||||
throttled = 0
|
||||
assets = set()
|
||||
|
@ -512,17 +512,17 @@ class Agora(object):
|
|||
self.log.error("Error updating ad {ad_id}: {response}", ad_id=ad_id, response=rtrn["response"])
|
||||
continue
|
||||
iterations += 1
|
||||
if iterations == 0:
|
||||
self.log.info("Slow ad update finished, no ads to update")
|
||||
# self.irc.sendmsg("Slow ad update finished, no ads to update")
|
||||
else:
|
||||
self.log.info(
|
||||
"Slow ad update completed with {iterations} iterations: [{assets}] | [{currencies}]",
|
||||
iterations=iterations,
|
||||
assets=", ".join(assets),
|
||||
currencies=", ".join(currencies),
|
||||
)
|
||||
# self.irc.sendmsg(f"Slow ad update completed with {iterations} iterations: [{', '.join(assets)}] | [{', '.join(currencies)}]")
|
||||
# if iterations == 0:
|
||||
# self.log.info("Slow ad update finished, no ads to update")
|
||||
# self.irc.sendmsg("Slow ad update finished, no ads to update")
|
||||
# else:
|
||||
# self.log.info(
|
||||
# "Slow ad update completed with {iterations} iterations: [{assets}] | [{currencies}]",
|
||||
# iterations=iterations,
|
||||
# assets=", ".join(assets),
|
||||
# currencies=", ".join(currencies),
|
||||
# )
|
||||
# self.irc.sendmsg(f"Slow ad update completed with {iterations} iterations: [{', '.join(assets)}] | [{', '.join(currencies)}]")
|
||||
|
||||
@handle_exceptions
|
||||
def nuke_ads(self):
|
||||
|
|
Loading…
Reference in New Issue