|
|
@@ -51,12 +51,12 @@ class Schedule:
|
|
|
continue
|
|
|
|
|
|
plugin = self.plugins[plugin_type]()
|
|
|
- thread = threading.Thread(target=plugin.exec)
|
|
|
+ thread = threading.Thread(target=plugin.exec, kwargs=item)
|
|
|
thread.setDaemon(True)
|
|
|
thread.start()
|
|
|
|
|
|
@staticmethod
|
|
|
- def check_config(self, data_list):
|
|
|
+ def check_config(data_list):
|
|
|
enable = []
|
|
|
disable = []
|
|
|
for item in data_list:
|
|
|
@@ -64,7 +64,7 @@ class Schedule:
|
|
|
if not isinstance(item, object):
|
|
|
disable.append(item)
|
|
|
continue
|
|
|
- if not item.__contains__('dev_ip'):
|
|
|
+ if not item.__contains__('host'):
|
|
|
disable.append(item)
|
|
|
continue
|
|
|
if not item.__contains__('port'):
|
|
|
@@ -79,7 +79,7 @@ class Schedule:
|
|
|
if not item.__contains__('schema'):
|
|
|
disable.append(item)
|
|
|
continue
|
|
|
- if not item.__contains__('login_name'):
|
|
|
+ if not item.__contains__('username'):
|
|
|
disable.append(item)
|
|
|
continue
|
|
|
if not item.__contains__('pwd'):
|
