storage layer        \
notifications           < - > task i/o
persistence layer /

Recommended way to provide flow inputs: store parameter.