check-load.py

@app.route('/tasks/check-load')
def check_load():
    """Entry point for cron task that launches a task for each cluster
    check cluster stats"""
    clusters = settings.get_all_clusters_settings()
    for cluster in clusters.iter():
        task = taskqueue.add(queue_name='shamash',
                             url="/monitors",
                             method='GET',
                             params={'cluster_name': cluster.Cluster})
        logging.debug('Task %s enqueued, ETA %s.', task.name, task.eta)

    return 'ok', 200