X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=catalog%2Fpub%2Futils%2Fjobutil.py;h=c2e1c1578f182d3a1cb635051db9d6c2fe6756f1;hb=a9a3ee11e04094511c793d529092e488c75de128;hp=3d79c7ae9dda3de574807bb9a3994865f25c03a3;hpb=5fd2ae6a4517980ce0f89247bb354220748ae67b;p=modeling%2Fetsicatalog.git diff --git a/catalog/pub/utils/jobutil.py b/catalog/pub/utils/jobutil.py index 3d79c7a..c2e1c15 100644 --- a/catalog/pub/utils/jobutil.py +++ b/catalog/pub/utils/jobutil.py @@ -13,12 +13,11 @@ # limitations under the License. import datetime import logging -import uuid import traceback +import uuid from functools import reduce from catalog.pub.database.models import JobStatusModel, JobModel -from catalog.pub.utils import idutil logger = logging.getLogger(__name__) @@ -30,8 +29,10 @@ def enum(**enums): JOB_STATUS = enum(PROCESSING=0, FINISH=1) JOB_MODEL_STATUS = enum(STARTED='started', PROCESSING='processing', FINISHED='finished', ERROR='error', TIMEOUT='timeout') -JOB_TYPE = enum(CREATE_VNF="create vnf", TERMINATE_VNF="terminate vnf", GRANT_VNF="grant vnf", MANUAL_SCALE_VNF="manual scale vnf", +JOB_TYPE = enum(CREATE_VNF="create vnf", TERMINATE_VNF="terminate vnf", GRANT_VNF="grant vnf", + MANUAL_SCALE_VNF="manual scale vnf", HEAL_VNF="heal vnf") +JOB_ERROR_CODE = enum(NORMAL=0, PACKAGE_EXIST=1, CATALOG_EXCEPTION=2, SYSTEM_ERROR=3) class JobUtil(object): @@ -96,7 +97,12 @@ class JobUtil(object): try: int_progress = int(progress) job_status = JobStatusModel() - job_status.indexid = int(idutil.get_auto_id(job_id)) + jobstatuslist = JobStatusModel.objects.filter(jobid=job_id) + indexid = 0 + for jobstatus in jobstatuslist: + if jobstatus.indexid > indexid: + indexid = jobstatus.indexid + job_status.indexid = indexid + 1 job_status.jobid = job_id job_status.status = "processing" job_status.progress = int_progress