pass along connection in datum to facilitate retry/reset
simplify idempotent/retry logic