def METHOD_NAME(self, *args, **options):
    dry_run = "dry_run" in options and options["dry_run"]
    ssl = "ssl" in options and options["ssl"]
    batch_size = options["batch_size"]
    source = options["source_connection"]
    source_connection = connections[source]
    target = options["target_connection"]
    target_connection = connections[target]
    copy_tables(
        batch_size,
        dry_run,
        ssl,
        source_connection,
        target_connection,
        self.stdout.write,
        run,
    )