Skip to content

Commit

Permalink
Allow retrieve execution log files from other paths
Browse files Browse the repository at this point in the history
  • Loading branch information
L2JE committed Oct 2, 2023
1 parent 4dd07dc commit f7f9e93
Show file tree
Hide file tree
Showing 2 changed files with 32 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -131,6 +131,10 @@ class AzureFileStoragePlugin implements ExecutionFileStoragePlugin, ExecutionMul
container.createIfNotExists()
}

protected static boolean isImportedExecution(Map<String, ?> context){
return context != null && context.get("isRemoteFilePath") != null && context.get("isRemoteFilePath") == "true"
}

@Override
boolean isAvailable(String filetype) throws ExecutionFileStorageException {
try {
Expand Down Expand Up @@ -225,7 +229,10 @@ class AzureFileStoragePlugin implements ExecutionFileStoragePlugin, ExecutionMul
*/
static String expandPath(String pathFormat, Map<String, ?> context) {
String result = pathFormat.replaceAll("^/+", "");
if (null != context) {

if(isImportedExecution(context))
result = String.valueOf(context.get("outputfilepath").toString())
else if (null != context) {
result = DataContextUtils.replaceDataReferences(
result,
DataContextUtils.addContext("job", stringMap(context), new HashMap<>()),
Expand All @@ -252,12 +259,16 @@ class AzureFileStoragePlugin implements ExecutionFileStoragePlugin, ExecutionMul
}

String getFileName(String fileType){
String executionId=context.get(META_EXECID)
String project=context.get(META_PROJECT)

String fileName="${project}/${executionId}.${fileType}"
String fileName
if(isImportedExecution(this.context))
fileName = expandedPath.substring(expandedPath.indexOf("/"), expandedPath.length()).toLowerCase()
else{
String executionId=context.get(META_EXECID)
String project=context.get(META_PROJECT)
fileName = "${project}/${executionId}"
}

return fileName
return fileName + ".${fileType}"
}


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,21 @@ class AzureFileStoragePluginSpec extends Specification{
thrown IllegalArgumentException
}

def "return true if it was initialized with an imported execution"(){
when:
boolean isImportedExecution = AzureFileStoragePlugin.isImportedExecution(context)

then:
isImportedExecution == expected

where:
context | expected
['isRemoteFilePath': 'asd'] | false
['isRemoteFilePath': 'true'] | true
[:] | false
null | false
}


private HashMap<String, Object> testContext() {
HashMap<String, Object> stringHashMap = new HashMap<String, Object>();
Expand Down

0 comments on commit f7f9e93

Please sign in to comment.