feat(specs): add notification settings to tasks [skip-bc] (#4297)

Author: millotp

specs/ingestion/common/schemas/task.yml

@@ -26,6 +26,10 @@ Task:
       $ref: '#/ActionType'
     cursor:
       $ref: './common.yml#/cursor'
+    notifications:
+      $ref: '#/Notifications'
+    policies:
+      $ref: '#/Policies'
     createdAt:
       $ref: './common.yml#/createdAt'
     updatedAt:
@@ -63,6 +67,10 @@ TaskV1:
       $ref: '#/ActionType'
     cursor:
       $ref: './common.yml#/cursor'
+    notifications:
+      $ref: '#/Notifications'
+    policies:
+      $ref: '#/Policies'
     createdAt:
       $ref: './common.yml#/createdAt'
     updatedAt:
@@ -105,6 +113,10 @@ TaskCreate:
       $ref: '#/TaskInput'
     cursor:
       $ref: './common.yml#/cursor'
+    notifications:
+      $ref: '#/Notifications'
+    policies:
+      $ref: '#/Policies'
   required:
     - sourceID
     - destinationID
@@ -175,6 +187,10 @@ TaskUpdate:
       description: Whether the task is enabled.
     failureThreshold:
       $ref: '#/failureThreshold'
+    notifications:
+      $ref: '#/Notifications'
+    policies:
+      $ref: '#/Policies'
 
 TaskUpdateV1:
   type: object
@@ -553,3 +569,30 @@ ShopifyMarket:
     - countries
     - currencies
     - locales
+
+Notifications:
+  type: object
+  additionalProperties: false
+  description: Notifications settings for a task.
+  properties:
+    email:
+      title: emailNotifications
+      type: object
+      additionalProperties: false
+      properties:
+        enabled:
+          description: Whether to send email notifications, note that this doesn't prevent the task from being blocked.
+          type: boolean
+  required:
+    - email
+
+Policies:
+  type: object
+  additionalProperties: false
+  description: Set of rules for a task.
+  properties:
+    criticalThreshold:
+      description: The number of critical failures in a row before blocking the task and sending a notification.
+      type: integer
+      minimum: 1
+      maximum: 10

specs/ingestion/common/taskParameters.yml

@@ -70,6 +70,14 @@ triggerType:
       $ref: './schemas/task.yml#/TriggerType'
     example: onDemand,schedule,subscription,streaming
 
+withEmailNotifications:
+  name: withEmailNotifications
+  in: query
+  description: If specified, the response only includes tasks with notifications.email.enabled set to this value.
+  required: false
+  schema:
+    type: boolean
+
 sort:
   name: sort
   in: query

specs/ingestion/paths/tasks/v2/tasks.yml

@@ -17,6 +17,7 @@ get:
     - $ref: '../../../common/taskParameters.yml#/sourceType'
     - $ref: '../../../common/taskParameters.yml#/destinationID'
     - $ref: '../../../common/taskParameters.yml#/triggerType'
+    - $ref: '../../../common/taskParameters.yml#/withEmailNotifications'
     - $ref: '../../../common/taskParameters.yml#/sort'
     - $ref: '../../../common/parameters.yml#/order'
   responses:

tests/CTS/requests/ingestion/createTask.json

@@ -22,7 +22,15 @@
       "sourceID": "search",
       "destinationID": "destinationName",
       "cron": "* * * * *",
-      "action": "replace"
+      "action": "replace",
+      "notifications": {
+        "email": {
+          "enabled": true
+        }
+      },
+      "policies": {
+        "criticalThreshold": 8
+      }
     },
     "request": {
       "path": "/2/tasks",
@@ -31,7 +39,15 @@
         "sourceID": "search",
         "destinationID": "destinationName",
         "cron": "* * * * *",
-        "action": "replace"
+        "action": "replace",
+        "notifications": {
+          "email": {
+            "enabled": true
+          }
+        },
+        "policies": {
+          "criticalThreshold": 8
+        }
       }
     }
   },