Updated working with jobs notebook to integrate the use of unity-py.

Author: anilnatha

jupyter-notebooks/tutorials/3_working_with_jobs.ipynb

@@ -48,7 +48,8 @@
     "from IPython.display import JSON\n",
     "\n",
     "from unity_py.unity import Unity\n",
-    "from unity_py.unity_services import UnityServices"
+    "from unity_py.unity_services import UnityServices\n",
+    "from unity_py.resources.job_status import JobStatus"
    ]
   },
   {
@@ -92,7 +93,6 @@
    "cell_type": "markdown",
    "id": "98017416-3d3c-4225-843f-8f2fa35be36b",
    "metadata": {
-    "jp-MarkdownHeadingCollapsed": true,
     "tags": []
    },
    "source": [
@@ -150,7 +150,6 @@
    "cell_type": "markdown",
    "id": "9e36a5fb-25ab-40ad-a9cb-ed2c06597cea",
    "metadata": {
-    "jp-MarkdownHeadingCollapsed": true,
     "tags": []
    },
    "source": [
@@ -197,7 +196,7 @@
    "id": "9f1cdbbc-6c38-4c2a-955a-08ac8d13e366",
    "metadata": {},
    "source": [
-    "## 5. List processes\n",
+    "## 5. Listing all deployed processes\n",
     "\n",
     "The Unity-Py client provides the ability to view all deployed application packages (a.k.a., Processes) on the system using the `get_processes` function. After a successful deployment of an application package to SPS, you should see a new entry for the deployed application.\n",
     "\n",
@@ -225,6 +224,27 @@
     "print(\"\\n\\nSelected Process:\\n\\n{}\".format(my_process))"
    ]
   },
+  {
+   "cell_type": "markdown",
+   "id": "51426e28-3fa9-41fd-bc52-eca7053c24e7",
+   "metadata": {},
+   "source": [
+    "### Retrieve a deployed process's information\n",
+    "\n",
+    "If you know the ID of the process, the process information can be retrieved using the `get_process(id)` method of `ProcessService`.\n"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "id": "9f2c9ea5-2691-4e4a-bc00-0b682b6a41fd",
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "process = process_service.get_process('l1b-cwl:develop')\n",
+    "print(process)"
+   ]
+  },
   {
    "cell_type": "markdown",
    "id": "00fc3f8f-8d05-4765-92cb-99bc25778a02",
@@ -265,10 +285,10 @@
     "\n",
     "    # Store Job ID to use in future steps\n",
     "    job = my_process.execute(data)\n",
+    "    print(job)\n",
     "\n",
     "    # If the job submission is successful, print a success message along with the returned JOB-ID\n",
     "    print(\"\\nJob Submission Successful!\\nJOB ID: {}\\n\".format(job.id))\n",
-    "    print(job)\n",
     "\n",
     "except requests.exceptions.HTTPError as e:\n",
     "    # An error has occurred, print the error message that was generated\n",
@@ -297,13 +317,13 @@
     "\n",
     "    job_status = job.get_status()\n",
     "    \n",
-    "    while job_status == \"running\":\n",
-    "        print(\"Status for job \\\"{}\\\" ({}): {}\".format(job.id, datetime.now().strftime(\"%H:%M:%S\"), job_status))\n",
+    "    while job_status == JobStatus.RUNNING:\n",
+    "        print(\"Status for job \\\"{}\\\" ({}): {}\".format(job.id, datetime.now().strftime(\"%H:%M:%S\"), job_status.value))\n",
     "        time.sleep(5)\n",
     "        job_status = job.get_status()\n",
     "    \n",
     "    # Print the job status\n",
-    "    print(\"\\nStatus for job \\\"{}\\\" ({}): {}\\n\".format(job.id, datetime.now().strftime(\"%H:%M:%S\"),job_status))\n",
+    "    print(\"\\nStatus for job \\\"{}\\\" ({}): {}\\n\".format(job.id, datetime.now().strftime(\"%H:%M:%S\"),job_status.value))\n",
     "    \n",
     "except requests.exceptions.HTTPError as e:\n",
     "    # An error has occurred, print the error message that was generated\n",
@@ -328,18 +348,10 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "# Set jobID here if you'd like\n",
-    "#job_id = \"35284103-b7ce-4ea4-86d1-c0dd0622f898\"\n",
-    "\n",
     "try:\n",
     "\n",
     "    job_data = job.get_result()\n",
     "\n",
-    "    #for data in job_data:\n",
-    "    #    print(\"ID: \" + data['id'])\n",
-    "    #    print(\"Type: \" + data['mimeType'])\n",
-    "    #    print(\"Location: \" + data['href'])\n",
-    "        \n",
     "except requests.exceptions.HTTPError as e:\n",
     "    print(e.reason)\n",
     "\n",
@@ -402,19 +414,8 @@
     "jobs = process_service.get_jobs(my_process)\n",
     "\n",
     "for job in jobs:\n",
-    "    print(\"{}/{}\".format(job.id, job.status))\n",
-    "       \n",
-    "print(\"\\n\\nFull JSON output data of get_jobs_for_app\")\n",
-    "JSON(jobs)"
+    "    print(job)"
    ]
-  },
-  {
-   "cell_type": "code",
-   "execution_count": null,
-   "id": "6181c3d1-88b9-4bb3-be43-73fc5ad582c6",
-   "metadata": {},
-   "outputs": [],
-   "source": []
   }
  ],
  "metadata": {