no message

build/job/test/index.js

@@ -10,19 +10,21 @@ const common_1 = require("../../libs/common");
  * @return {Promise<void>} 函数必须返回一个 promise
  */
 async function demoJobHandler(jobLogger, jobParams, context) {
-    jobLogger.debug('params: %o, context: %o', jobParams, context);
+    // jobLogger.debug('params: %o, context: %o', jobParams, context)
     for (let i = 1; i < 10; i++) {
         await (0, common_1.sleep)(1000);
         jobLogger.debug(`${i}s passed`);
     }
+    return { result: 'return value' };
 }
 exports.demoJobHandler = demoJobHandler;
 async function demo_test(jobLogger, jobParams, context) {
-    jobLogger.debug('params: %o, context: %o', jobParams, context);
-    for (let i = 1; i < 10; i++) {
+    // jobLogger.debug('params: %o, context: %o', jobParams, context)
+    for (let i = 1; i < 5; i++) {
         await (0, common_1.sleep)(1000);
         jobLogger.debug(`${i}s passed`);
     }
+    return { result: 'return value' };
 }
 exports.demo_test = demo_test;
 //# sourceMappingURL=index.js.map
\ No newline at end of file

src/job/test/index.ts

@@ -8,21 +8,24 @@ import { sleep } from '../../libs/common'
  */
 
 export async function demoJobHandler(jobLogger, jobParams, context) {
-    jobLogger.debug('params: %o, context: %o', jobParams, context)
+    // jobLogger.debug('params: %o, context: %o', jobParams, context)
 
     for (let i = 1; i < 10; i++) {
         await sleep(1000)
         jobLogger.debug(`${i}s passed`)
     }
 
+    return { result: 'return value' };
 }
 
 export async function demo_test(jobLogger, jobParams, context) {
-    jobLogger.debug('params: %o, context: %o', jobParams, context)
+    // jobLogger.debug('params: %o, context: %o', jobParams, context)
 
-    for (let i = 1; i < 10; i++) {
+    for (let i = 1; i < 5; i++) {
         await sleep(1000)
         jobLogger.debug(`${i}s passed`)
     }
 
+    return { result: 'return value' };
+
 }