public void copyOutPutFilesToBucket ( SubProcessConfiguration configuration , String params ) { if ( Files . exists ( outFile ) || Files . exists ( errFile ) ) { try { outFileLocation = FileUtils . copyFileFromWorkerToGCS ( configuration , outFile ) ; } catch ( Exception ex ) { LOG . error ( "Error uploading log file to storage " , ex ) ; } try { errFileLocation = FileUtils . copyFileFromWorkerToGCS ( configuration , errFile ) ; } catch ( Exception ex ) { LOG . error ( "Error uploading log file to storage " , ex ) ; } LOG . info ( String . format ( "Log Files for process: %s outFile was: %s errFile was: %s" , params , outFileLocation , errFileLocation ) ) ; } else { LOG . error ( String . format ( "There was no output file or err file for process %s" , params ) ) ; } }
Will copy the output files to the GCS path setup via the configuration .