d_mcknight/Varken
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

wip. broken

Browse source
This commit is contained in:
Nicholas St. Germain 2019-04-24 16:07:25 -05:00
parent f00bfa5be4
commit a926ecd7f9
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
Varken.py
View file

@ -32,7 +32,12 @@ PLATFORM_LINUX_DISTRO = ' '.join(x for x in linux_distribution() if x)
def thread(): def thread():
while schedule.jobs: while schedule.jobs:
job = QUEUE.get() job = QUEUE.get()
a = job() if isinstance(job, tuple):
query = job[1]
job = job[0]
a = job(query=query)
else:
a = job()
if a is not None: if a is not None:
schedule.clear(a) schedule.clear(a)
QUEUE.task_done() QUEUE.task_done()
@ -147,7 +152,8 @@ if __name__ == "__main__":
"lidarr-{}-get_missing".format(server.id)) "lidarr-{}-get_missing".format(server.id))
if server.future_days > 0: if server.future_days > 0:
at_time = schedule.every(server.future_days_run_seconds).seconds at_time = schedule.every(server.future_days_run_seconds).seconds
at_time.do(QUEUE.put, LIDARR.get_calendar, query="Future").tag("lidarr-{}-get_future".format(server.id)) at_time.do(QUEUE.put, (LIDARR.get_calendar, "Future")).tag("lidarr-{}-get_future".format(
server.id))
if CONFIG.ombi_enabled: if CONFIG.ombi_enabled:
for server in CONFIG.ombi_servers: for server in CONFIG.ombi_servers: