queue/flow purge. redis case still failing
each Module.process needs to signal done via callback