def METHOD_NAME(conn, addr):
    rcs = []
    with conn:
        print('Connected by', addr)
        dfs_configs_paths = {}
        while True:
            data = recv_msg(conn)
            if not data:
                break
            print("got new request")
            request = decode_request(data)
            if request['type'] == 'Exec-Graph':
                graph, shell_vars, functions = parse_exec_graph(request)
                save_configs(graph, dfs_configs_paths)
                exec_graph(graph, shell_vars, functions)
                body = {}
            else:
                print(f"Unsupported request {request}")
            send_success(conn, body)
    print("connection ended")
    for rc in rcs:
        rc.wait()