flexmeasures.cli.jobs

CLI commands for controlling jobs

Functions

flexmeasures.cli.jobs.handle_worker_exception(job, exc_type, exc_value, traceback)

Just a fallback, usually we would use the per-queue handler.

flexmeasures.cli.jobs.parse_queue_list(queue_names_str: str) → list[Queue]

Parse a | separated string of queue names against the app.queues dict.

The app.queues dict is expected to have queue names as keys, and rq.Queue objects as values.

Parameters:

queue_names_str – a string with queue names separated by the | character

Returns:

a list of Queue objects.

flexmeasures.cli.jobs.wrap_up_message(count_after: int)