diff --git a/data-computer/v1/lda-segment.ini b/data-computer/v1/lda-segment.ini index f877e6b..df61c1f 100644 --- a/data-computer/v1/lda-segment.ini +++ b/data-computer/v1/lda-segment.ini @@ -54,6 +54,11 @@ [fork/exchange] value = get('value.topics').map((o, i) => _.zip(o.words, o.words_weights).map(x=>x.concat(i).concat(o.topic_weight))).flatten().map(y=> ({source: y[0], target: y[2], weight: y[1], origin: self.id})) [fork/ungroup] +[fork/identify] +path = uuid +scheme = sha +[fork/dedupe] +path = uuid # Step 2.2 (générique): Enregister le résulat et signaler que le traitment est fini [fork/delegate]