From bde1341337a7ab61d9332a387c90d3c5f5cc76c2 Mon Sep 17 00:00:00 2001 From: topilski Date: Mon, 10 Feb 2020 12:43:30 -0500 Subject: [PATCH] Start catchups --- app/service/service.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/app/service/service.py b/app/service/service.py index 8c279b6..1412710 100644 --- a/app/service/service.py +++ b/app/service/service.py @@ -1,3 +1,4 @@ +from datetime import datetime from bson.objectid import ObjectId from pyfastocloud_models.stream.entry import IStream, ProxyStream, EncodeStream, RelayStream, TimeshiftRecorderStream, \ @@ -408,5 +409,6 @@ class Service(IStreamHandler): def __refresh_catchups(self): for stream in self._streams: if stream.get_type() == constants.StreamType.CATCHUP: - self._client.start_stream(stream.config()) - return + now = datetime.now() + if stream.start > now and now < stream.stop and not stream.is_started(): + self._client.start_stream(stream.config())