| | |
| | | now, |
| | | true |
| | | ); |
| | | refreshSystemConfigCacheIfNeeded(persistenceResult); |
| | | refreshSystemConfigCacheSafely(persistenceResult); |
| | | return buildResult(job, persistenceResult.getAuditChanges(), false); |
| | | } catch (RuntimeException exception) { |
| | | markWriteFailure(validatedChanges, exception); |
| | |
| | | sourceChanges, |
| | | now |
| | | ); |
| | | refreshRollbackConfigCacheIfNeeded(persistenceResult); |
| | | refreshRollbackConfigCacheSafely(persistenceResult); |
| | | return buildResult(rollbackJob, persistenceResult.getRollbackChanges(), false); |
| | | } catch (RuntimeException exception) { |
| | | Date failureNow = new Date(); |
| | |
| | | } |
| | | } |
| | | |
| | | private void refreshSystemConfigCacheIfNeeded(ApplyPersistenceResult persistenceResult) { |
| | | private void refreshSystemConfigCacheSafely(ApplyPersistenceResult persistenceResult) { |
| | | if (persistenceResult != null && persistenceResult.isRefreshConfigCache()) { |
| | | configService.refreshSystemConfigCache(); |
| | | refreshSystemConfigCacheSafely("apply"); |
| | | } |
| | | } |
| | | |
| | |
| | | return List.of(rollbackChange); |
| | | } |
| | | |
| | | private void refreshRollbackConfigCacheIfNeeded(RollbackPersistenceResult persistenceResult) { |
| | | private void refreshRollbackConfigCacheSafely(RollbackPersistenceResult persistenceResult) { |
| | | if (persistenceResult != null && persistenceResult.isRefreshConfigCache()) { |
| | | refreshSystemConfigCacheSafely("rollback"); |
| | | } |
| | | } |
| | | |
| | | private void refreshSystemConfigCacheSafely(String scene) { |
| | | try { |
| | | configService.refreshSystemConfigCache(); |
| | | } catch (RuntimeException exception) { |
| | | LOGGER.warn("AI自动调参{}已提交,但刷新系统配置缓存失败", scene, exception); |
| | | } |
| | | } |
| | | |