Skip to content

Commit

Permalink
feat: 流水线级回调与流水线编排解耦 TencentBlueKing#11283
Browse files Browse the repository at this point in the history
  • Loading branch information
hejieehe committed Jan 10, 2025
1 parent 8036913 commit da44aaa
Showing 1 changed file with 9 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2216,13 +2216,15 @@ class PipelineRepositoryService constructor(
projectId = projectId,
pipelineId = pipelineId
).map { it.name }.toSet()
val needDelNames = existEventNames.subtract(events.keys).toSet()
pipelineCallbackDao.delete(
dslContext = dslContext,
projectId = projectId,
pipelineId = pipelineId,
names = needDelNames
)
if (existEventNames.isNotEmpty()) {
val needDelNames = existEventNames.subtract(events.keys).toSet()
pipelineCallbackDao.delete(
dslContext = dslContext,
projectId = projectId,
pipelineId = pipelineId,
names = needDelNames
)
}
// 保存回调事件
pipelineCallbackDao.save(
dslContext = dslContext,
Expand Down

0 comments on commit da44aaa

Please sign in to comment.