Make sure manifest contains taskdata

basemodels/manifest/manifest.py

@@ -20,15 +20,6 @@
 from basemodels.constants import JOB_TYPES_FOR_CONTENT_TYPE_VALIDATION
 
 
-# Validator function for taskdata and taskdata_uri fields
-def validator_taskdata_uri(cls, value, values, **kwargs):
-    taskdata = values.get("taskdata")
-    taskdata_uri = values.get("taskdata_uri")
-    if taskdata is not None and len(taskdata) > 0 and taskdata_uri is not None:
-        raise ValidationError("Specify only one of taskdata {} or taskdata_uri {}".format(taskdata, taskdata_uri))
-    return value
-
-
 # A validator function for UUID fields
 def validate_uuid(cls, value):
     return value or uuid.uuid4()
@@ -330,6 +321,14 @@ class Manifest(Model):
     def validate(cls, values: Dict[str, Any]) -> Dict[str, Any]:
         start_date = values["start_date"]
         expiration_date = values["expiration_date"]
+        # validate at least taskdata or taskdata_uri is present
+        taskdata = values.get("taskdata")
+        taskdata_uri = values.get("taskdata_uri")
+        if taskdata is not None and len(taskdata) > 0 and taskdata_uri is not None:
+            raise ValueError("Specify only one of taskdata {} or taskdata_uri {}".format(taskdata, taskdata_uri))
+        if taskdata is None and taskdata_uri is None:
+            raise ValueError("No taskdata or taskdata_uri found in manifest")
+
         if not start_date and not expiration_date:
             # Timestamps are not passed
             return values
@@ -398,8 +397,6 @@ def validate_requester_question_example(cls, value, values, **kwargs):
             raise ValueError("Lists are not allowed in this challenge type")
         return value
 
-    validate_taskdata_uri = validator("taskdata_uri", allow_reuse=True, always=True)(validator_taskdata_uri)
-    validate_taskdata = validator("taskdata", allow_reuse=True, always=True)(validator_taskdata_uri)
     validate_request_type = validator("request_type", allow_reuse=True, always=True)(RequestTypeValidator().validate)
     validate_job_api_key = validator("job_api_key", always=True, allow_reuse=True)(validate_uuid)
     validate_job_id = validator("job_id", always=True, allow_reuse=True)(validate_uuid)

tests/test_manifest_validation.py

@@ -196,6 +196,13 @@ def test_can_fail_toconstruct2(self):
         mani.taskdata_uri = "test"
         self.assertRaises(ValidationError, validate_func(mani))
 
+    def test_manifest_must_contain_taskdata(self):
+        """Tests that manifest raises error when there is no taskdata"""
+        manifest = get_data()
+        manifest["taskdata_uri"] = None
+        with self.assertRaises(ValidationError):
+            basemodels.manifest.Manifest(**manifest)
+
     def test_can_make_request_config_job(self):
         """Test that jobs with valid request_config parameter work"""
         manifest = a_manifest(

tests/test_restricted_answer_set.py

@@ -13,6 +13,7 @@
     "recording_oracle_addr": "0x6a0E68eA5F706339dd6bd354F53EfcB5B9e53E49",
     "reputation_oracle_addr": "0x6a0E68eA5F706339dd6bd354F53EfcB5B9e53E49",
     "reputation_agent_addr": "0x6a0E68eA5F706339dd6bd354F53EfcB5B9e53E49",
+    "taskdata_uri": "http://google.com/fake",
 }
 
 NESTED_MANIFEST_VALUES = {