def METHOD_NAME():
    client = DagsterGrpcClient(port=8080)
    shutdown_event, watch_thread = create_grpc_watch_thread("test_location", client)
    watch_thread.start()
    shutdown_event.set()
    watch_thread.join()