def METHOD_NAME(cluster):
    """
    Start replication and wait until replication completes.
    """
    print(f"Creating replication source in cluster '{cluster}'")
    kubectl.apply("--filename", "source/replication-src.yaml", context=cluster)
    print(f"Waiting until replication source reports sync status in '{cluster}'")
    drenv.wait_for(
        "replicationsource/busybox-src",
        output="jsonpath={.status.lastManualSync}",
        namespace=NAMESPACE,
        timeout=120,
        profile=cluster,
    )
    print(f"Waiting until replication is completed in cluster '{cluster}'")
    kubectl.wait(
        "replicationsource/busybox-src",
        "--for=jsonpath={.status.lastManualSync}=replication-1",
        f"--namespace={NAMESPACE}",
        "--timeout=120s",
        context=cluster,
    )
    out = kubectl.get(
        "replicationsource/busybox-src",
        "--output=jsonpath={.status}",
        f"--namespace={NAMESPACE}",
        context=cluster,
    )
    status = json.loads(out)
    print("Replication status:")
    print(json.dumps(status, indent=2))