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

specs/ingestion/common/schemas/task.yml

@@ -553,3 +553,6 @@ ShopifyMarket:
     - countries
     - currencies
     - locales
+
+PushTaskResponse:
+  $ref: './source.yml#/SourceWatchResponse'

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/task.yml#/PushTaskResponse'
     '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
+    PushTaskResponse 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);
 }

templates/kotlin/guides/ingestion/pushSetup.mustache

@@ -18,10 +18,10 @@ suspend fun main() {
     {{> snippets/init}}
 
     try {
-        val run = client.{{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
+        // setting `watch` to `true` will make the call synchronous
+        val resp = client.{{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
 
-        // use runID in the Observability debugger
-        println(run)
+        println(resp)
     } catch(e: Exception) {
         println(e.message)
     }

templates/php/guides/ingestion/pushSetup.mustache

@@ -7,7 +7,7 @@ $records = json_decode(file_get_contents("records.json"), true);
 // use the region matching your applicationID
 {{> snippets/init}}
 
-$run = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}};
+// setting `watch` to `true` will make the call synchronous
+$resp = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}};
 
-// use runID in the Observability debugger
-print($run);
+print($resp);

templates/python/guides/ingestion/pushSetup.mustache

@@ -10,9 +10,9 @@ async def main():
     with open("records.json") as f:
         records = json.load(f)
 
-        run = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
+        # setting `watch` to `true` will make the call synchronous
+        resp = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
 
-        # use runID in the Observability debugger
-        print(run.run_id)
+        print(resp)
 
 asyncio.run(main())

templates/ruby/guides/ingestion/pushSetup.mustache

@@ -6,7 +6,7 @@ records = JSON.parse(File.read('records.json'))
 # use the region matching your applicationID
 {{> snippets/init}}
 
-run = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
+# setting `watch` to `true` will make the call synchronous
+resp = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
 
-# use runID in the Observability debugger
-puts run.run_id
+puts resp

templates/scala/guides/ingestion/pushSetup.mustache

@@ -21,13 +21,13 @@ object PushSetup {
     {{> snippets/init}}
 
     try {
-      val run = Await.result(
+      // setting `watch` to `true` will make the call synchronous
+      val resp = Await.result(
         {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}},
         Duration(100, "sec")
       )
 
-      // use runID in the Observability debugger
-      println(run.runID)
+      println(resp)
     } catch {
       case e: Exception => println(e)
     }

templates/swift/guides/ingestion/pushSetup.mustache

@@ -16,10 +16,10 @@ func pushSetup() async throws {
         // use the region matching your applicationID
         {{> snippets/init}}
 
-        let run = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
+        // setting `watch` to `true` will make the call synchronous
+        let resp = {{#dynamicSnippet}}pushSetup{{/dynamicSnippet}}
 
-        // use runID in the Observability debugger
-        dump(run)
+        dump(resp)
     } catch {
         print(error)
     }

tests/CTS/guides/ingestion.json

@@ -6,7 +6,8 @@
       "pushTaskPayload": {
         "action": "addObject",
         "records": "$var: records" 
-      }
+      },
+      "watch": true
     }
   }
 }