slhaf/Partner
1
0
Fork 0
mirror of https://github.com/slhaf/Partner.git synced 2026-05-12 08:43:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(action): remove legacy additionalContext from Action state and snapshots

Browse Source
This commit is contained in:
slhafzjw
2026-03-26 21:22:59 +08:00
parent b65f5f37fb
commit 7bbb7745f4
1 changed files with 2 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
Partner-Core/src/main/java/work/slhaf/partner/core/action/entity/Action.kt
View File

@@ -107,11 +107,6 @@ sealed class ExecutableAction : Action() {
val history: MutableMap<Int, MutableList<HistoryAction>> = mutableMapOf() val history: MutableMap<Int, MutableList<HistoryAction>> = mutableMapOf()
/**
* 修复上下文
*/
val additionalContext: MutableMap<Int, MutableList<String>> = mutableMapOf()
override val timeout: Duration = 10.minutes override val timeout: Duration = 10.minutes
/** /**
@@ -123,12 +118,12 @@ sealed class ExecutableAction : Action() {
val interruptAt = Instant.now().epochSecond val interruptAt = Instant.now().epochSecond
while (status == Status.INTERRUPTED) { while (status == Status.INTERRUPTED) {
Thread.sleep(500); Thread.sleep(500)
if (Instant.now().epochSecond - interruptAt > timeout) { if (Instant.now().epochSecond - interruptAt > timeout) {
return false return false
} }
} }
return true; return true
} }
fun resume() { fun resume() {
@@ -150,7 +145,6 @@ sealed class ExecutableAction : Action() {
executingStage = executingStage, executingStage = executingStage,
result = if (::result.isInitialized) result else null, result = if (::result.isInitialized) result else null,
history = history.mapValues { (_, value) -> value.toList() }, history = history.mapValues { (_, value) -> value.toList() },
additionalContext = additionalContext.mapValues { (_, value) -> value.toList() },
scheduleType = schedulable?.scheduleType, scheduleType = schedulable?.scheduleType,
scheduleContent = schedulable?.scheduleContent, scheduleContent = schedulable?.scheduleContent,
enabled = schedulable?.enabled enabled = schedulable?.enabled
@@ -178,7 +172,6 @@ data class SchedulableExecutableAction(
val newHistory = ScheduleHistory(ZonedDateTime.now(), result, history.toMap()) val newHistory = ScheduleHistory(ZonedDateTime.now(), result, history.toMap())
scheduleHistories.add(newHistory) scheduleHistories.add(newHistory)
additionalContext.clear()
executingStage = 0 executingStage = 0
for (entry in actionChain) { for (entry in actionChain) {
for (action in entry.value) { for (action in entry.value) {
@@ -275,7 +268,6 @@ data class ExecutableActionSnapshot(
val executingStage: Int, val executingStage: Int,
val result: String?, val result: String?,
val history: Map<Int, List<HistoryAction>>, val history: Map<Int, List<HistoryAction>>,
val additionalContext: Map<Int, List<String>>,
val scheduleType: Schedulable.ScheduleType? = null, val scheduleType: Schedulable.ScheduleType? = null,
val scheduleContent: String? = null, val scheduleContent: String? = null,