Skip to content
This repository was archived by the owner on Dec 17, 2021. It is now read-only.

Commit 823ff11

Browse files
authored
fix: profiles are now loaded from file every time (#164)
1 parent b646e19 commit 823ff11

File tree

1 file changed

+6
-4
lines changed
  • splunk_connect_for_snmp_poller/manager

1 file changed

+6
-4
lines changed

splunk_connect_for_snmp_poller/manager/poller.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -171,6 +171,7 @@ def run_enricher_check(
171171
def delete_all_entries_per_host(self, host):
172172
for entry_key in list(self._jobs_map.keys()):
173173
if entry_key.split("#")[0] == host:
174+
logger.debug("Removing job for %s", entry_key)
174175
schedule.cancel_job(self._jobs_map.get(entry_key))
175176
del self._jobs_map[entry_key]
176177

@@ -264,7 +265,7 @@ def __start_realtime_scheduler_task(self):
264265

265266
schedule.every(self._args.matching_task_frequency).seconds.do(
266267
self.process_unmatched_devices_job,
267-
self._server_config,
268+
self._args.config,
268269
)
269270

270271
automatic_realtime_job(
@@ -288,15 +289,16 @@ def add_device_for_profile_matching(self, device: InventoryRecord):
288289
self._unmatched_devices[device.host] = device
289290
self._lock.release()
290291

291-
def process_unmatched_devices_job(self, server_config):
292+
def process_unmatched_devices_job(self, config_location):
292293
job_thread = threading.Thread(
293-
target=self.process_unmatched_devices, args=[server_config]
294+
target=self.process_unmatched_devices, args=[config_location]
294295
)
295296
job_thread.start()
296297

297-
def process_unmatched_devices(self, server_config):
298+
def process_unmatched_devices(self, config_location):
298299
if self._unmatched_devices:
299300
try:
301+
server_config = parse_config_file(config_location)
300302
profiles = get_profiles(server_config)
301303
self._lock.acquire()
302304
processed_devices = set()

0 commit comments

Comments
 (0)