File tree Expand file tree Collapse file tree 2 files changed +6
-2
lines changed Expand file tree Collapse file tree 2 files changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -373,7 +373,9 @@ impl TaskMgr {
373
373
TaskDependentIdent :: new_generic ( & self . tenant , task_after_dependent) ;
374
374
update_ops. push ( TxnOp :: delete ( task_after_ident. to_string_key ( ) ) ) ;
375
375
}
376
- update_ops. push ( TxnOp :: delete ( TaskStateIdent :: new ( & self . tenant , task_name) . to_string_key ( ) ) ) ;
376
+ update_ops. push ( TxnOp :: delete (
377
+ TaskStateIdent :: new ( & self . tenant , task_name) . to_string_key ( ) ,
378
+ ) ) ;
377
379
378
380
let request = TxnRequest :: new ( vec ! [ ] , update_ops) ;
379
381
let _ = self . kv_api . transaction ( request) . await ?;
Original file line number Diff line number Diff line change @@ -449,7 +449,9 @@ impl TaskService {
449
449
token. cancel ( ) ;
450
450
}
451
451
if task_mgr. accept ( & task_key) . await ? {
452
- task_mgr. clean_task_state_and_dependents ( & task_name) . await ??;
452
+ task_mgr
453
+ . clean_task_state_and_dependents ( & task_name)
454
+ . await ??;
453
455
}
454
456
task_mgr
455
457
. accept ( & TaskMessageIdent :: new (
You can’t perform that action at this time.
0 commit comments