updated jobs and dockstore notebooks

Author: rtapella

jupyter-notebooks/tutorials/3_working_with_jobs.ipynb

@@ -31,7 +31,55 @@
    "id": "a4037156-e9ee-4b99-aee8-569772ae1d29",
    "metadata": {},
    "source": [
-    "### Imports"
+    "## Imports"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "id": "9b9dd885-56a9-4e46-889d-ca47144f7986",
+   "metadata": {
+    "tags": []
+   },
+   "source": [
+    "### See whether unity_sds_client is installed. If it is installed, this will show details of the package."
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "id": "db1492bd-600d-47f8-8bae-68c2108b1060",
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "pip show unity_sds_client"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "id": "59276a75-1add-439d-b650-c61db81c0e94",
+   "metadata": {
+    "tags": []
+   },
+   "source": [
+    "### If unity_sds_client is NOT installed do an install. Otherwise skip this."
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "id": "7b30e677-6d0b-4544-adf8-3db6f2d395bb",
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "pip install unity_sds_client"
+   ]
+  },
+  {
+   "cell_type": "markdown",
+   "id": "27b413f7-e546-45f9-9c2f-4d670e25fec6",
+   "metadata": {},
+   "source": [
+    "### Set up imports"
    ]
   },
   {
@@ -94,6 +142,7 @@
    "cell_type": "markdown",
    "id": "98017416-3d3c-4225-843f-8f2fa35be36b",
    "metadata": {
+    "jp-MarkdownHeadingCollapsed": true,
     "tags": []
    },
    "source": [
@@ -183,6 +232,7 @@
    "cell_type": "markdown",
    "id": "69d43073-3e99-4ea2-8021-9104b4003e84",
    "metadata": {
+    "jp-MarkdownHeadingCollapsed": true,
     "tags": []
    },
    "source": [
@@ -314,12 +364,7 @@
     "    print(\"Process Title: {}\".format(process.title))\n",
     "    print(\"Process Abstract: {}\".format(process.abstract))\n",
     "    print(\"Process Version: {}\".format(process.process_version))\n",
-    "    print(\"\")\n",
-    "    print(process)\n",
-    "    \n",
-    "# For example purposes, we will use the first process returned\n",
-    "my_process = processes[0]\n",
-    "print(\"\\n\\nSelected Process:\\n\\n{}\".format(my_process))"
+    "    print(\"\")\n"
    ]
   },
   {
@@ -339,8 +384,9 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "process = process_service.get_process('l1b-cwl:develop')\n",
-    "print(process)"
+    "# For example purposes, we will use the a process with the id:version indicated below (taken from the list above)\n",
+    "my_process = process_service.get_process('chirp:develop')\n",
+    "print(my_process)"
    ]
   },
   {
@@ -370,6 +416,50 @@
     "  \"mode\": \"async\",\n",
     "  \"response\": \"document\",\n",
     "  \"inputs\": [\n",
+    "     {\n",
+    "      \"id\": \"job_id\",\n",
+    "      \"data\": \"abc1234\"\n",
+    "    },\n",
+    "    {\n",
+    "      \"id\": \"input_processing_labels\",\n",
+    "      \"data\": [\"label1\", \"label2\"]\n",
+    "    },\n",
+    "    {\n",
+    "      \"id\": \"input_cmr_collection_name\",\n",
+    "      \"data\": \"C2011289787-GES_DISC\"\n",
+    "    },\n",
+    "    {\n",
+    "      \"id\": \"input_cmr_search_start_time\",\n",
+    "      \"data\": \"2016-08-22\"\n",
+    "    },\n",
+    "    {\n",
+    "      \"id\": \"input_cmr_search_stop_time\",\n",
+    "      \"data\": \"2016-09-06\"\n",
+    "    },\n",
+    "     {\n",
+    "      \"id\": \"input_cmr_edl_user\",\n",
+    "      \"data\": \"cmr_user\"\n",
+    "    },\n",
+    "    {\n",
+    "      \"id\": \"input_cmr_edl_pass\",\n",
+    "      \"data\": \"cmr_pass\"\n",
+    "    },\n",
+    "    {\n",
+    "      \"id\": \"output_collection_id\",\n",
+    "      \"data\": \"CHIRP_OUTPUT_COLLECTION\"\n",
+    "    },\n",
+    "    {\n",
+    "      \"id\": \"output_data_bucket\",\n",
+    "      \"data\": \"s3://unity-data-bucket\"\n",
+    "    },\n",
+    "    {\n",
+    "      \"id\": \"input_daac_collection_shortname\",\n",
+    "      \"data\": \"CHIRP_L1B\"\n",
+    "    },\n",
+    "    {\n",
+    "      \"id\": \"input_daac_collection_sns\",\n",
+    "      \"data\": \"arn:://SNS-arn\"\n",
+    "    }\n",
     "  ],\n",
     "  \"outputs\": [\n",
     "    {\n",
@@ -420,7 +510,7 @@
     "        time.sleep(5)\n",
     "        job_status = job.get_status()\n",
     "    \n",
-    "    # Print the job status\n",
+    "    # Print the job status once it has stopped running (i.e., succeded or failed)\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",
@@ -484,7 +574,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "print(\"{},{}\".format(my_process.id, job.id))\n",
+    "print(\"Dismissing {}, job {}\\n\".format(my_process.id, job.id))\n",
     "response = job.dismiss()\n",
     "\n",
     "print(\"Response: \", response, \"\\n\")"
@@ -507,7 +597,7 @@
    "metadata": {},
    "outputs": [],
    "source": [
-    "print(\"Jobs running for Process: \", my_process.id, \"\\n\")\n",
+    "print(\"Jobs for Process: \", my_process.id, \"\\n\")\n",
     "\n",
     "jobs = process_service.get_jobs(my_process)\n",
     "\n",
@@ -526,9 +616,9 @@
  ],
  "metadata": {
   "kernelspec": {
-   "display_name": "sounder-sips-tutorial",
+   "display_name": "Python 3 (ipykernel)",
    "language": "python",
-   "name": "sounder-sips-tutorial"
+   "name": "python3"
   },
   "language_info": {
    "codemirror_mode": {
@@ -540,7 +630,7 @@
    "name": "python",
    "nbconvert_exporter": "python",
    "pygments_lexer": "ipython3",
-   "version": "3.11.0"
+   "version": "3.10.5"
   }
  },
  "nbformat": 4,