Fix job op to use run id as job name

Makefile

@@ -13,7 +13,7 @@ endef
 export PRINT_HELP_PYSCRIPT
 
 
-VERSION=2.3
+VERSION=2.2.0.1
 help:
 	@python -c "$$PRINT_HELP_PYSCRIPT" < $(MAKEFILE_LIST)
 

dkube/pipelines/components/op.py

@@ -14,7 +14,7 @@ def __init__(self, name, authtoken, stage, args=[]):
             stage in VALID_STAGES
         ), "stage must be one of training/preprocessing/serving/storage/submit"
 
-        kwargs = {"name": name, "image": "ocdr/dkube_pylauncher:2.2"}
+        kwargs = {"name": name, "image": "ocdr/dkube_pylauncher:2.2.0.1"}
         kwargs["command"] = ["python3", "-u", "/dkubepl/main.py", name, authtoken]
         kwargs["command"].extend(["{{workflow.uid}}", "{{pod.name}}", stage])
         kwargs["arguments"] = args

dkube/sdk/rsrcs/util.py

@@ -1,7 +1,17 @@
 import string
 import random
+from datetime import datetime
 
-generate = lambda hint: "{}-{}".format(hint, ''.join([random.choice(string.digits) for n in range(4)]))
+def generate(prefix):
+    random.seed(datetime.now())
+    # truncate length of the prefix to 12 characters
+    prefix = prefix[:12]
+    #Total length = 16 characters
+    N = 16
+    #length of random characters to be generated
+    random_len = N - len(prefix) - 1
+    return "{}-{}".format(prefix, ''.join([random.choice(string.ascii_uppercase + string.ascii_lowercase +
+                             string.digits) for n in range(random_len)]))
 
 def list_of_strs(x):
     if x != None:

launcher/src/job.py

@@ -76,7 +76,7 @@ def job(
     tags,
     output,
 ):
-    name = generate(obj["name"])
+    name = obj["runid"]
     tags = json.loads(tags)
     tags.extend(
         [