@@ -175,25 +175,6 @@ func createInstanceP(ctx context.Context, p redis.Pipeliner, instance *core.Work
175
175
return nil
176
176
}
177
177
178
- func updateInstanceP (ctx context.Context , p redis.Pipeliner , instance * core.WorkflowInstance , state * instanceState ) error {
179
- key := instanceKey (instance )
180
-
181
- b , err := json .Marshal (state )
182
- if err != nil {
183
- return fmt .Errorf ("marshaling instance state: %w" , err )
184
- }
185
-
186
- p .Set (ctx , key , string (b ), 0 )
187
-
188
- if state .State != core .WorkflowInstanceStateActive {
189
- p .SRem (ctx , instancesActive (), instanceSegment (instance ))
190
- }
191
-
192
- // CreatedAt does not change, so skip updating the instancesByCreation() ZSET
193
-
194
- return nil
195
- }
196
-
197
178
func readInstance (ctx context.Context , rdb redis.UniversalClient , instanceKey string ) (* instanceState , error ) {
198
179
p := rdb .Pipeline ()
199
180
@@ -255,9 +236,3 @@ func setActiveInstanceExecutionP(ctx context.Context, p redis.Pipeliner, instanc
255
236
256
237
return p .Set (ctx , key , string (b ), 0 ).Err ()
257
238
}
258
-
259
- func removeActiveInstanceExecutionP (ctx context.Context , p redis.Pipeliner , instance * core.WorkflowInstance ) error {
260
- key := activeInstanceExecutionKey (instance .InstanceID )
261
-
262
- return p .Del (ctx , key ).Err ()
263
- }
0 commit comments