no message

build/xxl_job/job_manager.js

@@ -89,6 +89,13 @@ class JobManager {
                 }), executorTimeout * 1000);
             }
             result = await jobHandler(jobParams, this.context);
+            if (result && result.err) {
+                error = result.err;
+                delete result.err;
+                if (Object.keys(result).length === 0) {
+                    result = null;
+                }
+            }
         }
         catch (err) {
             error = err;

src/xxl_job/job_manager.ts

@@ -107,6 +107,14 @@ export class JobManager {
 
       result = await jobHandler(jobParams, this.context);
 
+      if (result && result.err) {
+        error = result.err
+        delete result.err
+        if (Object.keys(result).length === 0) {
+          result = null
+        }
+      }
+
     } catch (err) {
       error = err
     }