diff --git a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/result/FinishActor.java b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/result/FinishActor.java
index 275d82906..14fafb1ef 100644
--- a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/result/FinishActor.java
+++ b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/result/FinishActor.java
@@ -57,10 +57,8 @@ public class FinishActor extends AbstractActor  {
                    protected void doInTransactionWithoutResult(TransactionStatus status) {
                        retryTaskAccess.updateRetryTask(retryTask);
 
-                       if (TaskTypeEnum.RETRY.getType().equals(retryTask.getTaskType())) {
-                           // 创建一个回调任务
-                           callbackRetryTaskHandler.create(retryTask);
-                       }
+                       // 创建一个回调任务
+                       callbackRetryTaskHandler.create(retryTask);
                    }
                });
 
diff --git a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/handler/CallbackRetryTaskHandler.java b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/handler/CallbackRetryTaskHandler.java
index c35e31aa5..37de552eb 100644
--- a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/handler/CallbackRetryTaskHandler.java
+++ b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/handler/CallbackRetryTaskHandler.java
@@ -40,6 +40,10 @@ public class CallbackRetryTaskHandler {
 
     @Transactional
     public void create(RetryTask retryTask) {
+        if (!TaskTypeEnum.RETRY.getType().equals(retryTask.getTaskType())) {
+          return;
+        }
+
         RetryTask callbackRetryTask = RetryTaskConverter.INSTANCE.toRetryTask(retryTask);
 
         callbackRetryTask.setTaskType(TaskTypeEnum.CALLBACK.getType());