flexmeasures.utils.job_utils
Functions
- flexmeasures.utils.job_utils.get_job_timeout(queue_name: str, config: Mapping[str, Any] | None = None, logger: Logger | None = None) int
Return the configured RQ timeout for jobs in
queue_name.
- flexmeasures.utils.job_utils.job_result_ttl(queue_name: str) int
Return how long, in seconds, to keep the result of a job on the given queue.
An ingestion job’s result is kept for FLEXMEASURES_JOB_TTL, as are the results of the ingestion jobs the API queues. A job on any other queue keeps its result for FLEXMEASURES_PLANNING_TTL, including a job on a queue a plugin invents. NB job.cleanup docs say that a negative number of seconds means persisting forever.