Source: factory.core/ObjScheduler.py
| Method | Signature | Description |
|---|---|---|
| load_yaml_query | load_yaml_query(query_name: str) -> str |
Compatibility wrapper around ObjData.get_queries(). |
| provision_notify | provision_notify() -> int |
Ensure all required SCHEDULER_* def_notify entries exist. |
| notify | notify(notify_code: str, message_text: str) -> None |
Send a notification using the ObjNotify system. |
| patch_param | patch_param(notes: str, depth: int = 0) -> str |
|
| reschedule | reschedule(guid: str = '') |
|
| add_schedule | add_schedule(guid: str, package: str) -> None |
Execute a scheduled task. |
| run_service | async run_service(num_workers: int = None, use_tui: bool = False) -> None |
Run the scheduler as a continuous service with worker processes. |
| compute | compute(task_name: str = '') -> None |
|
| select_compute | select_compute() -> None |
Interactive CLI for selecting and running a scheduled task. |
| poll_once | poll_once(on_due: Callable[[dict], None]) -> None |
Compute which schedule rows are due now, call on_due(row_dict) |
| check_recurring | check_recurring() -> list |
Check and execute all due recurring |
| send_email | send_email(recipients: str = '') -> None |
Send a scheduler status report email. |
Worker process that consumes tasks from the queue.
List all scheduled tasks.
Add a new scheduled task.
Disable a scheduled task.
Enable a scheduled task.
Check and execute due recurring schedules.
Send scheduler status report email.
Run scheduler as a continuous service monitoring scheduled tasks.
Manually select and execute a scheduled task interactively.