checkpoint wip
dry_run param
fix dry_run
pubsub yo