feature: 优化清洗任务失败后重试

Author: hhhhsc701

backend/services/data-cleaning-service/src/main/java/com/datamate/cleaning/application/CleaningTaskService.java

@@ -171,10 +171,10 @@ public void deleteTask(String taskId) {
     }
 
     public void executeTask(String taskId) {
-        List<CleaningResultDto> failed = cleaningResultRepo.findByInstanceId(taskId, "FAILED");
-        Set<String> failedSet = failed.stream().map(CleaningResultDto::getSrcFileId).collect(Collectors.toSet());
+        List<CleaningResultDto> succeed = cleaningResultRepo.findByInstanceId(taskId, "COMPLETED");
+        Set<String> succeedSet = succeed.stream().map(CleaningResultDto::getSrcFileId).collect(Collectors.toSet());
         CleaningTaskDto task = cleaningTaskRepo.findTaskById(taskId);
-        scanDataset(taskId, task.getSrcDatasetId(), failedSet);
+        scanDataset(taskId, task.getSrcDatasetId(), succeedSet);
         cleaningResultRepo.deleteByInstanceId(taskId, "FAILED");
         taskScheduler.executeTask(taskId);
     }
@@ -232,7 +232,7 @@ private void scanDataset(String taskId, String srcDatasetId) {
         } while (pageNumber < datasetFiles.getTotalPages());
     }
 
-    private void scanDataset(String taskId, String srcDatasetId, Set<String> failedFiles) {
+    private void scanDataset(String taskId, String srcDatasetId, Set<String> succeedFiles) {
         int pageNumber = 0;
         int pageSize = 500;
         PagingQuery pageRequest = new PagingQuery(pageNumber, pageSize);
@@ -243,7 +243,7 @@ private void scanDataset(String taskId, String srcDatasetId, Set<String> failedF
                 break;
             }
             List<Map<String, Object>> files = datasetFiles.getContent().stream()
-                    .filter(content -> failedFiles.contains(content.getId()))
+                    .filter(content -> !succeedFiles.contains(content.getId()))
                     .map(content -> Map.of("fileName", (Object) content.getFileName(),
                             "fileSize", content.getFileSize(),
                             "filePath", content.getFilePath(),

frontend/src/pages/DataCleansing/Create/components/OperatorOrchestration.tsx

@@ -182,14 +182,6 @@ const OperatorFlow: React.FC<OperatorFlowProps> = ({
               {operator?.categories?.map((categoryId) => {
                 return <Tag color="default">{categoryMap[categoryId].name}</Tag>
               })}
-              {/* 参数状态指示 */}
-              {Object.values(operator.configs).some(
-                (param: any) =>
-                  (param.type === "input" && !param.defaultValue) ||
-                  (param.type === "checkbox" &&
-                    Array.isArray(param.defaultValue) &&
-                    param.defaultValue.length === 0)
-              ) && <Tag color="red">待配置</Tag>}
               {/* 操作按钮 */}
               <span
                 className="cursor-pointer text-red-500"

scripts/images/deer-flow-backend/Dockerfile

@@ -26,4 +26,4 @@ RUN --mount=type=cache,target=/root/.cache/uv \
 EXPOSE 8000
 
 # Run the application.
-CMD ["uv", "run", "python", "server.py", "--host", "0.0.0.0", "--port", "8000"]
+CMD ["uv", "run", "--no-sync", "python", "server.py", "--host", "0.0.0.0", "--port", "8000"]