Handle cases for first submissions for the task

src/submission_uploader.py

@@ -90,6 +90,9 @@ class SubmissionUploader:
         with open(os.path.join(temp_directory, "request_metadata.json"), "w") as f:
             json.dump(request_metadata, f)
 
+        if task_id not in self._fs.ls(f"datasets/{self._private_dataset_id}"):
+            self._fs.makedirs(f"datasets/{self._private_dataset_id}/{task_id}", exist_ok=True)
+
         num_requests_already_present = len(self._fs.ls(f"datasets/{self._private_dataset_id}/{task_id}/"))
         commit_operations = [
             CommitOperationAdd(
@@ -236,6 +239,14 @@ class SubmissionUploader:
 
             task_id = TASKS_PRETTY_REVERSE[task_pretty]
 
+            if (
+                task_id not in self._fs.ls(f"datasets/{self._dataset_id}")
+                or "predictions" not in self._fs.ls(f"datasets/{self._dataset_id}/{task_id}")
+                or "results" not in self._fs.ls(f"datasets/{self._dataset_id}/{task_id}")
+            ):
+                self._fs.makedirs(f"datasets/{self._dataset_id}/{task_id}/predictions", exist_ok=True)
+                self._fs.makedirs(f"datasets/{self._dataset_id}/{task_id}/results", exist_ok=True)
+
             logging.info("Checking if this request has already been submitted...")
             if not force:
                 if model_folder in self._fs.ls(f"datasets/{self._dataset_id}/{task_id}/predictions"):