@@ -938,7 +938,7 @@ impl FlowInstServ {
938
938
)
939
939
. await ?;
940
940
if !resp. rel_bus_objs . is_empty ( ) {
941
- let inst_ids = Self :: find_inst_ids_by_rel_obj_ids ( resp. rel_bus_objs . pop ( ) . unwrap ( ) . rel_bus_obj_ids , & change_info, funs, ctx) . await ?;
941
+ let inst_ids = Self :: find_inst_ids_by_rel_obj_ids ( & current_model , resp. rel_bus_objs . pop ( ) . unwrap ( ) . rel_bus_obj_ids , & change_info, funs, ctx) . await ?;
942
942
Self :: do_modify_state_by_post_action ( inst_ids, & change_info, updated_instance_list, funs, ctx) . await ?;
943
943
}
944
944
}
@@ -949,6 +949,7 @@ impl FlowInstServ {
949
949
Ok ( ( ) )
950
950
}
951
951
async fn find_inst_ids_by_rel_obj_ids (
952
+ flow_model : & FlowModelDetailResp ,
952
953
rel_bus_obj_ids : Vec < String > ,
953
954
change_info : & FlowTransitionActionByStateChangeInfo ,
954
955
funs : & TardisFunsInst ,
@@ -970,7 +971,7 @@ impl FlowInstServ {
970
971
}
971
972
let inst_id = Self :: get_inst_ids_by_rel_business_obj_id ( vec ! [ rel_obj_id. clone( ) ] , funs, ctx) . await ?. pop ( ) . unwrap_or_default ( ) ;
972
973
973
- let resp = FlowExternalServ :: do_fetch_rel_obj ( & change_info . obj_tag , & inst_id, rel_obj_id, rel_tags, ctx, funs) . await ?;
974
+ let resp = FlowExternalServ :: do_fetch_rel_obj ( & flow_model . tag , & inst_id, rel_obj_id, rel_tags, ctx, funs) . await ?;
974
975
if !resp. rel_bus_objs . is_empty ( ) {
975
976
for rel_bus_obj in resp. rel_bus_objs {
976
977
let condition = change_condition
0 commit comments