Mirrors/Dispatcharr
1
0
Fork 1
mirror of https://github.com/Dispatcharr/Dispatcharr.git synced 2026-07-28 12:36:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 8

Search entire epg for channels to accomodate non standard epg files.

Browse source
This commit is contained in:
SergeantPanda 2025-05-24 15:07:49 -05:00
parent f87ab4b071
commit 759cbe2f7d
1 changed files with 14 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

27
apps/epg/tasks.py
View file

@ -632,17 +632,6 @@ def parse_channels_only(source):
for _, elem in channel_parser:
total_elements_processed += 1
# If we encounter a programme element, we've processed all channels
# Break out of the loop to avoid memory spike
if elem.tag == 'programme':
logger.debug(f"[parse_channels_only] Found first programme element after processing {processed_channels} channels - exiting channel parsing")
# Clean up the element before breaking
elem.clear()
parent = elem.getparent()
if parent is not None:
parent.remove(elem)
break
# Only process channel elements
if elem.tag == 'channel':
channel_count += 1
@ -818,8 +807,6 @@ def parse_channels_only(source):
# Reset parser state
del channel_parser
channel_parser = None
gc.collect()
# Perform thorough cleanup
cleanup_memory(log_usage=should_log_memory, force_collection=True)
@ -833,6 +820,20 @@ def parse_channels_only(source):
logger.info(f"[parse_channels_only] Processed all channels current memory: {process.memory_info().rss / 1024 / 1024:.2f} MB")
else:
logger.info(f"[parse_channels_only] Processed all channels")
else:
# Just clear the element to avoid memory leaks
if elem is not None:
elem.clear()
parent = elem.getparent()
if parent is not None:
while elem.getprevious() is not None:
del parent[0]
try:
parent.remove(elem)
except (ValueError, KeyError, TypeError):
pass
del elem
continue
except (etree.XMLSyntaxError, Exception) as xml_error:
logger.error(f"[parse_channels_only] XML parsing failed: {xml_error}")