mirror of https://github.com/jumpserver/jumpserver
parent
e4d28f5f3e
commit
4735565cb8
|
@ -174,6 +174,12 @@ class BasePlaybookManager:
|
||||||
self.runtime_dir,
|
self.runtime_dir,
|
||||||
callback=PlaybookCallback(),
|
callback=PlaybookCallback(),
|
||||||
)
|
)
|
||||||
|
|
||||||
|
with open(inventory_path, 'r') as f:
|
||||||
|
inventory_data = json.load(f)
|
||||||
|
if not inventory_data['all'].get('hosts'):
|
||||||
|
continue
|
||||||
|
|
||||||
runners.append(runer)
|
runners.append(runer)
|
||||||
return runners
|
return runners
|
||||||
|
|
||||||
|
@ -244,11 +250,12 @@ class BasePlaybookManager:
|
||||||
self.before_runner_start(runner)
|
self.before_runner_start(runner)
|
||||||
try:
|
try:
|
||||||
cb = runner.run(**kwargs)
|
cb = runner.run(**kwargs)
|
||||||
self.delete_sensitive_data(runner.inventory)
|
|
||||||
self.on_runner_success(runner, cb)
|
self.on_runner_success(runner, cb)
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
self.on_runner_failed(runner, e)
|
self.on_runner_failed(runner, e)
|
||||||
print('\n')
|
finally:
|
||||||
|
self.delete_sensitive_data(runner.inventory)
|
||||||
|
print('\n')
|
||||||
self.execution.status = 'success'
|
self.execution.status = 'success'
|
||||||
self.execution.date_finished = timezone.now()
|
self.execution.date_finished = timezone.now()
|
||||||
self.execution.save()
|
self.execution.save()
|
||||||
|
|
Loading…
Reference in New Issue