Reads and writes job instance records to ores_scheduler_job_instances_tbl. More...
#include <job_instance_repository.hpp>
Collaboration diagram for job_instance_repository:
Public Types | |
| using | context = ores::database::context |
Public Member Functions | |
| std::int64_t | write_started (context ctx, const domain::job_instance &inst) |
| Inserts a new job instance row with status='started' and returns the new id. | |
| void | write_completed (context ctx, std::int64_t id, const std::chrono::system_clock::time_point &triggered_at, domain::job_status status, const std::string &error="") |
| Updates completed_at, duration_ms, status and error_message for the given id. | |
| std::vector< domain::job_instance > | read_latest (context ctx, const boost::uuids::uuid &job_definition_id, std::size_t limit=100) |
| Returns the most recent job instances for a given job_definition_id. | |
| std::optional< std::chrono::system_clock::time_point > | last_run_at (context ctx, const boost::uuids::uuid &job_definition_id) |
| Returns the triggered_at of the most recent run for a job definition, if any. | |
Detailed Description
Reads and writes job instance records to ores_scheduler_job_instances_tbl.
