def find_sink_bucket_name(opts, source_bucket):
    sink_bucket = getattr(opts, "bucket_destination", None) or source_bucket
    if not sink_bucket:
        return "error: please specify a bucket_destination", None
    logging.debug("sink_bucket: " + sink_bucket)
    return 0, sink_bucket
Default bucket_destination to the same as bucket_source.
dataset/ETHPy150Open membase/membase-cli/pump.py/find_sink_bucket_name