diff --git a/python/fate_flow/utils/schedule_utils.py b/python/fate_flow/utils/schedule_utils.py
index 3bef373ec..324f4ebae 100644
--- a/python/fate_flow/utils/schedule_utils.py
+++ b/python/fate_flow/utils/schedule_utils.py
@@ -74,7 +74,7 @@ def _wrapper(*args, **kwargs):
             finally:
                 ready_signal(job_id=job.f_job_id, set_or_reset=False)
                 schedule_logger(job.f_job_id).info(f"release job {job.f_job_id} schedule lock")
-                return _result
+            return _result
         else:
             return func(*args, **kwargs)
     return _wrapper