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.work_on_rq(redis_queue: Queue, exc_handler=None, max_jobs=None, job: Job | str | None = None)