diff --git a/webui/.eslintrc.json b/webui/.eslintrc.json
deleted file mode 100644
index ce13b20e9..000000000
--- a/webui/.eslintrc.json
+++ /dev/null
@@ -1,16 +0,0 @@
-{
- "extends": ["eslint:recommended", "google"],
- "env": {
- "browser": true
- },
- "plugins": [
- "html"
- ],
- "rules": {
- "no-var": "off",
- "new-cap": ["error", { "capIsNewExceptions": ["Polymer"] }]
- },
- "globals": {
- "Polymer": true
- }
-}
diff --git a/webui/.gitattributes b/webui/.gitattributes
deleted file mode 100644
index 212566614..000000000
--- a/webui/.gitattributes
+++ /dev/null
@@ -1 +0,0 @@
-* text=auto
\ No newline at end of file
diff --git a/webui/.github/ISSUE_TEMPLATE.md b/webui/.github/ISSUE_TEMPLATE.md
deleted file mode 100644
index 38f6726f6..000000000
--- a/webui/.github/ISSUE_TEMPLATE.md
+++ /dev/null
@@ -1,33 +0,0 @@
-
-### Description
-
-
-### Expected outcome
-
-
-
-### Actual outcome
-
-
-
-### Live Demo
-
-
-### Steps to reproduce
-
-
-
-### Browsers Affected
-
-- [ ] Chrome
-- [ ] Firefox
-- [ ] Safari 9
-- [ ] Safari 8
-- [ ] Safari 7
-- [ ] Edge
-- [ ] IE 11
-- [ ] IE 10
diff --git a/webui/.gitignore b/webui/.gitignore
deleted file mode 100644
index 77e759d2c..000000000
--- a/webui/.gitignore
+++ /dev/null
@@ -1,3 +0,0 @@
-bower_components/
-build/
-node_modules/
diff --git a/webui/.travis.yml b/webui/.travis.yml
deleted file mode 100644
index 280e8ec22..000000000
--- a/webui/.travis.yml
+++ /dev/null
@@ -1,19 +0,0 @@
-language: node_js
-sudo: required
-dist: trusty
-addons:
- firefox: latest
- apt:
- sources:
- - google-chrome
- packages:
- - google-chrome-stable
-node_js:
- - '6'
- - '5'
- - '4'
-before_script:
- - npm install -g bower polymer-cli
- - bower install
-script:
- - xvfb-run npm test
diff --git a/webui/README.md b/webui/README.md
deleted file mode 100644
index e76880d4b..000000000
--- a/webui/README.md
+++ /dev/null
@@ -1,85 +0,0 @@
-# The Ray Web UI
-
-This is Ray's Web UI. It consists of two components:
-
-* The **frontend** is a [Polymer](https://www.polymer-project.org/1.0/) app that
- uses [D3](https://d3js.org/) for visualization.
-* The **backend** is a Python 3 websocket server (see `backend/ray_ui.py`) that
- connects to Redis and potentially Ray.
-
-### Prerequisites
-
-The Ray Web UI requires Python 3.
-
-Install [polymer-cli](https://github.com/Polymer/polymer-cli):
-
- pip install aioredis websockets
- npm install -g polymer-cli
-
-### Setup
-
-The following must be done once.
-
- cd webui
- bower install
-
-### Start the backend
-
-First start Ray and note down the address of the Redis server. Then run
-
- cd webui/backend
- python ray_ui.py --redis-address 127.0.0.1:6379
-
-where you substitute your Redis address appropriately.
-
-### Start the frontend development server
-
-To start the front end, run the following.
-
- cd webui
- polymer serve --open
-
-The web UI can then be accessed at `http://localhost:8080`.
-
-### Build
-
-This command performs HTML, CSS, and JS minification on the application
-dependencies, and generates a service-worker.js file with code to pre-cache the
-dependencies based on the entrypoint and fragments specified in `polymer.json`.
-The minified files are output to the `build/unbundled` folder, and are suitable
-for serving from a HTTP/2+Push compatible server.
-
-In addition the command also creates a fallback `build/bundled` folder,
-generated using fragment bundling, suitable for serving from non
-H2/push-compatible servers or to clients that do not support H2/Push.
-
- polymer build
-
-### Preview the build
-
-This command serves the minified version of the app at `http://localhost:8080`
-in an unbundled state, as it would be served by a push-compatible server:
-
- polymer serve build/unbundled
-
-This command serves the minified version of the app at `http://localhost:8080`
-generated using fragment bundling:
-
- polymer serve build/bundled
-
-### Run tests
-
-This command will run
-[Web Component Tester](https://github.com/Polymer/web-component-tester) against
-the browsers currently installed on your machine.
-
- polymer test
-
-### Adding a new view
-
-You can extend the app by adding more views that will be demand-loaded e.g.
-based on the route, or to progressively render non-critical sections of the
-application. Each new demand-loaded fragment should be added to the list of
-`fragments` in the included `polymer.json` file. This will ensure those
-components and their dependencies are added to the list of pre-cached components
-(and will have bundles created in the fallback `bundled` build).
diff --git a/webui/backend/ray_ui.py b/webui/backend/ray_ui.py
deleted file mode 100644
index ba62b8577..000000000
--- a/webui/backend/ray_ui.py
+++ /dev/null
@@ -1,460 +0,0 @@
-import aioredis
-import argparse
-import asyncio
-import binascii
-import collections
-import datetime
-import json
-import numpy as np
-import time
-import websockets
-
-# Import flatbuffer bindings.
-from ray.core.generated.LocalSchedulerInfoMessage import \
- LocalSchedulerInfoMessage
-
-parser = argparse.ArgumentParser(
- description="parse information for the web ui")
-parser.add_argument("--redis-address", required=True, type=str,
- help="the address to use for redis")
-
-loop = asyncio.get_event_loop()
-
-IDENTIFIER_LENGTH = 20
-
-# This prefix must match the value defined in ray_redis_module.cc.
-DB_CLIENT_PREFIX = b"CL:"
-
-
-def hex_identifier(identifier):
- return binascii.hexlify(identifier).decode()
-
-
-def identifier(hex_identifier):
- return binascii.unhexlify(hex_identifier)
-
-
-def key_to_hex_identifier(key):
- return hex_identifier(
- key[(key.index(b":") + 1):(key.index(b":") + IDENTIFIER_LENGTH + 1)])
-
-
-def timestamp_to_date_string(timestamp):
- """Convert a time stamp returned by time.time() to a formatted string."""
- return (datetime.datetime.fromtimestamp(timestamp)
- .strftime("%Y/%m/%d %H:%M:%S"))
-
-
-def key_to_hex_identifiers(key):
- # Extract worker_id and task_id from key of the form
- # prefix:worker_id:task_id.
- offset = key.index(b":") + 1
- worker_id = hex_identifier(key[offset:(offset + IDENTIFIER_LENGTH)])
- offset += IDENTIFIER_LENGTH + 1
- task_id = hex_identifier(key[offset:(offset + IDENTIFIER_LENGTH)])
- return worker_id, task_id
-
-
-async def hgetall_as_dict(redis_conn, key):
- fields = await redis_conn.execute("hgetall", key)
- return {fields[2 * i]: fields[2 * i + 1] for i in range(len(fields) // 2)}
-
-
-# Cache information about the local schedulers.
-local_schedulers = {}
-errors = []
-
-
-def duration_to_string(duration):
- """Format a duration in seconds as a string.
-
- Args:
- duration (float): The duration in seconds.
-
- Return:
- A more human-readable version of the string (for example, "3.5 hours" or
- "93 milliseconds").
- """
- if duration > 3600 * 24:
- duration_str = "{0:0.1f} days".format(duration / (3600 * 24))
- elif duration > 3600:
- duration_str = "{0:0.1f} hours".format(duration / 3600)
- elif duration > 60:
- duration_str = "{0:0.1f} minutes".format(duration / 60)
- elif duration > 1:
- duration_str = "{0:0.1f} seconds".format(duration)
- elif duration > 0.001:
- duration_str = "{0:0.1f} milliseconds".format(duration * 1000)
- else:
- duration_str = "{} microseconds".format(int(duration * 1000000))
- return duration_str
-
-
-async def handle_get_statistics(websocket, redis_conn):
- cluster_start_time = float(await redis_conn.execute("get",
- "redis_start_time"))
- start_date = timestamp_to_date_string(cluster_start_time)
-
- uptime = duration_to_string(time.time() - cluster_start_time)
-
- client_keys = await redis_conn.execute("keys", "CL:*")
- clients = []
- for client_key in client_keys:
- client_fields = await hgetall_as_dict(redis_conn, client_key)
- clients.append(client_fields)
- ip_addresses = list(set([client[b"node_ip_address"].decode("ascii")
- for client in clients
- if client[b"client_type"] == b"local_scheduler"]))
- num_nodes = len(ip_addresses)
- reply = {"uptime": uptime,
- "start_date": start_date,
- "nodes": num_nodes,
- "addresses": ip_addresses}
- await websocket.send(json.dumps(reply))
-
-
-async def handle_get_drivers(websocket, redis_conn):
- keys = await redis_conn.execute("keys", "Drivers:*")
- drivers = []
- for key in keys:
- driver_fields = await hgetall_as_dict(redis_conn, key)
- driver_info = {
- "node ip address": driver_fields[b"node_ip_address"].decode("ascii"),
- "name": driver_fields[b"name"].decode("ascii")}
-
- driver_info["start time"] = timestamp_to_date_string(
- float(driver_fields[b"start_time"]))
-
- if b"end_time" in driver_fields:
- duration = (float(driver_fields[b"end_time"]) -
- float(driver_fields[b"start_time"]))
- else:
- duration = time.time() - float(driver_fields[b"start_time"])
- driver_info["duration"] = duration_to_string(duration)
-
- if b"exception" in driver_fields:
- driver_info["status"] = "FAILED"
- elif b"end_time" not in driver_fields:
- driver_info["status"] = "IN PROGRESS"
- else:
- driver_info["status"] = "SUCCESS"
-
- if b"exception" in driver_fields:
- driver_info["exception"] = driver_fields[b"exception"].decode("ascii")
-
- drivers.append(driver_info)
- # Sort the drivers by their start times.
- reply = sorted(drivers, key=(lambda driver: driver["start time"]))[::-1]
- await websocket.send(json.dumps(reply))
-
-
-async def listen_for_errors(redis_ip_address, redis_port):
- pubsub_conn = await aioredis.create_connection(
- (redis_ip_address, redis_port), loop=loop)
- data_conn = await aioredis.create_connection((redis_ip_address, redis_port),
- loop=loop)
-
- error_pattern = "__keyspace@0__:ErrorKeys"
- await pubsub_conn.execute_pubsub("psubscribe", error_pattern)
- channel = pubsub_conn.pubsub_patterns[error_pattern]
- print("Listening for error messages...")
- index = 0
- while (await channel.wait_message()):
- await channel.get()
- info = await data_conn.execute("lrange", "ErrorKeys", index, -1)
-
- for error_key in info:
- worker, task = key_to_hex_identifiers(error_key)
- # TODO(richard): Filter out workers so that only relevant task errors are
- # necessary.
- result = await data_conn.execute("hget", error_key, "message")
- result = result.decode("ascii")
- # TODO(richard): Maybe also get rid of the coloring.
- errors.append({"driver_id": worker,
- "task_id": task,
- "error": result})
- index += 1
-
-
-async def handle_get_errors(websocket):
- """Send error messages to the frontend."""
- await websocket.send(json.dumps(errors))
-
-node_info = collections.OrderedDict()
-worker_info = collections.OrderedDict()
-
-
-async def handle_get_recent_tasks(websocket, redis_conn, num_tasks):
- # First update the cache of worker information.
- worker_keys = await redis_conn.execute("keys", "Workers:*")
- for key in worker_keys:
- worker_id = hex_identifier(key[len("Workers:"):])
- if worker_id not in worker_info:
- worker_info[worker_id] = await hgetall_as_dict(redis_conn, key)
- node_ip_address = (worker_info[worker_id][b"node_ip_address"]
- .decode("ascii"))
- if node_ip_address not in node_info:
- node_info[node_ip_address] = {"workers": []}
- node_info[node_ip_address]["workers"].append(worker_id)
-
- keys = await redis_conn.execute("keys", "event_log:*")
- if len(keys) == 0:
- # There are no tasks, so send a message to the client saying so.
- await websocket.send(json.dumps({"num_tasks": 0}))
- else:
- timestamps = []
- contents = []
- for key in keys:
- content = await redis_conn.execute("lrange", key, "0", "-1")
- contents.append(json.loads(content[0].decode()))
- timestamps += [timestamp for (timestamp, task, kind, info)
- in contents[-1] if task == "ray:task"]
-
- timestamps.sort()
- time_cutoff = timestamps[(-2 * num_tasks):][0]
-
- max_time = timestamps[-1]
- min_time = time_cutoff - (max_time - time_cutoff) * 0.1
- max_time = max_time + (max_time - time_cutoff) * 0.1
-
- worker_ids = list(worker_info.keys())
- node_ip_addresses = list(node_info.keys())
-
- num_tasks = 0
- task_data = [{"task_data": [],
- "num_workers": len(node_info[node_ip_address]["workers"])}
- for node_ip_address in node_ip_addresses]
- for i in range(len(keys)):
- worker_id, task_id = key_to_hex_identifiers(keys[i])
- data = contents[i]
- if worker_id not in worker_ids:
- # This case should be extremely rare.
- raise Exception("A worker ID was not present in the list of worker "
- "IDs.")
- node_ip_address = (worker_info[worker_id][b"node_ip_address"]
- .decode("ascii"))
- worker_index = node_info[node_ip_address]["workers"].index(worker_id)
- node_index = node_ip_addresses.index(node_ip_address)
-
- task_times = [timestamp for (timestamp, task, kind, info) in data
- if task == "ray:task"]
- if task_times[1] <= time_cutoff:
- continue
-
- task_get_arguments_times = [timestamp for (timestamp, task, kind, info)
- in data if task == "ray:task:get_arguments"]
- task_execute_times = [timestamp for (timestamp, task, kind, info)
- in data if task == "ray:task:execute"]
- task_store_outputs_times = [timestamp for (timestamp, task, kind, info)
- in data if task == "ray:task:store_outputs"]
- task_info = {
- "task": task_times,
- "get_arguments": task_get_arguments_times,
- "execute": task_execute_times,
- "store_outputs": task_store_outputs_times,
- "worker_index": worker_index,
- "node_ip_address": node_ip_address,
- "task_formatted_time": duration_to_string(task_times[1] -
- task_times[0]),
- "get_arguments_formatted_time":
- duration_to_string(task_get_arguments_times[1] -
- task_get_arguments_times[0])}
- if len(task_execute_times) == 2:
- task_info["execute_formatted_time"] = duration_to_string(
- task_execute_times[1] - task_execute_times[0])
- if len(task_store_outputs_times) == 2:
- task_info["store_outputs_formatted_time"] = duration_to_string(
- task_store_outputs_times[1] - task_store_outputs_times[0])
- task_data[node_index]["task_data"].append(task_info)
- num_tasks += 1
- reply = {"min_time": min_time,
- "max_time": max_time,
- "num_tasks": num_tasks,
- "task_data": task_data}
- await websocket.send(json.dumps(reply))
-
-
-async def send_heartbeat_payload(websocket):
- """Send heartbeat updates to the frontend every half second."""
- while True:
- reply = []
- for local_scheduler_id, local_scheduler in local_schedulers.items():
- current_time = time.time()
- local_scheduler_info = {
- "local scheduler ID": local_scheduler_id,
- "time since heartbeat":
- (duration_to_string(current_time -
- local_scheduler["last_heartbeat"])),
- "time since heartbeat numeric":
- str(current_time - local_scheduler["last_heartbeat"]),
- "node ip address": local_scheduler["node_ip_address"]}
- reply.append(local_scheduler_info)
- # Send the payload to the frontend.
- await websocket.send(json.dumps(reply))
- # Wait for a little while so as not to overwhelm the frontend.
- await asyncio.sleep(0.5)
-
-
-async def send_heartbeats(websocket, redis_conn):
- # First update the local scheduler info locally.
- client_keys = await redis_conn.execute("keys", "CL:*")
- for client_key in client_keys:
- client_fields = await hgetall_as_dict(redis_conn, client_key)
- if client_fields[b"client_type"] == b"local_scheduler":
- local_scheduler_id = hex_identifier(client_fields[b"ray_client_id"])
- local_schedulers[local_scheduler_id] = {
- "node_ip_address": client_fields[b"node_ip_address"].decode("ascii"),
- "local_scheduler_socket_name":
- client_fields[b"local_scheduler_socket_name"].decode("ascii"),
- "aux_address": client_fields[b"aux_address"].decode("ascii"),
- "last_heartbeat": -1 * np.inf}
-
- # Subscribe to local scheduler heartbeats.
- await redis_conn.execute_pubsub("subscribe", "local_schedulers")
-
- # Start a method in the background to periodically update the frontend.
- asyncio.ensure_future(send_heartbeat_payload(websocket))
-
- while True:
- msg = await redis_conn.pubsub_channels["local_schedulers"].get()
- heartbeat = LocalSchedulerInfoMessage.GetRootAsLocalSchedulerInfoMessage(
- msg, 0)
- local_scheduler_id_bytes = heartbeat.DbClientId()
- local_scheduler_id = hex_identifier(local_scheduler_id_bytes)
- if local_scheduler_id not in local_schedulers:
- # A new local scheduler has joined the cluster. Ignore it. This won't be
- # displayed in the UI until the page is refreshed.
- continue
- local_schedulers[local_scheduler_id]["last_heartbeat"] = time.time()
-
-
-async def cache_data_from_redis(redis_ip_address, redis_port):
- """Open up ports to listen for new updates from Redis."""
- # TODO(richard): A lot of code needs to be ported in order to open new
- # websockets.
-
- asyncio.ensure_future(listen_for_errors(redis_ip_address, redis_port))
-
-
-async def handle_get_log_files(websocket, redis_conn):
- reply = {}
- # First get all keys for the log file lists.
- log_file_list_keys = await redis_conn.execute("keys", "LOG_FILENAMES:*")
- for log_file_list_key in log_file_list_keys:
- node_ip_address = log_file_list_key.decode("ascii").split(":")[1]
- reply[node_ip_address] = {}
- # Get all of the log filenames for this node IP address.
- log_filenames = await redis_conn.execute("lrange", log_file_list_key, 0,
- -1)
- for log_filename in log_filenames:
- log_filename_key = "LOGFILE:{}:{}".format(node_ip_address,
- log_filename.decode("ascii"))
- logfile = await redis_conn.execute("lrange", log_filename_key, 0, -1)
- logfile = [line.decode("ascii") for line in logfile]
- reply[node_ip_address][log_filename.decode("ascii")] = logfile
-
- # Send the reply back to the front end.
- await websocket.send(json.dumps(reply))
-
-
-async def serve_requests(websocket, path):
- redis_conn = await aioredis.create_connection((redis_ip_address, redis_port),
- loop=loop)
- while True:
- command = json.loads(await websocket.recv())
- print("received command {}".format(command))
-
- if command["command"] == "get-statistics":
- await handle_get_statistics(websocket, redis_conn)
- elif command["command"] == "get-drivers":
- await handle_get_drivers(websocket, redis_conn)
- elif command["command"] == "get-recent-tasks":
- await handle_get_recent_tasks(websocket, redis_conn, command["num"])
- elif command["command"] == "get-errors":
- await handle_get_errors(websocket)
- elif command["command"] == "get-heartbeats":
- await send_heartbeats(websocket, redis_conn)
- elif command["command"] == "get-log-files":
- await handle_get_log_files(websocket, redis_conn)
-
- if command["command"] == "get-workers":
- result = []
- workers = await redis_conn.execute("keys", "WorkerInfo:*")
- for key in workers:
- content = await redis_conn.execute("hgetall", key)
- worker_id = key_to_hex_identifier(key)
- result.append({"worker": worker_id, "export_counter": int(content[1])})
- await websocket.send(json.dumps(result))
- elif command["command"] == "get-clients":
- result = []
- clients = await redis_conn.execute("keys", "CL:*")
- for key in clients:
- content = await redis_conn.execute("hgetall", key)
- result.append({"client": hex_identifier(content[1]),
- "node_ip_address": content[3].decode(),
- "client_type": content[5].decode()})
- await websocket.send(json.dumps(result))
- elif command["command"] == "get-objects":
- result = []
- objects = await redis_conn.execute("keys", "OI:*")
- for key in objects:
- content = await redis_conn.execute("hgetall", key)
- result.append({"object_id": hex_identifier(content[1]),
- "hash": hex_identifier(content[3]),
- "data_size": content[5].decode()})
- await websocket.send(json.dumps(result))
- elif command["command"] == "get-object-info":
- # TODO(pcm): Get the object here (have to connect to ray) and ship
- # content and type back to webclient. One challenge here is that the
- # naive implementation will block the web ui backend, which is not ok if
- # it is serving multiple users.
- await websocket.send(json.dumps({"object_id": "none"}))
- elif command["command"] == "get-tasks":
- result = []
- tasks = await redis_conn.execute("keys", "TT:*")
- for key in tasks:
- content = await redis_conn.execute("hgetall", key)
- result.append({"task_id": key_to_hex_identifier(key),
- "state": int(content[1]),
- "node_id": hex_identifier(content[3])})
- await websocket.send(json.dumps(result))
- elif command["command"] == "get-timeline":
- tasks = collections.defaultdict(list)
- for key in await redis_conn.execute("keys", "event_log:*"):
- worker_id, task_id = key_to_hex_identifiers(key)
- content = await redis_conn.execute("lrange", key, "0", "-1")
- data = json.loads(content[0].decode())
- begin_and_end_time = [timestamp for (timestamp, task, kind, info)
- in data if task == "ray:task"]
- tasks[worker_id].append({"task_id": task_id,
- "start_task": min(begin_and_end_time),
- "end_task": max(begin_and_end_time)})
- await websocket.send(json.dumps(tasks))
- elif command["command"] == "get-events":
- result = []
- for key in await redis_conn.execute("keys", "event_log:*"):
- worker_id, task_id = key_to_hex_identifiers(key)
- answer = await redis_conn.execute("lrange", key, "0", "-1")
- assert len(answer) == 1
- events = json.loads(answer[0].decode())
- result.extend([{"worker_id": worker_id,
- "task_id": task_id,
- "time": event[0],
- "type": event[1]} for event in events])
- await websocket.send(json.dumps(result))
-
-if __name__ == "__main__":
- args = parser.parse_args()
- redis_address = args.redis_address.split(":")
- redis_ip_address, redis_port = redis_address[0], int(redis_address[1])
-
- # The port here must match the value used by the frontend to connect over
- # websockets. TODO(richard): Automatically increment the port if it is
- # already taken.
- port = 8888
-
- loop.run_until_complete(cache_data_from_redis(redis_ip_address, redis_port))
-
- start_server = websockets.serve(serve_requests, "localhost", port)
- loop.run_until_complete(start_server)
- loop.run_forever()
diff --git a/webui/bower.json b/webui/bower.json
deleted file mode 100644
index 448b8dfff..000000000
--- a/webui/bower.json
+++ /dev/null
@@ -1,26 +0,0 @@
-{
- "name": "polymer-starter-kit",
- "authors": [
- "The Polymer Authors"
- ],
- "license": "https://polymer.github.io/LICENSE.txt",
- "dependencies": {
- "app-layout": "PolymerElements/app-layout#^0.10.0",
- "app-route": "PolymerElements/app-route#^0.9.0",
- "iron-flex-layout": "PolymerElements/iron-flex-layout#^1.0.0",
- "iron-icon": "PolymerElements/iron-icon#^1.0.0",
- "iron-iconset-svg": "PolymerElements/iron-iconset-svg#^1.0.0",
- "iron-localstorage": "PolymerElements/iron-localstorage#^1.0.0",
- "iron-media-query": "PolymerElements/iron-media-query#^1.0.0",
- "iron-pages": "PolymerElements/iron-pages#^1.0.0",
- "iron-selector": "PolymerElements/iron-selector#^1.0.0",
- "paper-icon-button": "PolymerElements/paper-icon-button#~1.1.0",
- "polymer": "Polymer/polymer#^1.6.0",
- "vaadin-grid": "^1.2.1",
- "google-chart": "^1.1.1"
- },
- "devDependencies": {
- "web-component-tester": "^4.0.0"
- },
- "private": true
-}
diff --git a/webui/images/favicon.ico b/webui/images/favicon.ico
deleted file mode 100644
index 9cd897ef4..000000000
Binary files a/webui/images/favicon.ico and /dev/null differ
diff --git a/webui/images/manifest/icon-144x144.png b/webui/images/manifest/icon-144x144.png
deleted file mode 100644
index c09f0ce58..000000000
Binary files a/webui/images/manifest/icon-144x144.png and /dev/null differ
diff --git a/webui/images/manifest/icon-192x192.png b/webui/images/manifest/icon-192x192.png
deleted file mode 100644
index e74d22e09..000000000
Binary files a/webui/images/manifest/icon-192x192.png and /dev/null differ
diff --git a/webui/images/manifest/icon-48x48.png b/webui/images/manifest/icon-48x48.png
deleted file mode 100644
index 15bb11e27..000000000
Binary files a/webui/images/manifest/icon-48x48.png and /dev/null differ
diff --git a/webui/images/manifest/icon-512x512.png b/webui/images/manifest/icon-512x512.png
deleted file mode 100644
index 1f8053f0e..000000000
Binary files a/webui/images/manifest/icon-512x512.png and /dev/null differ
diff --git a/webui/images/manifest/icon-72x72.png b/webui/images/manifest/icon-72x72.png
deleted file mode 100644
index c0af86565..000000000
Binary files a/webui/images/manifest/icon-72x72.png and /dev/null differ
diff --git a/webui/images/manifest/icon-96x96.png b/webui/images/manifest/icon-96x96.png
deleted file mode 100644
index 712a60533..000000000
Binary files a/webui/images/manifest/icon-96x96.png and /dev/null differ
diff --git a/webui/index.html b/webui/index.html
deleted file mode 100644
index 5ff9cdc8c..000000000
--- a/webui/index.html
+++ /dev/null
@@ -1,107 +0,0 @@
-
-
-
-
-
-
-
-
-
- Ray UI
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/webui/manifest.json b/webui/manifest.json
deleted file mode 100644
index 1c787ff45..000000000
--- a/webui/manifest.json
+++ /dev/null
@@ -1,20 +0,0 @@
-{
- "name": "My App",
- "short_name": "My App",
- "start_url": "/?homescreen=1",
- "display": "standalone",
- "theme_color": "#3f51b5",
- "background_color": "#3f51b5",
- "icons": [
- {
- "src": "images/manifest/icon-192x192.png",
- "sizes": "192x192",
- "type": "image/png"
- },
- {
- "src": "images/manifest/icon-512x512.png",
- "sizes": "512x512",
- "type": "image/png"
- }
- ]
-}
diff --git a/webui/package.json b/webui/package.json
deleted file mode 100644
index f851c4de3..000000000
--- a/webui/package.json
+++ /dev/null
@@ -1,13 +0,0 @@
-{
- "name": "polymer-starter-kit",
- "license": "BSD-3-Clause",
- "devDependencies": {
- "eslint": "^3.12.0",
- "eslint-config-google": "^0.7.1",
- "eslint-plugin-html": "^1.7.0"
- },
- "scripts": {
- "lint": "eslint . --ext js,html; exit 0;",
- "test": "npm run lint && polymer test"
- }
-}
diff --git a/webui/polymer.json b/webui/polymer.json
deleted file mode 100644
index 8fe1ac481..000000000
--- a/webui/polymer.json
+++ /dev/null
@@ -1,19 +0,0 @@
-{
- "entrypoint": "index.html",
- "shell": "src/my-app.html",
- "fragments": [
- "src/my-overview.html",
- "src/my-objects.html",
- "src/my-view3.html",
- "src/my-view404.html"
- ],
- "sourceGlobs": [
- "src/**/*",
- "images/**/*",
- "bower.json"
- ],
- "includeDependencies": [
- "manifest.json",
- "bower_components/webcomponentsjs/webcomponents-lite.min.js"
- ]
-}
diff --git a/webui/service-worker.js b/webui/service-worker.js
deleted file mode 100644
index 93e9d49d7..000000000
--- a/webui/service-worker.js
+++ /dev/null
@@ -1,15 +0,0 @@
-/**
- * @license
- * Copyright (c) 2016 The Polymer Project Authors. All rights reserved.
- * This code may only be used under the BSD style license found at http://polymer.github.io/LICENSE.txt
- * The complete set of authors may be found at http://polymer.github.io/AUTHORS.txt
- * The complete set of contributors may be found at http://polymer.github.io/CONTRIBUTORS.txt
- * Code distributed by Google as part of the polymer project is also
- * subject to an additional IP rights grant found at http://polymer.github.io/PATENTS.txt
- */
-
-/* eslint no-console: ["error", { allow: ["info"] }] */
-
-console.info(
- 'Service worker disabled for development, will be generated at build time.'
-);
diff --git a/webui/src/ray-app.html b/webui/src/ray-app.html
deleted file mode 100644
index 1eaa2b6fd..000000000
--- a/webui/src/ray-app.html
+++ /dev/null
@@ -1,140 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- Menu
-
- Overview
- Cluster Health
- Objects
- Tasks
- Events
- Errors
- Timeline
- Recent Tasks
- Log Files
-
-
-
-
-
-
-
-
-
- Ray UI
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
diff --git a/webui/src/ray-cluster-health.html b/webui/src/ray-cluster-health.html
deleted file mode 100644
index dbadd81c1..000000000
--- a/webui/src/ray-cluster-health.html
+++ /dev/null
@@ -1,54 +0,0 @@
-
-
-
-
-
-
-
-
-
Ray Cluster Health
-
Clients
-
-
-
-
-
Overview
-
Cluster Statistics
-
-
-
-
-
Drivers
-
-
-
-
-
Clients
-
-
-
-
-
Workers
-
-
-
-
-
Ray Recent Tasks
-
-
-
-
-
-
-
-
Ray Timeline
-
-
-
-
-
-
diff --git a/webui/src/ray-view404.html b/webui/src/ray-view404.html
deleted file mode 100644
index 1733afba5..000000000
--- a/webui/src/ray-view404.html
+++ /dev/null
@@ -1,35 +0,0 @@
-
-
-
-
-
-
-
-
-
- Oops you hit a 404. Head back to home.
-
-
-
-
diff --git a/webui/src/recent-tasks.js b/webui/src/recent-tasks.js
deleted file mode 100644
index 443847d62..000000000
--- a/webui/src/recent-tasks.js
+++ /dev/null
@@ -1,107 +0,0 @@
-RecentTasks = function(all_recent_tasks_elem) {
- var self = this;
-
- var verticalPadding = 10;
- var barHeight = 25;
-
- var all_recent_tasks_div = d3.select(all_recent_tasks_elem);
-
- this.generate_task_info = function(d) {
- return "Total Time: " + d.task_formatted_time + "
" +
- "Time Getting Arguments: " + d.get_arguments_formatted_time + "
" +
- "Time in Execution: " + d.execute_formatted_time + "
" +
- "Time Storing Outputs: " + d.store_outputs_formatted_time + "
";
- }
-
- this.draw_new_node_tasks = function(all_task_info, task_info, width, svg, info) {
- var height = task_info.num_workers * barHeight + 2 * verticalPadding;
-
- svg.attr("width", width)
- .attr("height", height);
-
- var borderPath = svg.append("rect")
- .attr("x", 0)
- .attr("y", 0)
- .attr("height", height)
- .attr("width", width)
- .style("stroke", "black")
- .style("fill", "none")
- .style("stroke-width", 1);
-
- var x = d3.scaleLinear()
- .domain([all_task_info.min_time, all_task_info.max_time])
- .range([-1, width + 1]);
-
- var task_rects = svg.append("g").attr("class", "task_rects");
- var get_arguments_rects = svg.append("g").attr("class", "get_arguments_rects");
- var execute_rects = svg.append("g").attr("class", "execute_rects");
- var store_outputs_rects = svg.append("g").attr("class", "store_outputs_rects");
-
- task_rects.selectAll("rect")
- .data(task_info.task_data)
- .enter()
- .append("rect")
- .attr("x", function (d) { return x(d.task[0]); })
- .attr("y", function (d) { return verticalPadding + d.worker_index * barHeight; })
- .attr("width", function (d) { return x(d.task[1]) - x(d.task[0]); })
- .attr("height", function (d) { return barHeight - 1; })
- .attr("fill", "orange")
- .attr("id", function (d) { d.store_outputs[1]; })
- .on("click", function(d, i) {
- info.html(self.generate_task_info(d));
- })
-
- get_arguments_rects.selectAll("rect")
- .data(task_info.task_data)
- .enter()
- .append("rect")
- .attr("x", function (d) { return x(d.get_arguments[0]); })
- .attr("y", function (d) { return verticalPadding + d.worker_index * barHeight + 1; })
- .attr("width", function (d) { return x(d.get_arguments[1]) - x(d.get_arguments[0]); })
- .attr("height", function (d) { return barHeight - 3; })
- .attr("fill", "black")
- .on("click", function(d, i) {
- info.html(self.generate_task_info(d));
- })
-
- execute_rects.selectAll("rect")
- .data(task_info.task_data)
- .enter()
- .append("rect")
- .attr("x", function (d) { return x(d.execute[0]); })
- .attr("y", function (d) { return verticalPadding + d.worker_index * barHeight + 1; })
- .attr("width", function (d) { return x(d.execute[1]) - x(d.execute[0]); })
- .attr("height", function (d) { return barHeight - 3; })
- .attr("fill", "blue")
- .on("click", function(d, i) {
- info.html(self.generate_task_info(d));
- })
-
- store_outputs_rects.selectAll("rect")
- .data(task_info.task_data)
- .enter()
- .append("rect")
- .attr("x", function (d) { return x(d.store_outputs[0]); })
- .attr("y", function (d) { return verticalPadding + d.worker_index * barHeight + 1; })
- .attr("width", function (d) { return x(d.store_outputs[1]) - x(d.store_outputs[0]); })
- .attr("height", function (d) { return barHeight - 3; })
- .attr("fill", "green")
- .on("click", function(d, i) {
- info.html(self.generate_task_info(d));
- })
- }
-
- this.draw_new_tasks = function(all_task_info, width) {
- // Call draw_new_node_tasks once for each node.
- for (i = 0; i < all_task_info.task_data.length; i++) {
- var new_svg = all_recent_tasks_div.append("svg");
- var info = all_recent_tasks_div.append("div");
- this.draw_new_node_tasks(all_task_info, all_task_info.task_data[i], width, new_svg, info);
- }
- }
-
- this.erase = function() {
- all_recent_tasks_div.selectAll("svg").remove();
- all_recent_tasks_div.selectAll("div").remove();
- }
-}
diff --git a/webui/src/shared-styles.html b/webui/src/shared-styles.html
deleted file mode 100644
index 5e4f2491d..000000000
--- a/webui/src/shared-styles.html
+++ /dev/null
@@ -1,45 +0,0 @@
-
-
-
-
-
-
-
-
-
-
diff --git a/webui/sw-precache-config.js b/webui/sw-precache-config.js
deleted file mode 100644
index 301bb56b0..000000000
--- a/webui/sw-precache-config.js
+++ /dev/null
@@ -1,20 +0,0 @@
-/**
- * @license
- * Copyright (c) 2016 The Polymer Project Authors. All rights reserved.
- * This code may only be used under the BSD style license found at http://polymer.github.io/LICENSE.txt
- * The complete set of authors may be found at http://polymer.github.io/AUTHORS.txt
- * The complete set of contributors may be found at http://polymer.github.io/CONTRIBUTORS.txt
- * Code distributed by Google as part of the polymer project is also
- * subject to an additional IP rights grant found at http://polymer.github.io/PATENTS.txt
- */
-
-/* eslint-env node */
-
-module.exports = {
- staticFileGlobs: [
- '/index.html',
- '/manifest.json',
- '/bower_components/webcomponentsjs/webcomponents-lite.min.js',
- ],
- navigateFallback: 'index.html',
-};
diff --git a/webui/test/.eslintrc.json b/webui/test/.eslintrc.json
deleted file mode 100644
index 72c940381..000000000
--- a/webui/test/.eslintrc.json
+++ /dev/null
@@ -1,10 +0,0 @@
-{
- "env": {
- "mocha": true
- },
- "globals": {
- "assert": false,
- "fixture": false,
- "WCT": false
- }
-}
diff --git a/webui/test/index.html b/webui/test/index.html
deleted file mode 100644
index 8678e3845..000000000
--- a/webui/test/index.html
+++ /dev/null
@@ -1,29 +0,0 @@
-
-
-
-
-
-
-
-
- Tests
-
-
-
-
-
-
-
diff --git a/webui/test/my-view1.html b/webui/test/my-view1.html
deleted file mode 100644
index bcb79628e..000000000
--- a/webui/test/my-view1.html
+++ /dev/null
@@ -1,47 +0,0 @@
-
-
-
-
-
-
-
-
- my-view1
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-