Fix Futures :p
This commit is contained in:
@@ -7,9 +7,9 @@ import requests
|
||||
from core import support
|
||||
import sys
|
||||
if sys.version_info[0] >= 3:
|
||||
from lib.concurrent import futures
|
||||
from concurrent import futures
|
||||
else:
|
||||
from lib.concurrent_py2 import futures
|
||||
from concurrent_py2 import futures
|
||||
current_session = requests.Session()
|
||||
host = support.config.get_channel_url()
|
||||
onair = host + '/palinsesto/onAir.json'
|
||||
|
||||
@@ -103,9 +103,9 @@ def episodios(item):
|
||||
data = ''
|
||||
import sys
|
||||
if sys.version_info[0] >= 3:
|
||||
from lib.concurrent import futures
|
||||
from concurrent import futures
|
||||
else:
|
||||
from lib.concurrent_py2 import futures
|
||||
from concurrent_py2 import futures
|
||||
with futures.ThreadPoolExecutor() as executor:
|
||||
thL = []
|
||||
for i, season in enumerate(seasons.matches):
|
||||
|
||||
@@ -8,9 +8,9 @@ from core.item import Item
|
||||
from specials import autorenumber
|
||||
import sys
|
||||
if sys.version_info[0] >= 3:
|
||||
from lib.concurrent import futures
|
||||
from concurrent import futures
|
||||
else:
|
||||
from lib.concurrent_py2 import futures
|
||||
from concurrent_py2 import futures
|
||||
|
||||
|
||||
host = support.config.get_channel_url()
|
||||
|
||||
@@ -738,9 +738,9 @@ def check_list_links(itemlist, numero='', timeout=3):
|
||||
numero = ((int(numero) + 1) * 5) if numero != '' else 10
|
||||
import sys
|
||||
if sys.version_info[0] >= 3:
|
||||
from lib.concurrent import futures
|
||||
from concurrent import futures
|
||||
else:
|
||||
from lib.concurrent_py2 import futures
|
||||
from concurrent_py2 import futures
|
||||
with futures.ThreadPoolExecutor() as executor:
|
||||
checked = []
|
||||
for it in itemlist:
|
||||
|
||||
@@ -7,9 +7,9 @@ import os
|
||||
import re
|
||||
import sys
|
||||
if sys.version_info[0] >= 3:
|
||||
from lib.concurrent import futures
|
||||
from concurrent import futures
|
||||
else:
|
||||
from lib.concurrent_py2 import futures
|
||||
from concurrent_py2 import futures
|
||||
|
||||
try:
|
||||
import urllib.request as urllib
|
||||
|
||||
@@ -12,7 +12,7 @@ from platformcode import config, logger
|
||||
logger.info("init...")
|
||||
|
||||
librerias = xbmc.translatePath(os.path.join(config.get_runtime_path(), 'lib'))
|
||||
sys.path.insert(0, librerias)
|
||||
sys.path.append(librerias)
|
||||
|
||||
if not config.dev_mode():
|
||||
from platformcode import updater
|
||||
|
||||
@@ -593,9 +593,9 @@ def findlinks(text):
|
||||
# text += '\n' + sh
|
||||
import sys
|
||||
if sys.version_info[0] >= 3:
|
||||
from lib.concurrent import futures
|
||||
from concurrent import futures
|
||||
else:
|
||||
from lib.concurrent_py2 import futures
|
||||
from concurrent_py2 import futures
|
||||
with futures.ThreadPoolExecutor() as executor:
|
||||
unshList = [executor.submit(unshorten, match) for match in matches]
|
||||
for link in futures.as_completed(unshList):
|
||||
|
||||
@@ -449,9 +449,9 @@ def get_search_menu(item, json='', itemlist=[], channel_name=''):
|
||||
def submenu(item, json, key, itemlist = []):
|
||||
import sys
|
||||
if sys.version_info[0] >= 3:
|
||||
from lib.concurrent import futures
|
||||
from concurrent import futures
|
||||
else:
|
||||
from lib.concurrent_py2 import futures
|
||||
from concurrent_py2 import futures
|
||||
|
||||
filter_list = []
|
||||
for option in json[key]:
|
||||
|
||||
@@ -6,9 +6,9 @@ from core import scrapertools
|
||||
from core import jsontools, filetools
|
||||
import sys
|
||||
if sys.version_info[0] >= 3:
|
||||
from lib.concurrent import futures
|
||||
from concurrent import futures
|
||||
else:
|
||||
from lib.concurrent_py2 import futures
|
||||
from concurrent_py2 import futures
|
||||
|
||||
next_dialogs = ['NextDialog.xml', 'NextDialogExtended.xml', 'NextDialogCompact.xml']
|
||||
next_ep_type = config.get_setting('next_ep_type')
|
||||
|
||||
@@ -14,9 +14,9 @@ if sys.version_info[0] >= 3: PY3 = True; unicode = str; unichr = chr; long = int
|
||||
import os, json, time, inspect, channelselector
|
||||
|
||||
if PY3:
|
||||
from lib.concurrent import futures
|
||||
from concurrent import futures
|
||||
else:
|
||||
from lib.concurrent_py2 import futures
|
||||
from concurrent_py2 import futures
|
||||
from core.item import Item
|
||||
from core import tmdb, scrapertools, channeltools, filetools, jsontools
|
||||
from channelselector import get_thumb
|
||||
|
||||
Reference in New Issue
Block a user