Fixing pipeline and its semantics after updating to Or/And

Author: raghukiran1224

Ray graph experiments.ipynb

@@ -22,31 +22,32 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 3,
+   "execution_count": 2,
    "id": "renewable-western",
    "metadata": {},
    "outputs": [
     {
      "name": "stderr",
      "output_type": "stream",
      "text": [
-      "2021-02-26 11:46:09,384\tINFO services.py:1166 -- View the Ray dashboard at \u001b[1m\u001b[32mhttp://127.0.0.1:8265\u001b[39m\u001b[22m\n"
+      "2021-05-04 16:17:33,432\tINFO services.py:1092 -- View the Ray dashboard at \u001b[1m\u001b[32mhttp://127.0.0.1:8266\u001b[39m\u001b[22m\n"
      ]
     },
     {
      "data": {
       "text/plain": [
-       "{'node_ip_address': '192.168.1.37',\n",
-       " 'raylet_ip_address': '192.168.1.37',\n",
-       " 'redis_address': '192.168.1.37:6379',\n",
-       " 'object_store_address': '/tmp/ray/session_2021-02-26_11-46-08_157773_47098/sockets/plasma_store',\n",
-       " 'raylet_socket_name': '/tmp/ray/session_2021-02-26_11-46-08_157773_47098/sockets/raylet',\n",
-       " 'webui_url': '127.0.0.1:8265',\n",
-       " 'session_dir': '/tmp/ray/session_2021-02-26_11-46-08_157773_47098',\n",
-       " 'metrics_export_port': 61984}"
+       "{'node_ip_address': '9.160.24.40',\n",
+       " 'raylet_ip_address': '9.160.24.40',\n",
+       " 'redis_address': '9.160.24.40:29280',\n",
+       " 'object_store_address': '/tmp/ray/session_2021-05-04_16-17-32_831080_96327/sockets/plasma_store',\n",
+       " 'raylet_socket_name': '/tmp/ray/session_2021-05-04_16-17-32_831080_96327/sockets/raylet',\n",
+       " 'webui_url': '127.0.0.1:8266',\n",
+       " 'session_dir': '/tmp/ray/session_2021-05-04_16-17-32_831080_96327',\n",
+       " 'metrics_export_port': 58844,\n",
+       " 'node_id': 'c8ed8ccd822336e1bcfc1d946811186c9b954ceb'}"
       ]
      },
-     "execution_count": 3,
+     "execution_count": 2,
      "metadata": {},
      "output_type": "execute_result"
     }
@@ -57,7 +58,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 4,
+   "execution_count": 3,
    "id": "scheduled-miami",
    "metadata": {},
    "outputs": [],
@@ -67,7 +68,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": 5,
+   "execution_count": 4,
    "id": "leading-sheriff",
    "metadata": {},
    "outputs": [],
@@ -89,10 +90,10 @@
     "\n",
     "pipeline = dm.Pipeline()\n",
     "\n",
-    "node_a = dm.Node('a', transformer)\n",
-    "node_b = dm.Node('b', transformer)\n",
-    "node_c = dm.Node('c', transformer)\n",
-    "node_d = dm.Node('d', transformer)\n",
+    "node_a = dm.OrNode('a', transformer)\n",
+    "node_b = dm.OrNode('b', transformer)\n",
+    "node_c = dm.OrNode('c', transformer)\n",
+    "node_d = dm.OrNode('d', transformer)\n",
     "\n",
     "pipeline.add_edge(node_a, node_b)\n",
     "pipeline.add_edge(node_b, node_c)\n",
@@ -239,24 +240,25 @@
     {
      "data": {
       "text/plain": [
-       "[[<com.ibm.research.ray.graph.Datamodel.XYRef at 0x7fbc48525c50>]]"
+       "[[<com.ibm.research.ray.graph.Datamodel.XYRef at 0x7f9898928190>]]"
       ]
      },
      "execution_count": 17,
      "metadata": {},
      "output_type": "execute_result"
-    },
-    {
-     "name": "stderr",
-     "output_type": "stream",
-     "text": [
-      "2021-02-28 11:00:54,243\tERROR worker.py:981 -- print_logs: Connection closed by server.\n"
-     ]
     }
    ],
    "source": [
     "ray.get(out_args[node_c])"
    ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "id": "b0188d6f",
+   "metadata": {},
+   "outputs": [],
+   "source": []
   }
  ],
  "metadata": {