def METHOD_NAME(registry_url: str, registry_container_name: str, images: str):
    images = images.split(",")
    loop = asyncio.get_event_loop()
    try:
        click.echo("Removing images from datanode docker")
        _remove_image_from_datanode_docker()
    except Exception as exc:
        click.echo(
            f"Unable to remove images from datanode docker: {exc}, continuing anyway"
        )
    try:
        click.echo("Removing dangling images from datanode docker")
        _remove_dangling_images_from_datanode_docker()
    except Exception as exc:
        click.echo(
            f"Unable to remove dangling images from datanode docker: {exc}, continuing anyway"
        )
    try:
        _run_registry_garbage_collection(registry_container_name)
    except Exception as exc:
        click.echo(f"Unable to run garbage collection: {exc}, continuing anyway")
    # to make sure everything is up-to-date in the registry cache
    click.echo("Restarting datanode docker registry and sleeping for 30 seconds")
    _restart_docker_registry(registry_container_name)
    # give the registry some time to start
    time.sleep(30)
    tags = loop.run_until_complete(_collect_image_tags(registry_url, images))
    loop.run_until_complete(_delete_image_tags(registry_url, tags))
    click.echo("Removed all tags. Running garbage collection...")
    _run_registry_garbage_collection(registry_container_name)
    click.echo("Restarting datanode docker registry...")
    _restart_docker_registry(registry_container_name)
    click.echo("Cleaning images from local Docker cache...")
    _clean_images_from_local_docker_cache(tags)