Interestingly, your block seems to work for me. I created a model similar to yours (also with delays) for a group of devices. I sent in a value of “200” for device 1 and then a value of “104” for device 2 before the delay occurred.
Input 1:
SyncInputs.process.Delay>>>$input_value1>>apama.analyticsbuilder.Value(any(float,200),1690542329.166,{"fragment":any(string,"input"),"id":any(string,"67950065"),"measurement_creationTime":any(float,1690542330.429),"measurement_source.name":any(),"measurement_source.type":any(string,"com_cumulocity_model_idtype_GId"),"measurement_source.value":any(string,"9266897646"),"measurement_tenantId":any(string,"t21106993"),"series":any(string,"i"),"source":any(string,"9266897646"),"time":any(float,1690542329.166),"type":any(string,"input"),"unit":any(string,""),"value":any(float,200)})>>>$input_value2>>apama.analyticsbuilder.Value(any(),0,{})>>>$input_value3>>apama.analyticsbuilder.Value(any(),0,{})
Input 2:
SyncInputs.process.Delay>>>$input_value1>>apama.analyticsbuilder.Value(any(float,104),1690542331.695,{"fragment":any(string,"input"),"id":any(string,"67933927"),"measurement_creationTime":any(float,1690542332.559),"measurement_source.name":any(),"measurement_source.type":any(string,"com_cumulocity_model_idtype_GId"),"measurement_source.value":any(string,"2318011"),"measurement_tenantId":any(string,"t21106993"),"series":any(string,"i"),"source":any(string,"2318011"),"time":any(float,1690542331.695),"type":any(string,"input"),"unit":any(string,""),"value":any(float,104)})>>>$input_value2>>apama.analyticsbuilder.Value(any(),0,{})>>>$input_value3>>apama.analyticsbuilder.Value(any(),0,{})
Output 1:
SyncInputs.process.Delay>>>$input_value1>>apama.analyticsbuilder.Value(any(float,200),1690542329.166,{"fragment":any(string,"input"),"id":any(string,"67950065"),"measurement_creationTime":any(float,1690542330.429),"measurement_source.name":any(),"measurement_source.type":any(string,"com_cumulocity_model_idtype_GId"),"measurement_source.value":any(string,"9266897646"),"measurement_tenantId":any(string,"t21106993"),"series":any(string,"i"),"source":any(string,"9266897646"),"time":any(float,1690542329.166),"type":any(string,"input"),"unit":any(string,""),"value":any(float,200)})>>>$input_value2>>apama.analyticsbuilder.Value(any(float,200),1690542339.166,{})>>>$input_value3>>apama.analyticsbuilder.Value(any(float,200),1690542344.166,{})
SyncInputs.process.Delay>>>$input_value1.timestamp>>1690542329.166/1690542329.166>>>$input_value2.timestamp>>1690542339.166/1690542339.166>>>$input_value3.timestamp>>1690542344.166/0
SyncInputs.process.Delay>>>$blockState.buffer1>>[200]>>>$blockState.buffer2>>[200]>>>$blockState.buffer3>>[]
SyncInputs.process.Delay>>>v1active>>false>>>v2active>>false>>>v3active>>true
SyncInputs.processSync.Delay>>>$input_value1>>200>>>$input_value2>>200>>>$input_value3>>200
SyncInputs.processSync.Delay>>>sum>>600
Output 2:
SyncInputs.process.Delay>>>$input_value1>>apama.analyticsbuilder.Value(any(float,104),1690542331.695,{"fragment":any(string,"input"),"id":any(string,"67933927"),"measurement_creationTime":any(float,1690542332.559),"measurement_source.name":any(),"measurement_source.type":any(string,"com_cumulocity_model_idtype_GId"),"measurement_source.value":any(string,"2318011"),"measurement_tenantId":any(string,"t21106993"),"series":any(string,"i"),"source":any(string,"2318011"),"time":any(float,1690542331.695),"type":any(string,"input"),"unit":any(string,""),"value":any(float,104)})>>>$input_value2>>apama.analyticsbuilder.Value(any(float,104),1690542341.695,{})>>>$input_value3>>apama.analyticsbuilder.Value(any(float,104),1690542346.695,{})
SyncInputs.process.Delay>>>$input_value1.timestamp>>1690542331.695/1690542331.695>>>$input_value2.timestamp>>1690542341.695/1690542341.695>>>$input_value3.timestamp>>1690542346.695/0
SyncInputs.process.Delay>>>$blockState.buffer1>>[104]>>>$blockState.buffer2>>[104]>>>$blockState.buffer3>>[]
SyncInputs.process.Delay>>>v1active>>false>>>v2active>>false>>>v3active>>true
SyncInputs.processSync.Delay>>>$input_value1>>104>>>$input_value2>>104>>>$input_value3>>104
SyncInputs.processSync.Delay>>>sum>>312