From 37d7b7f6fbac0f71a6a78e8de097fe2ce10b3ac1 Mon Sep 17 00:00:00 2001 From: tech234a <46801700+tech234a@users.noreply.github.com> Date: Tue, 22 Sep 2020 00:34:47 -0400 Subject: [PATCH] Bug fix in reporting discoveries --- worker.py | 19 +++++++++---------- 1 file changed, 9 insertions(+), 10 deletions(-) diff --git a/worker.py b/worker.py index 1a2e5f3..5f505a2 100644 --- a/worker.py +++ b/worker.py @@ -161,7 +161,15 @@ while not gkiller.kill_now: threads.remove(x) del x - open("out/discoveries.json", "w").write(dumps({"recvids": sorted(recvids), "recchans": sorted(recchans), "recmixes": sorted(recmixes), "recplayl": sorted(recplayl)})) + print("Sending discoveries to tracker...") + #don't send channels and playlists as those have already been converted for video IDs + #IDK how to handle mixes so send them for now + for itemvid in recvids: + tracker.add_item_to_tracker(tracker.ItemType.Video, itemvid) + + for itemmix in recvids: + tracker.add_item_to_tracker(tracker.ItemType.MixPlaylist, itemmix) + #open("out/discoveries.json", "w").write(dumps({"recvids": sorted(recvids), "recchans": sorted(recchans), "recmixes": sorted(recmixes), "recplayl": sorted(recplayl)})) #clear recvids.clear() recchans.clear() @@ -194,15 +202,6 @@ while not gkiller.kill_now: sleep(1) #wait a second to hopefully allow the other threads to finish - print("Sending discoveries to tracker...") - #don't send channels and playlists as those have already been converted for video IDs - #IDK how to handle mixes so send them for now - for itemvid in recvids: - tracker.add_item_to_tracker(tracker.ItemType.Video, itemvid) - - for itemmix in recvids: - tracker.add_item_to_tracker(tracker.ItemType.MixPlaylist, itemmix) - for fol in listdir("out"): #remove extra folders try: if isdir("out/"+fol):