Update an existing schedule definition (ALTER SCHEDULE).
(&self, def: ScheduleDef)
| 42 | |
| 43 | /// Update an existing schedule definition (ALTER SCHEDULE). |
| 44 | pub fn update(&self, def: ScheduleDef) { |
| 45 | let key = (def.tenant_id, def.name.clone()); |
| 46 | let mut map = self.by_name.write().unwrap_or_else(|p| p.into_inner()); |
| 47 | map.insert(key, def); |
| 48 | } |
| 49 | |
| 50 | /// List all enabled schedules (all tenants). Used by the scheduler loop. |
| 51 | pub fn list_all_enabled(&self) -> Vec<ScheduleDef> { |