diff --git a/lemur/endpoints/cli.py b/lemur/endpoints/cli.py index 61677a99..689461b1 100644 --- a/lemur/endpoints/cli.py +++ b/lemur/endpoints/cli.py @@ -26,10 +26,14 @@ def expire(ttl): """ Removed all endpoints that have not been recently updated. """ + print("[+] Staring expiration of old endpoints.") now = arrow.utcnow() expiration = now - timedelta(hours=ttl) endpoints = database.session_query(Endpoint).filter(cast(Endpoint.last_updated, ArrowType) <= expiration) for endpoint in endpoints: + print("[!] Expiring endpoint: {name} Last Updated: {last_updated}".format(name=endpoint.name, last_updated=endpoint.last_updated)) database.delete(endpoint) metrics.send('endpoint_expired', 'counter', 1) + + print("[+] Finished expiration.")