Setting concurrent tasks per job 20
@@ -97,8 +97,10 @@ public class WorkflowOperator {
.addTaskConfigs(taskBuilds)
.setFailureThreshold(0)
.setExpiry(WORKFLOW_EXPIRY_TIME)
+ .setNumConcurrentTasksPerInstance(20)
.setMaxAttemptsPerTask(data.getRetryCount());
+
if (!globalParticipant) {
job.setInstanceGroupTag(taskType);
}
