def METHOD_NAME():
    """Remove image from datanode docker"""
    formatted_docker_images = subprocess.Popen(
        ["docker", "images", "--format", "'{{.Repository }}:{{.Tag}}'"],
        stdout=subprocess.PIPE,
    )
    grep = subprocess.Popen(
        ["grep", "mlrun"],
        stdin=formatted_docker_images.stdout,
        stdout=subprocess.PIPE,
    )
    subprocess.run(
        ["xargs", "--no-run-if-empty", "docker", "rmi", "-f"],
        stdin=grep.stdout,
    )
    formatted_docker_images.stdout.close()
    grep.stdout.close()