@@ -11,19 +11,20 @@ def test_scheduler_config_as_dict(self):
1111 self .assertEqual (SCHEDULER_CONFIG .EXECUTIONS_IN_PAGE , 20 )
1212 settings .SCHEDULER_CONFIG = dict (
1313 EXECUTIONS_IN_PAGE = 1 ,
14- SCHEDULER_INTERVAL = 10 ,
14+ SCHEDULER_INTERVAL = 60 ,
1515 BROKER = Broker .REDIS ,
16- CALLBACK_TIMEOUT = 60 , # Callback timeout in seconds (success/failure/stopped)
17- # Default values, can be overriden per task/job
18- DEFAULT_SUCCESS_TTL = 10 * 60 , # Time To Live (TTL) in seconds to keep successful job results
19- DEFAULT_FAILURE_TTL = 365 * 24 * 60 * 60 , # Time To Live (TTL) in seconds to keep job failure information
20- DEFAULT_JOB_TTL = 10 * 60 , # Time To Live (TTL) in seconds to keep job information
21- DEFAULT_JOB_TIMEOUT = 5 * 60 , # timeout (seconds) for a job
16+ CALLBACK_TIMEOUT = 1111 ,
17+
18+ DEFAULT_SUCCESS_TTL = 1111 ,
19+ DEFAULT_FAILURE_TTL = 111111 ,
20+ DEFAULT_JOB_TTL = 1111 ,
21+ DEFAULT_JOB_TIMEOUT = 11111 ,
2222 # General configuration values
23- DEFAULT_WORKER_TTL = 10 * 60 , # Time To Live (TTL) in seconds to keep worker information after last heartbeat
24- DEFAULT_MAINTENANCE_TASK_INTERVAL = 10 * 60 , # The interval to run maintenance tasks in seconds. 10 minutes.
25- DEFAULT_JOB_MONITORING_INTERVAL = 30 , # The interval to monitor jobs in seconds.
26- SCHEDULER_FALLBACK_PERIOD_SECS = 120 , # Period (secs) to wait before requiring to reacquire locks
23+ DEFAULT_WORKER_TTL = 11111 ,
24+ DEFAULT_MAINTENANCE_TASK_INTERVAL = 111 ,
25+ DEFAULT_JOB_MONITORING_INTERVAL = 1111 ,
26+ SCHEDULER_FALLBACK_PERIOD_SECS = 1111 ,
2727 )
2828 conf_settings ()
29- self .assertEqual (SCHEDULER_CONFIG .EXECUTIONS_IN_PAGE , 1 )
29+ for key , value in settings .SCHEDULER_CONFIG .items ():
30+ self .assertEqual (getattr (SCHEDULER_CONFIG , key ), value )
0 commit comments