| 9 | |
| 10 | |
| 11 | class ScheduleSchema(ma.Schema): |
| 12 | |
| 13 | class Meta: |
| 14 | unknown = ma.EXCLUDE |
| 15 | |
| 16 | id = ma.fields.String() |
| 17 | schedule = ma.fields.String(required=True, metadata={"example": "5 4 * * *"}) |
| 18 | task = ma.fields.Nested(OperationSchema()) |
| 19 | |
| 20 | @ma.validates('schedule') |
| 21 | def validate_schedule(self, value): |
| 22 | if not croniter.is_valid(value): |
| 23 | raise ma.ValidationError("Invalid cron syntax for schedule field.") |
| 24 | |
| 25 | @ma.post_load |
| 26 | def build_schedule(self, data, **kwargs): |
| 27 | return None if kwargs.get('partial') is True else Schedule(**data) |
| 28 | |
| 29 | |
| 30 | class Schedule(FirstClassObjectInterface, BaseObject): |