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 {
373373 TaskDependentIdent :: new_generic ( & self . tenant , task_after_dependent) ;
374374 update_ops. push ( TxnOp :: delete ( task_after_ident. to_string_key ( ) ) ) ;
375375 }
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+ ) ) ;
377379
378380 let request = TxnRequest :: new ( vec ! [ ] , update_ops) ;
379381 let _ = self . kv_api . transaction ( request) . await ?;
Original file line number Diff line number Diff line change @@ -449,7 +449,9 @@ impl TaskService {
449449 token. cancel ( ) ;
450450 }
451451 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 ??;
453455 }
454456 task_mgr
455457 . accept ( & TaskMessageIdent :: new (
You can’t perform that action at this time.
0 commit comments