fix(specs): ingestion docker task input (#3488)

Author: shortcuts

specs/ingestion/common/schemas/task.yml

@@ -460,10 +460,34 @@ DockerStreamsInput:
   type: object
   properties:
     streams:
-      type: object
+      type: array
+      items: 
+        $ref: '#/DockerStreams'
   required:
     - streams
 
+DockerStreams:
+  type: object
+  properties:
+    name:
+      type: string
+      description: The name of the stream to fetch the data from (e.g. table name).
+    properties:
+      type: array
+      description: The properties of the stream to select (e.g. column).
+      items:
+        type: string
+    syncMode:
+      $ref: '#/DockerStreamsSyncMode'
+  required:
+    - name
+    - syncMode
+
+DockerStreamsSyncMode:
+  type: string
+  description: The strategy to use to fetch the data.
+  enum: [incremental, fullTable]
+
 failureThreshold:
   type: integer
   minimum: 0

specs/ingestion/paths/transformations/transformationsTry.yml

@@ -3,7 +3,7 @@ post:
     - transformations
   summary: Try a transformation
   description: Try a transformation.
-  operationId: tryTransformations
+  operationId: tryTransformation
   x-acl:
     - addObject
     - deleteIndex

tests/CTS/requests/ingestion/createTask.json

@@ -34,5 +34,40 @@
         "action": "replace"
       }
     }
+  },
+  {
+    "testName": "task shopify",
+    "parameters": {
+      "sourceID": "search",
+      "destinationID": "destinationName",
+      "cron": "* * * * *",
+      "action": "replace",
+      "input": {
+        "streams": [
+          {
+            "name": "foo",
+            "syncMode": "incremental"
+          }
+        ]
+      }
+    },
+    "request": {
+      "path": "/2/tasks",
+      "method": "POST",
+      "body": {
+        "sourceID": "search",
+        "destinationID": "destinationName",
+        "cron": "* * * * *",
+        "action": "replace",
+        "input": {
+          "streams": [
+            {
+              "name": "foo",
+              "syncMode": "incremental"
+            }
+          ]
+        }
+      }
+    }
   }
 ]

tests/CTS/requests/ingestion/createTaskV1.json

@@ -69,5 +69,44 @@
         "action": "replace"
       }
     }
+  },
+  {
+    "testName": "task shopify",
+    "parameters": {
+      "sourceID": "search",
+      "destinationID": "destinationName",
+      "trigger": {
+        "type": "onDemand"
+      },
+      "action": "replace",
+      "input": {
+        "streams": [
+          {
+            "name": "foo",
+            "syncMode": "incremental"
+          }
+        ]
+      }
+    },
+    "request": {
+      "path": "/1/tasks",
+      "method": "POST",
+      "body": {
+        "sourceID": "search",
+        "destinationID": "destinationName",
+        "trigger": {
+          "type": "onDemand"
+        },
+        "action": "replace",
+        "input": {
+          "streams": [
+            {
+              "name": "foo",
+              "syncMode": "incremental"
+            }
+          ]
+        }
+      }
+    }
   }
 ]