diff --git a/Jenkinsfile2 b/Jenkinsfile2 index ccaedcd8e5..5321dd8f10 100644 --- a/Jenkinsfile2 +++ b/Jenkinsfile2 @@ -400,7 +400,7 @@ pipeline { } } stage('linux test') { - agent{label "slave1_47"} + agent{label "slave1_47 || slave1_48 || slave1_49 || slave1_50 || slave1_52 || slave1_59 || slave1_63 || worker03 || slave215 || slave217 || slave219 "} options { skipDefaultCheckout() } when { changeRequest() diff --git a/docs/examples/node/websocketexample/all_type_query.js b/docs/examples/node/websocketexample/all_type_query.js index d1303d68ac..6524d35718 100644 --- a/docs/examples/node/websocketexample/all_type_query.js +++ b/docs/examples/node/websocketexample/all_type_query.js @@ -92,11 +92,9 @@ async function all_type_example() { } async function test() { - console.log("begin all_type_query") await json_tag_example() await all_type_example() taos.destroy(); - console.log("end all_type_query") } test() diff --git a/docs/examples/node/websocketexample/all_type_stmt.js b/docs/examples/node/websocketexample/all_type_stmt.js index daf26a1ff1..f095bee090 100644 --- a/docs/examples/node/websocketexample/all_type_stmt.js +++ b/docs/examples/node/websocketexample/all_type_stmt.js @@ -139,11 +139,9 @@ async function all_type_example() { } async function test() { - console.log("begin all_type_stmt") await json_tag_example() await all_type_example() taos.destroy(); - console.log("end all_type_stmt") } test() diff --git a/docs/examples/node/websocketexample/line_example.js b/docs/examples/node/websocketexample/line_example.js index 4c051bc7c5..97570475b0 100644 --- a/docs/examples/node/websocketexample/line_example.js +++ b/docs/examples/node/websocketexample/line_example.js @@ -16,7 +16,7 @@ async function createConnect() { } -async function schemalessInsert() { +async function test() { let wsSql = null; let wsRows = null; let ttl = 0; @@ -42,10 +42,4 @@ async function schemalessInsert() { } } -async function test() { - console.log("begin line_example") - await schemalessInsert(); - console.log("end line_example") -} - test() diff --git a/docs/examples/node/websocketexample/nodejsChecker.js b/docs/examples/node/websocketexample/nodejsChecker.js index 02133d524a..9f1d40f0cc 100644 --- a/docs/examples/node/websocketexample/nodejsChecker.js +++ b/docs/examples/node/websocketexample/nodejsChecker.js @@ -22,7 +22,7 @@ async function createConnect() { return await taos.sqlConnect(conf); } -async function execSql() { +async function test() { let wsSql = null; let wsRows = null; let reqId = 0; @@ -60,7 +60,7 @@ async function execSql() { } catch (err) { console.error(err.code, err.message); - process.exitCode = 1; + throw err; } finally { if (wsRows) { @@ -73,10 +73,4 @@ async function execSql() { } } -async function test() { - console.log("begin nodejsChecker") - await execSql(); - console.log("end nodejsChecker") -} - test() \ No newline at end of file diff --git a/docs/examples/node/websocketexample/sql_example.js b/docs/examples/node/websocketexample/sql_example.js index 080b21bba1..0a09228d97 100644 --- a/docs/examples/node/websocketexample/sql_example.js +++ b/docs/examples/node/websocketexample/sql_example.js @@ -136,13 +136,11 @@ async function sqlWithReqid() { // ANCHOR_END: sqlWithReqid async function test() { - console.log("begin sql_example") await createDbAndTable(); await insertData(); await queryData(); await sqlWithReqid(); taos.destroy(); - console.log("end sql_example") } test() diff --git a/docs/examples/node/websocketexample/stmt_example.js b/docs/examples/node/websocketexample/stmt_example.js index 098b6e1e99..6f98bb7974 100644 --- a/docs/examples/node/websocketexample/stmt_example.js +++ b/docs/examples/node/websocketexample/stmt_example.js @@ -23,7 +23,7 @@ async function prepare() { return wsSql } -async function stmtInsert() { +async function test() { let stmt = null; let connector = null; try { @@ -73,10 +73,4 @@ async function stmtInsert() { } } -async function test () { - console.log("begin stmt_example") - await stmtInsert(); - console.log("end stmt_example") -} - test() \ No newline at end of file diff --git a/docs/examples/node/websocketexample/tmq_example.js b/docs/examples/node/websocketexample/tmq_example.js index c16afa955b..4f7f099c31 100644 --- a/docs/examples/node/websocketexample/tmq_example.js +++ b/docs/examples/node/websocketexample/tmq_example.js @@ -86,7 +86,7 @@ async function subscribe(consumer) { // ANCHOR_END: commit } -async function consumer() { +async function test() { // ANCHOR: unsubscribe let consumer = null; try { @@ -113,10 +113,4 @@ async function consumer() { // ANCHOR_END: unsubscribe } -async function test() { - console.log("begin tmq_example") - await consumer(); - console.log("end tmq_example") -} - test() diff --git a/docs/examples/node/websocketexample/tmq_seek_example.js b/docs/examples/node/websocketexample/tmq_seek_example.js index 8f00e4230d..f676efe36f 100644 --- a/docs/examples/node/websocketexample/tmq_seek_example.js +++ b/docs/examples/node/websocketexample/tmq_seek_example.js @@ -82,7 +82,7 @@ async function subscribe(consumer) { } // ANCHOR_END: offset -async function consumer() { +async function test() { let consumer = null; try { await prepare(); @@ -107,10 +107,4 @@ async function consumer() { } } -async function test() { - console.log("begin tmq_example") - await consumer(); - console.log("end tmq_example") -} - test()