{"action":"created","issue":{"url":"https://api.github.com/repos/ray-project/ray/issues/2015","repository_url":"https://api.github.com/repos/ray-project/ray","labels_url":"https://api.github.com/repos/ray-project/ray/issues/2015/labels{/name}","comments_url":"https://api.github.com/repos/ray-project/ray/issues/2015/comments","events_url":"https://api.github.com/repos/ray-project/ray/issues/2015/events","html_url":"https://github.com/ray-project/ray/pull/2015","id":321218059,"node_id":"MDExOlB1bGxSZXF1ZXN0MTg2NjU4NjM4","number":2015,"title":"Asyncio prototype implementation","user":{"login":"suquark","id":13750372,"node_id":"MDQ6VXNlcjEzNzUwMzcy","avatar_url":"https://avatars1.githubusercontent.com/u/13750372?v=4","gravatar_id":"","url":"https://api.github.com/users/suquark","html_url":"https://github.com/suquark","followers_url":"https://api.github.com/users/suquark/followers","following_url":"https://api.github.com/users/suquark/following{/other_user}","gists_url":"https://api.github.com/users/suquark/gists{/gist_id}","starred_url":"https://api.github.com/users/suquark/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/suquark/subscriptions","organizations_url":"https://api.github.com/users/suquark/orgs","repos_url":"https://api.github.com/users/suquark/repos","events_url":"https://api.github.com/users/suquark/events{/privacy}","received_events_url":"https://api.github.com/users/suquark/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":48,"created_at":"2018-05-08T14:46:21Z","updated_at":"2018-07-16T09:57:40Z","closed_at":null,"author_association":"CONTRIBUTOR","pull_request":{"url":"https://api.github.com/repos/ray-project/ray/pulls/2015","html_url":"https://github.com/ray-project/ray/pull/2015","diff_url":"https://github.com/ray-project/ray/pull/2015.diff","patch_url":"https://github.com/ray-project/ray/pull/2015.patch"},"body":"<!--\r\nThank you for your contribution!\r\n\r\nPlease review https://github.com/ray-project/ray/blob/master/CONTRIBUTING.rst before opening a pull request.\r\n-->\r\n\r\n## What do these changes do?\r\n\r\n<!-- Please give a short brief about these changes. -->\r\nThis is a prototype implementation for https://github.com/ray-project/ray/issues/493 which provides awaitable interface for `ray.wait` & ray's `ObjectID`\r\n\r\nAs a prototype, these codes are meant to be modified later.\r\n\r\n## How do these changes work?\r\n\r\n1. `AsyncPlasmaClient` is implemeted to override original `pyarrow.plasma.PlasmaClient`. `pyarrow.plasma.PlasmaClient` is created by `pyarrow.plasma.connect` and is attached to `ray.worker.global_worker` to handle basic ray functions. It also create an interface for wrapping ray's ObjectID.\r\n2. `AsyncPlasmaSocket` is created for async socket messaging with PlasmaStore & PlasmaManager. It is the core of async. `pyarrow.plasma.PlasmaClient` does not make use of event loops and only create a single socket connection, it is why original ray does not support much of async functions. `AsyncPlasmaSocket` uses asyncio event loop and is capable of creating multiple socket connections with PlasmaManager.\r\n3. `plasma.fbs` under `format` directory needs to be compiled with flatbuffer ahead of time. \r\n\r\n## Related issue number\r\n\r\n<!-- Are there any issues opened that will be resolved by merging this change? -->\r\n\r\nhttps://github.com/ray-project/ray/issues/493\r\n\r\ncc @mitar"},"comment":{"url":"https://api.github.com/repos/ray-project/ray/issues/comments/405199402","html_url":"https://github.com/ray-project/ray/pull/2015#issuecomment-405199402","issue_url":"https://api.github.com/repos/ray-project/ray/issues/2015","id":405199402,"node_id":"MDEyOklzc3VlQ29tbWVudDQwNTE5OTQwMg==","user":{"login":"AmplabJenkins","id":4031291,"node_id":"MDQ6VXNlcjQwMzEyOTE=","avatar_url":"https://avatars3.githubusercontent.com/u/4031291?v=4","gravatar_id":"","url":"https://api.github.com/users/AmplabJenkins","html_url":"https://github.com/AmplabJenkins","followers_url":"https://api.github.com/users/AmplabJenkins/followers","following_url":"https://api.github.com/users/AmplabJenkins/following{/other_user}","gists_url":"https://api.github.com/users/AmplabJenkins/gists{/gist_id}","starred_url":"https://api.github.com/users/AmplabJenkins/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/AmplabJenkins/subscriptions","organizations_url":"https://api.github.com/users/AmplabJenkins/orgs","repos_url":"https://api.github.com/users/AmplabJenkins/repos","events_url":"https://api.github.com/users/AmplabJenkins/events{/privacy}","received_events_url":"https://api.github.com/users/AmplabJenkins/received_events","type":"User","site_admin":false},"created_at":"2018-07-16T09:57:40Z","updated_at":"2018-07-16T09:57:40Z","author_association":"COLLABORATOR","body":"Test FAILed.\nRefer to this link for build results (access rights to CI server needed): \nhttps://amplab.cs.berkeley.edu/jenkins//job/Ray-PRB/6661/\nTest FAILed."}}
{"actor":{"display_login":"AmplabJenkins"}}