From 6b2494a5bcf5ac0df15dc1eb9aad4fe403e10db9 Mon Sep 17 00:00:00 2001
From: Naz <nazargargol@gmail.com>
Date: Wed, 3 Mar 2021 12:26:37 +1300
Subject: [PATCH] Bumped bree to 6.2.0

refs https://github.com/TryGhost/Utils/commit/55060e323c44faacc6b82b44a8d2673a072b8efc

- This bump was meant to be done when the referenced changes landed. Without it parts of worker thread messages are lost
---
 ghost/job-manager/package.json             | 2 +-
 ghost/job-manager/test/job-manager.test.js | 2 +-
 ghost/job-manager/test/jobs/message.js     | 3 ++-
 3 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/ghost/job-manager/package.json b/ghost/job-manager/package.json
index 9467936ce1..d6f39ae911 100644
--- a/ghost/job-manager/package.json
+++ b/ghost/job-manager/package.json
@@ -28,7 +28,7 @@
   },
   "dependencies": {
     "@breejs/later": "4.0.2",
-    "bree": "4.1.1",
+    "bree": "6.2.0",
     "cron-validate": "1.4.2",
     "fastq": "1.10.1",
     "p-wait-for": "3.2.0"
diff --git a/ghost/job-manager/test/job-manager.test.js b/ghost/job-manager/test/job-manager.test.js
index b0f0d94d9b..d8cfbbb214 100644
--- a/ghost/job-manager/test/job-manager.test.js
+++ b/ghost/job-manager/test/job-manager.test.js
@@ -243,7 +243,7 @@ describe('Job Manager', function () {
 
                 should(workerMessageHandlerSpy.called).be.true();
                 should(workerMessageHandlerSpy.args[0][0].name).equal('will-send-msg');
-                should(workerMessageHandlerSpy.args[0][0].message).equal('hello from Ghost!');
+                should(workerMessageHandlerSpy.args[0][0].message).equal('Worker received: hello from Ghost!');
             });
         });
     });
diff --git a/ghost/job-manager/test/jobs/message.js b/ghost/job-manager/test/jobs/message.js
index 09fc27be73..03550550e9 100644
--- a/ghost/job-manager/test/jobs/message.js
+++ b/ghost/job-manager/test/jobs/message.js
@@ -13,7 +13,8 @@ if (parentPort) {
             return;
         }
 
-        parentPort.postMessage(message);
+        // post the message back
+        parentPort.postMessage(`Worker received: ${message}`);
         process.exit(0);
     });
 }