linspector/uplink
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

import threadung libs only when used

Browse source
This commit is contained in:
Johannes Findeisen 2022-07-31 21:26:18 +02:00
commit 8dd81c5eee
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
uplink
View file

@ -28,7 +28,6 @@ import os
import sys import sys
import time import time
from threading import Thread
from uplink import Uplink from uplink import Uplink
# Version format: MAJOR.FEATURE.FIXES # Version format: MAJOR.FEATURE.FIXES
@ -149,12 +148,14 @@ def main():
uplink = Uplink("/tmp/uplink.pid", config) uplink = Uplink("/tmp/uplink.pid", config)
if args.cron: if args.cron:
from threading import Thread
for i in range(len(config["uplinks"])): for i in range(len(config["uplinks"])):
t = Thread(target=uplink.fetch_data, args=(config, i)) t = Thread(target=uplink.fetch_data, args=(config, i))
t.start() t.start()
elif args.daemon: elif args.daemon:
uplink.start() uplink.start()
elif args.foreground: elif args.foreground:
from threading import Thread
while True: while True:
for i in range(len(config["uplinks"])): for i in range(len(config["uplinks"])):
t = Thread(target=uplink.fetch_data, args=(config, i)) t = Thread(target=uplink.fetch_data, args=(config, i))