This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<?php | |
/* | |
* Dynamic Queue adjustments for autoscaling Action Scheduler. | |
* | |
* Every few minutes, this checks to see if the AS queue has exceeded a certain | |
* threshold of "due now" actions. And if so, will schedule additional queues to run | |
* concurrently in cron until the queue is caught up. | |
* | |
* Scales directly off of cron control's JOB_CONCURRENCY_LIMIT. |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/usr/bin/env python | |
import logging | |
import tornado.httpserver | |
import tornado.ioloop | |
import tornado.web | |
import tornado.websocket | |
from tornado.options import define, options | |
from tornado.process import Subprocess |