public class ForkedTaskVariablesManager extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
static String |
CREDENTIALS_KEY_PREFIX
Will be replaced by the matching third-party credential
Example: if one of the third-party credentials' key-value pairs is 'foo:bar',
then '$credentials_foo' will be replaced by 'bar' in the arguments of the tasks.
|
Constructor and Description |
---|
ForkedTaskVariablesManager() |
Modifier and Type | Method and Description |
---|---|
void |
addBindingsToScriptHandler(ScriptHandler scriptHandler,
TaskContext taskContext,
VariablesMap variables,
Map<String,Serializable> resultMap,
Map<String,String> thirdPartyCredentials,
SchedulerNodeClient client,
RemoteSpace userSpaceClient,
RemoteSpace globalSpaceClient,
Map<String,String> resultMetadata) |
RemoteSpace |
createDataSpaceNodeClient(TaskContext container,
SchedulerNodeClient schedulerNodeClient,
IDataSpaceClient.Dataspace space) |
SchedulerNodeClient |
createSchedulerNodeClient(TaskContext container) |
Map<String,String> |
extractThirdPartyCredentials(TaskContext container) |
void |
replaceScriptParameters(Script<?> script,
Map<String,String> thirdPartyCredentials,
VariablesMap variables,
PrintStream errorStream) |
public static final String CREDENTIALS_KEY_PREFIX
public void addBindingsToScriptHandler(ScriptHandler scriptHandler, TaskContext taskContext, VariablesMap variables, Map<String,Serializable> resultMap, Map<String,String> thirdPartyCredentials, SchedulerNodeClient client, RemoteSpace userSpaceClient, RemoteSpace globalSpaceClient, Map<String,String> resultMetadata)
public Map<String,String> extractThirdPartyCredentials(TaskContext container) throws Exception
Exception
public SchedulerNodeClient createSchedulerNodeClient(TaskContext container)
public RemoteSpace createDataSpaceNodeClient(TaskContext container, SchedulerNodeClient schedulerNodeClient, IDataSpaceClient.Dataspace space)
public void replaceScriptParameters(Script<?> script, Map<String,String> thirdPartyCredentials, VariablesMap variables, PrintStream errorStream)