|
@@ -388,7 +388,7 @@ public class TaskApplicationService {
|
|
|
}
|
|
|
}
|
|
|
if (allCom){
|
|
|
- multiSimulationProjectParam.setProjectStatus(MultiSimulationStatusEnum.COMPLETED_STATUS.getProjectStatus());
|
|
|
+ multiSimulationProjectParam.setProjectStatus(DictConstants.TASK_ABORTED.equals(state) ? MultiSimulationStatusEnum.TERMINATED_STATUS.getProjectStatus() : MultiSimulationStatusEnum.COMPLETED_STATUS.getProjectStatus());
|
|
|
multiSimulationProjectMapper.updateMultiSimulationProjectStatus(multiSimulationProjectParam);
|
|
|
// 删除kafka topic
|
|
|
KafkaUtil.deleteTopic(kafkaAdminClient, projectId);
|