Skip to content

Commit

Permalink
rename
Browse files Browse the repository at this point in the history
  • Loading branch information
0xbase12 committed Dec 19, 2024
1 parent c1f016d commit 6997b9f
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions nuvla/job_engine/job/actions/monitor_bulk_job.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,8 @@

@action(action_name)
class MonitorBulkJob(object):
category_job_failed = 'Job failed'
category_job_canceled = 'Job canceled'
job_failed_reason = 'Job failed'
job_canceled_reason = 'Job canceled'

def __init__(self, job):
self.job = job
Expand Down Expand Up @@ -72,11 +72,11 @@ def update_result(self):
if state == JOB_SUCCESS and not self.result.exist_in_success(resource_id):
self.result.add_success_action(resource_id)
if state == JOB_FAILED and not self.result.exist_in_fail_reason_ids(
self.category_job_failed, resource_id):
self.result.fail_action(self.category_job_failed, resource_id)
self.job_failed_reason, resource_id):
self.result.fail_action(self.job_failed_reason, resource_id)
if state == JOB_CANCELED and not self.result.exist_in_fail_reason_ids(
self.category_job_canceled, resource_id):
self.result.fail_action(self.category_job_canceled, resource_id)
self.job_canceled_reason, resource_id):
self.result.fail_action(self.job_canceled_reason, resource_id)

def build_update_job_body(self):
update_job_body = {'progress': self.progress,
Expand Down

0 comments on commit 6997b9f

Please sign in to comment.