Idea: 1) When a record is written 2) Trigger a follow on task on write Specifically with this change https://github.com/nodestream-proj/nodestream/pull/435