Scheduled task is a pydantic model now.

Signed-off-by: Pavel Kirilin <[email protected]>

Author: s3rius

docs/examples/extending/schedule_source.py

@@ -1,4 +1,4 @@
-from typing import Any, Coroutine, List
+from typing import List
 
 from taskiq import ScheduledTask, ScheduleSource
 

taskiq/scheduler/scheduled_task.py

@@ -1,11 +1,12 @@
 import uuid
-from dataclasses import dataclass, field
+from dataclasses import field
 from datetime import datetime, timedelta
 from typing import Any, Dict, List, Optional, Union
 
+from pydantic import BaseModel
 
-@dataclass
-class CronSpec:
+
+class CronSpec(BaseModel):
     """Cron specification for running tasks."""
 
     minutes: Optional[Union[str, int]] = "*"
@@ -21,8 +22,7 @@ def to_cron(self) -> str:
         return f"{self.minutes} {self.hours} {self.days} {self.months} {self.weekdays}"
 
 
-@dataclass(frozen=True, eq=True)
-class ScheduledTask:
+class ScheduledTask(BaseModel):
     """Abstraction over task schedule."""
 
     task_name: str