fix(specs): enable watcher for push [skip-bc] (#4229)

Author: shortcuts

specs/ingestion/common/schemas/common.yml

@@ -96,3 +96,25 @@ Window:
   required:
     - startDate
     - endDate
+
+WatchResponse:
+  type: object
+  additionalProperties: false
+  properties:
+    runID:
+      $ref: './common.yml#/runID'
+    data:
+      type: array
+      description: when used with discovering or validating sources, the sampled data of your source is returned.
+      items:
+        type: object
+    events:
+      description: in case of error, observability events will be added to the response, if any.
+      type: array
+      items:
+        $ref: '../../common/schemas/event.yml#/Event'
+    message:
+      description: a message describing the outcome of a validate run.
+      type: string
+  required:
+    - message

specs/ingestion/common/schemas/source.yml

@@ -476,28 +476,6 @@ sourceShopifyBase:
   x-discriminator-fields:
     - shopURL
 
-SourceWatchResponse:
-  type: object
-  additionalProperties: false
-  properties:
-    runID:
-      $ref: './common.yml#/runID'
-    data:
-      type: array
-      description: depending on the source type, the validation returns sampling data of your source (JSON, CSV, BigQuery).
-      items:
-        type: object
-    events:
-      description: in case of error, observability events will be added to the response, if any.
-      type: array
-      items:
-        $ref: '../../common/schemas/event.yml#/Event'
-    message:
-      description: a message describing the outcome of a validate run.
-      type: string
-  required:
-    - message
-
 RunSourcePayload:
   type: object
   additionalProperties: false

specs/ingestion/paths/sources/discover.yml

@@ -18,6 +18,6 @@ post:
       content:
         application/json:
           schema:
-            $ref: '../../common/schemas/source.yml#/SourceWatchResponse'
+            $ref: '../../common/schemas/common.yml#/WatchResponse'
     '400':
       $ref: '../../../common/responses/BadRequest.yml'

specs/ingestion/paths/sources/validate.yml

@@ -21,6 +21,6 @@ post:
       content:
         application/json:
           schema:
-            $ref: '../../common/schemas/source.yml#/SourceWatchResponse'
+            $ref: '../../common/schemas/common.yml#/WatchResponse'
     '400':
       $ref: '../../../common/responses/BadRequest.yml'

specs/ingestion/paths/sources/validateID.yml

@@ -23,6 +23,6 @@ post:
       content:
         application/json:
           schema:
-            $ref: '../../common/schemas/source.yml#/SourceWatchResponse'
+            $ref: '../../common/schemas/common.yml#/WatchResponse'
     '400':
       $ref: '../../../common/responses/BadRequest.yml'

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

@@ -47,6 +47,6 @@ post:
       content:
         application/json:
           schema:
-            $ref: '../../../common/schemas/run.yml#/RunResponse'
+            $ref: '../../../common/schemas/common.yml#/WatchResponse'
     '400':
       $ref: '../../../../common/responses/BadRequest.yml'

templates/csharp/guides/ingestion/pushSetup.mustache

@@ -20,8 +20,10 @@ class PushSetup
 
         try
         {
-            var run = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}};
-            Console.WriteLine(run.RunID);
+            // setting `watch` to `true` will make the call synchronous
+            var resp = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}};
+
+            Console.WriteLine(resp);
         }
         catch (Exception e)
         {

templates/go/guides/ingestion/pushSetup.mustache

@@ -26,11 +26,11 @@ func push() {
     panic(err)
   }
 
-  run, err := {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
+  // setting `watch` to `true` will make the call synchronous
+  resp, err := {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
   if err != nil {
     panic(err)
   }
 
-  // use runID in the Observability debugger
-  fmt.Println("run", run.RunID)
+  fmt.Printf("%#v\n", resp)
 }

templates/java/guides/ingestion/pushSetup.mustache

@@ -13,10 +13,10 @@ public class pushSetup {
     // use the region matching your applicationID
     {{> snippets/init}}
 
-    RunResponse run = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}};
+    // setting `watch` to `true` will make the call synchronous
+    WatchResponse resp = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}};
 
-    // use runID in the Observability debugger
-    System.out.println(run.getRunID());
+    System.out.println(resp);
 
     client.close();
   }

templates/javascript/guides/ingestion/pushSetup.mustache

@@ -10,11 +10,10 @@ try {
   // read local JSON file containing array of records
   const records = JSON.parse(fs.readFileSync('records.json', 'utf8')) as PushTaskRecords[];
 
-  // push records to the API
-  const run = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
+  // setting `watch` to `true` will make the call synchronous
+  const resp = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
 
-  // use runID in the Observability debugger
-  console.log(run.runID);
+  console.log(resp);
 } catch (err) {
   console.error(err);
 }