github/jumpserver
1
0
Fork 0
mirror of https://github.com/jumpserver/jumpserver.git synced 2026-07-02 07:01:30 +00:00
Code Issues Projects Releases Wiki Activity

perf: push account

Browse Source
This commit is contained in:
feng
2026-06-23 18:34:19 +08:00
parent 42b522b2b0
commit cf4154af7b
1 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
apps/accounts/automations/base/manager.py
View File

@@ -186,7 +186,10 @@ class BaseChangeSecretPushManager(AccountBasePlaybookManager):
print("Account not found, deleted ?")
return
account.secret = getattr(record, 'new_secret', account.secret)
update_fields = ['date_updated', 'date_change_secret', 'change_secret_status']
if hasattr(record, 'new_secret'):
account.secret = record.new_secret
update_fields.insert(0, 'secret')
account.date_updated = timezone.now()
account.date_change_secret = timezone.now()
account.change_secret_status = ChangeSecretRecordStatusChoice.success
@@ -201,9 +204,16 @@ class BaseChangeSecretPushManager(AccountBasePlaybookManager):
super().on_host_success(host, result)
with safe_atomic_db_connection():
account.save(update_fields=['secret', 'date_updated', 'date_change_secret', 'change_secret_status'])
self.save_record(record)
self.clear_account_queue_status(account.id)
try:
account.save(update_fields=update_fields)
self.save_record(record)
except Exception:
logger.exception(
'Save account success result failed: account=%s, record=%s, host=%s',
account.id, getattr(record, 'id', None), host
)
finally:
self.clear_account_queue_status(account.id)
def on_host_error(self, host, error, result):
record = self.name_record_mapper.get(host)