|
|
|
@ -79,18 +79,18 @@
|
|
|
|
|
},
|
|
|
|
|
{
|
|
|
|
|
"name": "LAMBDA_TASK",
|
|
|
|
|
"taskReferenceName": "build_add_vre_folder_admins_tasks",
|
|
|
|
|
"taskReferenceName": "build_add_vre_folder_users_tasks",
|
|
|
|
|
"type": "LAMBDA",
|
|
|
|
|
"inputParameters": {
|
|
|
|
|
"admins" : "${workflow.input.folder_admins}",
|
|
|
|
|
"url": "${init.input.storagehub}/groups/${init.output.result.shubified_context_name}/admins",
|
|
|
|
|
"scriptExpression": "inputs={},tasks=[];for(var i=0;i<$.admins.length;i++)a=$.admins[i],tasks.push({name:'pyrest',type:'SIMPLE',taskReferenceName:'t_'+i}),inputs['t_'+i]={url:$.url,body:{userid:a},method:'POST',headers:{Authorization:'Bearer ${authorize_with_uma_rpt.output.body.access_token}', Accept: 'text/plain'}};return {tasks:Java.to(tasks,'java.util.Map[]'),inputs:inputs};"
|
|
|
|
|
"url": "${init.input.storagehub}/groups/${init.output.result.shubified_context_name}/users",
|
|
|
|
|
"scriptExpression": "inputs={},tasks=[];for(var i=0;i<$.admins.length;i++)a=$.admins[i],tasks.push({name:'pyrest',type:'SIMPLE',taskReferenceName:'tu_'+i}),inputs['tu_'+i]={url:$.url,body:{userId:a},method:'PUT',headers:{Authorization:'Bearer ${authorize_with_uma_rpt.output.body.access_token}', Accept: 'text/plain'}};return {tasks:Java.to(tasks,'java.util.Map[]'),inputs:inputs};"
|
|
|
|
|
}
|
|
|
|
|
},
|
|
|
|
|
{
|
|
|
|
|
"name" : "fork_dynamic",
|
|
|
|
|
"type" : "FORK_JOIN_DYNAMIC",
|
|
|
|
|
"taskReferenceName" : "parallel_add_vre_folder_admins",
|
|
|
|
|
"taskReferenceName" : "parallel_add_vre_folder_users",
|
|
|
|
|
"inputParameters" : {
|
|
|
|
|
"tasks" : "${build_add_vre_folder_admins_tasks.output.result.tasks}",
|
|
|
|
|
"inputs" : "${build_add_vre_folder_admins_tasks.output.result.inputs}"
|
|
|
|
@ -101,37 +101,33 @@
|
|
|
|
|
{
|
|
|
|
|
"name" : "join",
|
|
|
|
|
"type" : "JOIN",
|
|
|
|
|
"taskReferenceName" : "join_parallel_add_vre_folder_admins"
|
|
|
|
|
"taskReferenceName" : "join_parallel_add_vre_folder_users"
|
|
|
|
|
},
|
|
|
|
|
{
|
|
|
|
|
"name": "pyrest",
|
|
|
|
|
"taskReferenceName": "add_vre_folder_admins",
|
|
|
|
|
"name": "LAMBDA_TASK",
|
|
|
|
|
"taskReferenceName": "build_add_vre_folder_admins_tasks",
|
|
|
|
|
"type": "LAMBDA",
|
|
|
|
|
"inputParameters": {
|
|
|
|
|
"admins" : "${workflow.input.folder_admins}",
|
|
|
|
|
"url": "${init.input.storagehub}/groups/${init.output.result.shubified_context_name}/admins",
|
|
|
|
|
"method": "PUT",
|
|
|
|
|
"headers": {
|
|
|
|
|
"Authorization": "Bearer ${authorize_with_uma_rpt.output.body.access_token}",
|
|
|
|
|
"Accept": "text/plain"
|
|
|
|
|
},
|
|
|
|
|
"body": {
|
|
|
|
|
"accessType": [
|
|
|
|
|
"WRITE_OWNER",
|
|
|
|
|
"application/json"
|
|
|
|
|
],
|
|
|
|
|
"group": "${init.output.result.shubified_context_name}",
|
|
|
|
|
"folderOwner": "${workflow.input.folder_owner}"
|
|
|
|
|
}
|
|
|
|
|
"scriptExpression": "inputs={},tasks=[];for(var i=0;i<$.admins.length;i++)a=$.admins[i],tasks.push({name:'pyrest',type:'SIMPLE',taskReferenceName:'ta_'+i}),inputs['ta_'+i]={url:$.url,body:{userId:a},method:'PUT',headers:{Authorization:'Bearer ${authorize_with_uma_rpt.output.body.access_token}', Accept: 'text/plain'}};return {tasks:Java.to(tasks,'java.util.Map[]'),inputs:inputs};"
|
|
|
|
|
}
|
|
|
|
|
},
|
|
|
|
|
{
|
|
|
|
|
"name" : "fork_dynamic",
|
|
|
|
|
"type" : "FORK_JOIN_DYNAMIC",
|
|
|
|
|
"taskReferenceName" : "parallel_add_vre_folder_admins",
|
|
|
|
|
"inputParameters" : {
|
|
|
|
|
"tasks" : "${build_add_vre_folder_admins_tasks.output.result.tasks}",
|
|
|
|
|
"inputs" : "${build_add_vre_folder_admins_tasks.output.result.inputs}"
|
|
|
|
|
},
|
|
|
|
|
"type": "SIMPLE",
|
|
|
|
|
"decisionCases": {},
|
|
|
|
|
"defaultCase": [],
|
|
|
|
|
"forkTasks": [],
|
|
|
|
|
"startDelay": 0,
|
|
|
|
|
"joinOn": [],
|
|
|
|
|
"optional": false,
|
|
|
|
|
"defaultExclusiveJoinTask": [],
|
|
|
|
|
"asyncComplete": false,
|
|
|
|
|
"loopOver": []
|
|
|
|
|
"dynamicForkTasksParam": "tasks",
|
|
|
|
|
"dynamicForkTasksInputParamName": "inputs"
|
|
|
|
|
},
|
|
|
|
|
{
|
|
|
|
|
"name" : "join",
|
|
|
|
|
"type" : "JOIN",
|
|
|
|
|
"taskReferenceName" : "join_parallel_add_vre_folder_admins"
|
|
|
|
|
}
|
|
|
|
|
],
|
|
|
|
|
"inputParameters": [
|
|
|
|
|