fix: ignore ended items in playout push queue
This commit is contained in:
parent
01e8ee924b
commit
c99f45996f
|
@ -91,12 +91,19 @@ class PypoPush(Thread):
|
||||||
for mkey in sorted_keys:
|
for mkey in sorted_keys:
|
||||||
media_item = media_schedule[mkey]
|
media_item = media_schedule[mkey]
|
||||||
|
|
||||||
|
# Ignore track that already ended
|
||||||
|
if media_item["end"] < tnow:
|
||||||
|
self.logger.debug(f"ignoring ended media_item: {media_item}")
|
||||||
|
continue
|
||||||
|
|
||||||
diff_td = tnow - media_item["start"]
|
diff_td = tnow - media_item["start"]
|
||||||
diff_sec = self.date_interval_to_seconds(diff_td)
|
diff_sec = self.date_interval_to_seconds(diff_td)
|
||||||
|
|
||||||
if diff_sec >= 0:
|
if diff_sec >= 0:
|
||||||
|
self.logger.debug(f"adding media_item to present: {media_item}")
|
||||||
present.append(media_item)
|
present.append(media_item)
|
||||||
else:
|
else:
|
||||||
|
self.logger.debug(f"adding media_item to future: {media_item}")
|
||||||
future[mkey] = media_item
|
future[mkey] = media_item
|
||||||
|
|
||||||
return present, future
|
return present, future
|
||||||
|
|
Loading…
Reference in New Issue