jobs

Fill in a module description here

---

source

keep_alive

 keep_alive ()

*Run the scheduler in the background.

Returns: None*

---

source

start_scheduler

 start_scheduler ()

*Start the scheduler.

Returns: None*

Create()

---

source

create

 create (view_name:str, action_names:Union[str,List[str]],
         job_name:Optional[str]=None, job_config=None)

*Create a job function that fetches data from a view and runs specified actions.

Args: view_name: Name of the registered view action_names: Name or list of names of registered actions job_name: Optional name for the job

Returns: Job function*

schedule_jobs()

---

source

schedule_jobs

 schedule_jobs (config:Dict[str,Any])

*Schedule jobs based on TOML configuration.

Args: config: Dictionary containing configuration sections

Returns: None*

create_job_from_view()

---

source

create_job_from_view

 create_job_from_view (data, context=None)

*Create new jobs from views that have job configuration.

Args: data: List of views in the specified schema that have a job configuration*

utils

---

source

remove_job

 remove_job (job_id:str)

*Remove a scheduled job.

Args: job_id: Job ID to remove

Returns: Dictionary with operation result*

---

source

resume_job

 resume_job (job_id:str)

*Resume a paused job.

Args: job_id: Job ID to resume

Returns: Dictionary with operation result*

---

source

pause_job

 pause_job (job_id:str)

*Pause a scheduled job.

Args: job_id: Job ID to pause

Returns: Dictionary with operation result*

---

source

get_job_info

 get_job_info (job_id:Optional[str]=None)

*Get information about scheduled jobs.

Args: job_id: Optional job ID to get specific job info

Returns: Dictionary with job information*