fix: linting issues

Author: JanssenBrm

app/services/processing.py

@@ -76,7 +76,11 @@ def get_job_status(job: ProcessingJobRecord) -> ProcessingStatusEnum:
     )
     platform = get_processing_platform(job.label)
     details = ServiceDetails.model_validate_json(job.service)
-    return platform.get_job_status(job.platform_job_id, details)
+    return (
+        platform.get_job_status(job.platform_job_id, details)
+        if job.platform_job_id
+        else job.status
+    )
 
 
 def get_processing_job_results(
@@ -89,7 +93,11 @@ def get_processing_job_results(
     logger.info(f"Retrieving job result for job: {record.platform_job_id}")
     platform = get_processing_platform(record.label)
     details = ServiceDetails.model_validate_json(record.service)
-    return platform.get_job_results(record.platform_job_id, details)
+    return (
+        platform.get_job_results(record.platform_job_id, details)
+        if record.platform_job_id
+        else None
+    )
 
 
 def _refresh_job_status(

guides/upscaling_example.ipynb

@@ -283,7 +283,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": null,
+   "execution_count": 23,
    "id": "ac428293-7cd4-49a8-9bfa-4e0dc8f4d2cc",
    "metadata": {},
    "outputs": [
@@ -300,6 +300,19 @@
      },
      "metadata": {},
      "output_type": "display_data"
+    },
+    {
+     "ename": "ConnectionClosedError",
+     "evalue": "received 1012 (service restart); then sent 1012 (service restart)",
+     "output_type": "error",
+     "traceback": [
+      "\u001b[0;31m---------------------------------------------------------------------------\u001b[0m",
+      "\u001b[0;31mConnectionClosedError\u001b[0m                     Traceback (most recent call last)",
+      "Cell \u001b[0;32mIn[23], line 79\u001b[0m\n\u001b[1;32m     76\u001b[0m                     \u001b[38;5;28;01mbreak\u001b[39;00m\n\u001b[1;32m     78\u001b[0m \u001b[38;5;66;03m# Run the websocket listener in the notebook\u001b[39;00m\n\u001b[0;32m---> 79\u001b[0m \u001b[38;5;28;01mawait\u001b[39;00m listen_for_updates()\n",
+      "Cell \u001b[0;32mIn[23], line 47\u001b[0m, in \u001b[0;36mlisten_for_updates\u001b[0;34m()\u001b[0m\n\u001b[1;32m     45\u001b[0m \u001b[38;5;28;01masync\u001b[39;00m \u001b[38;5;28;01mwith\u001b[39;00m websockets\u001b[38;5;241m.\u001b[39mconnect(ws_url) \u001b[38;5;28;01mas\u001b[39;00m websocket:\n\u001b[1;32m     46\u001b[0m     \u001b[38;5;28;01mwhile\u001b[39;00m \u001b[38;5;28;01mTrue\u001b[39;00m:\n\u001b[0;32m---> 47\u001b[0m         message \u001b[38;5;241m=\u001b[39m \u001b[38;5;28;01mawait\u001b[39;00m websocket\u001b[38;5;241m.\u001b[39mrecv()\n\u001b[1;32m     48\u001b[0m         message \u001b[38;5;241m=\u001b[39m json\u001b[38;5;241m.\u001b[39mloads(message)\n\u001b[1;32m     49\u001b[0m         \u001b[38;5;28;01mif\u001b[39;00m message\u001b[38;5;241m.\u001b[39mget(\u001b[38;5;124m\"\u001b[39m\u001b[38;5;124mdata\u001b[39m\u001b[38;5;124m\"\u001b[39m):\n",
+      "File \u001b[0;32m~/.pyenv/versions/3.10.12/lib/python3.10/site-packages/websockets/asyncio/connection.py:322\u001b[0m, in \u001b[0;36mConnection.recv\u001b[0;34m(self, decode)\u001b[0m\n\u001b[1;32m    318\u001b[0m     \u001b[38;5;66;03m# fallthrough\u001b[39;00m\n\u001b[1;32m    319\u001b[0m \n\u001b[1;32m    320\u001b[0m \u001b[38;5;66;03m# Wait for the protocol state to be CLOSED before accessing close_exc.\u001b[39;00m\n\u001b[1;32m    321\u001b[0m \u001b[38;5;28;01mawait\u001b[39;00m asyncio\u001b[38;5;241m.\u001b[39mshield(\u001b[38;5;28mself\u001b[39m\u001b[38;5;241m.\u001b[39mconnection_lost_waiter)\n\u001b[0;32m--> 322\u001b[0m \u001b[38;5;28;01mraise\u001b[39;00m \u001b[38;5;28mself\u001b[39m\u001b[38;5;241m.\u001b[39mprotocol\u001b[38;5;241m.\u001b[39mclose_exc \u001b[38;5;28;01mfrom\u001b[39;00m\u001b[38;5;250m \u001b[39m\u001b[38;5;21;01mself\u001b[39;00m\u001b[38;5;21;01m.\u001b[39;00m\u001b[38;5;21;01mrecv_exc\u001b[39;00m\n",
+      "\u001b[0;31mConnectionClosedError\u001b[0m: received 1012 (service restart); then sent 1012 (service restart)"
+     ]
     }
    ],
    "source": [