diff options
| author |   hongyuzhao <zhao.hongyu@zte.com.cn> | 2020-02-03 17:35:20 +0800 |
|---|---|---|
| committer | hongyuzhao <zhao.hongyu@zte.com.cn> | 2020-02-03 17:39:21 +0800 |
| commit | 3d10bac5ec6b5394d32dc6ad3b0a7e6294ea6593 (patch) | |
| tree | ec149d69144ad48dcca5907c263fe26aac049194 /catalog/pub | |
| parent | a40cb469e3aa364fb2a0f016632bc642b4ecbdb7 (diff) | |
Remove use of redis db
Change-Id: I714c9f36ef9d6710bf8e3e21c023435d6fcc2a0a
Issue-ID: MODELING-307
Signed-off-by: hongyuzhao <zhao.hongyu@zte.com.cn>
Diffstat (limited to 'catalog/pub')
| -rw-r--r-- | catalog/pub/utils/jobutil.py | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/catalog/pub/utils/jobutil.py b/catalog/pub/utils/jobutil.py index 3d79c7a..5c35350 100644 --- a/catalog/pub/utils/jobutil.py +++ b/catalog/pub/utils/jobutil.py @@ -18,7 +18,6 @@ import traceback from functools import reduce from catalog.pub.database.models import JobStatusModel, JobModel -from catalog.pub.utils import idutil logger = logging.getLogger(__name__) @@ -96,7 +95,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 |