A system and a method are disclosed for implementing distributed processing in edge nodes. In an embodiment, a respective edge node receives data from a client of the respective edge node. The respective edge node generates a prediction of a respective activity based on the data, and determines whether the prediction is valid by feeding the prediction into a validator module and receiving a validation response from the validator module. The respective edge node, in response to determining that the prediction is valid, activates a function.