diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/afl/AFLWorker.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/afl/AFLWorker.java
index 5b4e843c..816acd82 100644
--- a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/afl/AFLWorker.java
+++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/afl/AFLWorker.java
@@ -113,7 +113,7 @@ public class AFLWorker extends DockerWorker {
             }
             localVariables.put(DIYImageExecuteCommandConstant.STATUS_CODE, statusCode);
             afterTaskExecute(context);
-            afterPipelineExecute(context);
+            afterPipelineExecute(context,pipeline);
         }
     }
     private String cdSourceName(String fileName){
diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/process/service/localAflCrashes/impl/LocalAflCrashesServiceImpl.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/process/service/localAflCrashes/impl/LocalAflCrashesServiceImpl.java
index 8d86a1e4..c069d62f 100644
--- a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/process/service/localAflCrashes/impl/LocalAflCrashesServiceImpl.java
+++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/process/service/localAflCrashes/impl/LocalAflCrashesServiceImpl.java
@@ -132,9 +132,6 @@ public class LocalAflCrashesServiceImpl extends ServiceImpl<LocalAflCrashesDao,
                         if (!StringUtils.isEmpty(req.getTaskId())){
                             aflCrashesInfo.setTaskId(req.getTaskId());
                         }
-                        if (!StringUtils.isEmpty(req.getPipelineHistoryId())){
-                            aflCrashesInfo.setPipelineHistoryId(req.getPipelineHistoryId());
-                        }
                         aflCrashesInfo.setGroupIdentifier(uuid);
                     }
                 }
@@ -164,7 +161,6 @@ public class LocalAflCrashesServiceImpl extends ServiceImpl<LocalAflCrashesDao,
                                 if (!StringUtils.isEmpty(req.getTaskId())){
                                     aflCrashesInfo.setTaskId(req.getTaskId());
                                 }
-                                aflCrashesInfo.setPipelineHistoryId(req.getPipelineHistoryId());
                                 aflCrashesInfo.setTaskType("AFL");
                                 aflCrashesInfo.setInstanceId(req.getInstanceId());
                                 aflCrashesInfo.setTargetType(req.getTargetType());