@@ -203,11 +203,11 @@ class LinObserver implements TraceObserver {
203
203
return key
204
204
}
205
205
206
- private List<Parameter > getNormalizedTaskOutputs ( TaskRun task , PathNormalizer normalizer ){
206
+ private List<Parameter > getNormalizedTaskOutputs (TaskRun task , PathNormalizer normalizer ){
207
207
final outputs = task. getOutputs()
208
208
final outputParams = new LinkedList<Parameter > ()
209
- outputs . forEach { OutParam key , Object value ->
210
- manageTaskOutputParameter(key, outputParams, value, task, normalizer)
209
+ for ( Map.Entry < OutParam , Object > entry : outputs ) {
210
+ manageTaskOutputParameter(entry . key, outputParams, entry . value, task, normalizer)
211
211
}
212
212
return outputParams
213
213
}
@@ -231,7 +231,8 @@ class LinObserver implements TraceObserver {
231
231
232
232
private Object manageFileOutParam (Object value , TaskRun task ) {
233
233
if (value == null ) {
234
- throw new IllegalArgumentException (" Unexpected output null for task '${ task.name} '" )
234
+ log. debug " Unexpected lineage File output value null"
235
+ return null
235
236
}
236
237
if (value instanceof Path ) {
237
238
return asUriString(storeTaskOutput(task, (Path ) value))
@@ -407,9 +408,11 @@ class LinObserver implements TraceObserver {
407
408
return Collection . simpleName
408
409
if ( param instanceof Map )
409
410
return Map . simpleName
410
- return param!= null
411
- ? param. class. simpleName
412
- : null
411
+ if ( param== null ) {
412
+ log. debug " Unexpected lineage param type null"
413
+ return null
414
+ }
415
+ return param. class. simpleName
413
416
}
414
417
415
418
private Object convertPathsToLidReferences (Object value ){
0 commit comments