This commit is contained in:
@ -47,8 +47,9 @@ def run(redis_client: Redis, site_url_map: Dict[str, str]):
|
||||
logging.debug("Default site is not set. Selecting one...")
|
||||
for site in Config.SITE_LIST:
|
||||
if site.name not in incraising_queue_at:
|
||||
redis_client.set("DEFAULT:SCHEDULED", site)
|
||||
logging.info(f"Default site set to {site}")
|
||||
ensure_running_pod_on_site(site.name) # blocking
|
||||
redis_client.set("DEFAULT:SCHEDULED", site.name)
|
||||
logging.info(f"Default site set to {site.name}")
|
||||
break
|
||||
else:
|
||||
logging.debug("Not enough data points to decide on default site yet")
|
||||
|
Reference in New Issue
Block a user