github/jumpserver
1
0
Fork 0
mirror of https://github.com/jumpserver/jumpserver.git synced 2025-07-04 02:26:34 +00:00
Code Issues Projects Releases Wiki Activity

perf: push account without increasing version.

Browse Source
This commit is contained in:
jiangweidong 2024-12-18 16:23:22 +08:00 committed by Bryan
parent 98cf6f82b7
commit 02bdd0f07d
2 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
apps/accounts/automations/change_secret/manager.py
View File

@ -160,6 +160,10 @@ class ChangeSecretManager(AccountBasePlaybookManager):
ChangeSecretRecord.objects.bulk_create(records) ChangeSecretRecord.objects.bulk_create(records)
return inventory_hosts return inventory_hosts
@staticmethod
def need_change_account_version(account, recorder):
return account.secret != recorder.new_secret
def on_host_success(self, host, result): def on_host_success(self, host, result):
recorder = self.name_recorder_mapper.get(host) recorder = self.name_recorder_mapper.get(host)
if not recorder: if not recorder:
@ -172,7 +176,6 @@ class ChangeSecretManager(AccountBasePlaybookManager):
print("Account not found, deleted ?") print("Account not found, deleted ?")
return return
version_update_required = account.secret != recorder.new_secret
account.secret = recorder.new_secret account.secret = recorder.new_secret
account.date_updated = timezone.now() account.date_updated = timezone.now()
@ -183,7 +186,7 @@ class ChangeSecretManager(AccountBasePlaybookManager):
try: try:
recorder.save() recorder.save()
account_update_fields = ['secret', 'date_updated'] account_update_fields = ['secret', 'date_updated']
if version_update_required: if self.need_change_account_version(account, recorder):
account_update_fields.append('version') account_update_fields.append('version')
account.save(update_fields=account_update_fields) account.save(update_fields=account_update_fields)
break break

5
apps/accounts/automations/push_account/manager.py
View File

@ -8,6 +8,11 @@ logger = get_logger(__name__)
class PushAccountManager(ChangeSecretManager, AccountBasePlaybookManager): class PushAccountManager(ChangeSecretManager, AccountBasePlaybookManager):
@staticmethod
def need_change_account_version(account, recorder):
account.skip_history_when_saving = True
return False
@classmethod @classmethod
def method_type(cls): def method_type(cls):
return AutomationTypes.push_account return AutomationTypes.push_account