support lebesgue v2 api (group id and machine_type)

Author: KZHIWEI

dpdispatcher/dp_cloud_server.py

@@ -56,7 +56,7 @@ def do_submit(self, job):
             )
             if self.grouped:
                 self.group_id = group_id
-            job.job_id = str(job_id) + ':job_group_id' + str(group_id)
+            job.job_id = str(job_id) + ':job_group_id:' + str(group_id)
             job_id = job.job_id
         else:
             job_id = api.job_create(
@@ -73,11 +73,11 @@ def check_status(self, job):
             return JobStatus.unsubmitted
         job_id = job.job_id
         group_id = None
-        if isinstance(job.job_id,str) and ':job_group_id' in job.job_id:
+        if isinstance(job.job_id, str) and ':job_group_id:' in job.job_id:
             group_id = None
-            ids = job.job_id.split(":job_group_id")
+            ids = job.job_id.split(":job_group_id:")
             job_id, group_id = int(ids[0]), int(ids[1])
-            if self.input_data.get('grouped') and 'job_group_id' not in self.input_data:
+            if self.input_data.get('grouped') and ':job_group_id:' not in self.input_data:
                 self.group_id = group_id
             self.api_version = 2
         dlog.debug(f"debug: check_status; job.job_id:{job_id}; job.job_hash:{job.job_hash}")