diff --git a/apps/rpm/tasks.py b/apps/rpm/tasks.py
index 8d314a34..6cc14879 100644
--- a/apps/rpm/tasks.py
+++ b/apps/rpm/tasks.py
@@ -32,7 +32,7 @@ def close_rpj_by_leave_time():
     for m in Rpjmember.objects.filter(rpj__in=rpjs):
         rpj_member_leave(m)
 
-
+@shared_task(base=CustomTask)
 def check_remployee_leave():
     """
     检查相关方是否已经离开