job skip clean up

paynie · Oct 28, 2019 · ad90ef4 · ad90ef4
1 parent 9a29ae0
commit ad90ef4
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/fate_flow/driver/task_scheduler.py b/fate_flow/driver/task_scheduler.py
@@ -391,6 +391,7 @@ def finish_job(job_id, job_runtime_conf):
                               json_body={},
                               work_mode=job_parameters['work_mode'])
                 # clean
+                """
                 federated_api(job_id=job_id,
                               method='POST',
                               endpoint='/{}/schedule/{}/{}/{}/clean'.format(
@@ -403,6 +404,7 @@ def finish_job(job_id, job_runtime_conf):
                               src_role=job_initiator['role'],
                               json_body={},
                               work_mode=job_parameters['work_mode'])
+                """
         schedule_logger(job_id, delete=True)
 
     @staticmethod