File tree Expand file tree Collapse file tree 2 files changed +12
-10
lines changed Expand file tree Collapse file tree 2 files changed +12
-10
lines changed Original file line number Diff line number Diff line change @@ -275,11 +275,11 @@ class K8sTaskHandler extends TaskHandler implements FusionAwareTask {
275
275
final resLabels = task. config. getResourceLabels()
276
276
if ( resLabels )
277
277
resLabels. putAll(resLabels)
278
- result. app = ' nextflow'
279
- result. runName = getRunName()
280
- result. taskName = task. getName()
281
- result. processName = task. getProcessor(). getName()
282
- result. sessionId = " uuid-${ executor.getSession().uniqueId} " as String
278
+ result. ' nextflow.io/ app' = ' nextflow'
279
+ result. ' nextflow.io/ runName' = getRunName()
280
+ result. ' nextflow.io/ taskName' = task. getName()
281
+ result. ' nextflow.io/ processName' = task. getProcessor(). getName()
282
+ result. ' nextflow.io/ sessionId' = " uuid-${ executor.getSession().uniqueId} " as String
283
283
return result
284
284
}
285
285
Original file line number Diff line number Diff line change @@ -806,11 +806,13 @@ class K8sTaskHandlerTest extends Specification {
806
806
807
807
labels. app == ' nextflow'
808
808
labels. foo == ' bar'
809
- labels. x == ' hello_world'
810
- labels. processName == ' hello-proc'
811
- labels. taskName == ' hello-world-1'
812
- labels. sessionId instanceof String
813
- labels. sessionId == " uuid-${ uuid.toString()} " . toString()
809
+ labels. x == ' hello_world'
810
+ and :
811
+ labels. ' nextflow.io/app' == ' nextflow'
812
+ labels. ' nextflow.io/processName' == ' hello-proc'
813
+ labels. ' nextflow.io/taskName' == ' hello-world-1'
814
+ labels. ' nextflow.io/sessionId' instanceof String
815
+ labels. ' nextflow.io/sessionId' == " uuid-${ uuid.toString()} " . toString()
814
816
}
815
817
816
818
def ' should delete pod if complete' () {
You can’t perform that action at this time.
0 commit comments