15
shardID int32,
16
workflowMutation *p.InternalWorkflowMutation,
18
>
19
>
// TODO update all call sites to update LastUpdatetime
20
>
// cqlNowTimestampMillis := p.UnixMilliseconds(time.Now().UTC())
21
>
22
>
namespaceID := workflowMutation.NamespaceID
23
>
workflowID := workflowMutation.WorkflowID
24
>
runID := workflowMutation.RunID
25
>
26
>
if err := updateExecution(
27
>
batch,
28
>
shardID,
29
>
namespaceID,
30
>
workflowID,
31
>
runID,
32
>
workflowMutation.ExecutionInfoBlob,
33
>
workflowMutation.ExecutionState,
34
>
workflowMutation.ExecutionStateBlob,
35
>
workflowMutation.NextEventID,
36
>
workflowMutation.Condition,
37
>
workflowMutation.DBRecordVersion,
38
>
workflowMutation.Checksum,
39
>
); err != nil {
40
return err
41
}
42
44
>
batch,
45
>
workflowMutation.UpsertActivityInfos,
46
>
workflowMutation.DeleteActivityInfos,
47
>
shardID,
48
>
namespaceID,
49
>
workflowID,
50
>
runID,
51
>
); err != nil {
52
return err
53
}
54
56
>
batch,
57
>
workflowMutation.UpsertTimerInfos,
58
>
workflowMutation.DeleteTimerInfos,
59
>
shardID,
60
>
namespaceID,
61
>
workflowID,
62
>
runID,
63
>
); err != nil {
64
return err
65
}
66
68
>
batch,
69
>
workflowMutation.UpsertChildExecutionInfos,
70
>
workflowMutation.DeleteChildExecutionInfos,
71
>
shardID,
72
>
namespaceID,
73
>
workflowID,
74
>
runID,
75
>
); err != nil {
76
return err
77
}
78
80
>
batch,
81
>
workflowMutation.UpsertRequestCancelInfos,
82
>
workflowMutation.DeleteRequestCancelInfos,
83
>
shardID,
84
>
namespaceID,
85
>
workflowID,
86
>
runID,
87
>
); err != nil {
88
return err
89
}
90
92
>
batch,
93
>
workflowMutation.UpsertSignalInfos,
94
>
workflowMutation.DeleteSignalInfos,
95
>
shardID,
96
>
namespaceID,
97
>
workflowID,
98
>
runID,
99
>
); err != nil {
100
return err
101
}
102
104
>
batch,
105
>
workflowMutation.UpsertChasmNodes,
106
>
workflowMutation.DeleteChasmNodes,
107
>
shardID,
108
>
namespaceID,
109
>
workflowID,
110
>
runID,
111
>
); err != nil {
112
return err
113
}
114
116
>
batch,
117
>
workflowMutation.UpsertSignalRequestedIDs,
118
>
workflowMutation.DeleteSignalRequestedIDs,
119
>
shardID,
120
>
namespaceID,
121
>
workflowID,
122
>
runID,
123
>
)
124
>
125
>
updateBufferedEvents(
126
>
batch,
127
>
workflowMutation.NewBufferedEvents,
128
>
workflowMutation.ClearBufferedEvents,
129
>
shardID,
130
>
namespaceID,
131
>
workflowID,
132
>
runID,
133
>
)
134
>
135
>
// transfer / replication / timer tasks
136
>
return applyTasks(
137
>
batch,
138
>
shardID,
139
>
workflowMutation.Tasks,
140
>
)
141
}
142