Clean staging files and pull from remote peers when staging not available
Run maint tasks in a loop
Cache cluster_peers table
Convert to SQLAlchemy