summaryrefslogtreecommitdiff
path: root/components/subscriptions/main.py
diff options
context:
space:
mode:
Diffstat (limited to 'components/subscriptions/main.py')
-rw-r--r--components/subscriptions/main.py9
1 files changed, 0 insertions, 9 deletions
diff --git a/components/subscriptions/main.py b/components/subscriptions/main.py
index 36e6d15..afd1d54 100644
--- a/components/subscriptions/main.py
+++ b/components/subscriptions/main.py
@@ -6,13 +6,10 @@ from bson.objectid import ObjectId
from feedparser import parse # type: ignore
from pymongo.collection import Collection
from pymongo.results import InsertOneResult, UpdateResult
-from schedule import Job, Scheduler
from components.database import subscriptions
from components.subscriptions.typing import SubsDict
from components.videos import VideoTuple
-default_scheduler = Scheduler()
-
@dataclass
class Subscription:
_id: str
@@ -26,15 +23,9 @@ class Subscription:
def __post_init__(self) -> None:
self._collection: Collection[SubsDict] = subscriptions
- self._scheduler: Scheduler = default_scheduler
if len(self.videos) and type(self.videos[0]) != VideoTuple:
self.videos = [VideoTuple._make(vid) for vid in self.videos]
- def initialise_job(self) -> None:
- self._job: Job = self._scheduler.every(self.time_between_fetches).minutes.do(self.fetch)
- if self.last_fetch > datetime.min.replace(tzinfo=UTC):
- self._job.next_run += self.last_fetch - datetime.now(tz=UTC)
-
def fetch(self) -> None:
try:
rss = parse(self.link)