Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 | 1x 1x 14x 14x 14x 14x 14x 1x 16x 16x 16x 16x 16x 16x 16x 16x 16x 16x 16x 16x 1x 1x | const { Client, Connection } = require('@temporalio/client');
async function getTemporalClient() {
const temporalAddress = process.env.TEMPORAL_ADDRESS || 'temporal:7233';
const connection = await Connection.connect({ address: temporalAddress });
return new Client({ connection });
}
async function countRunningWorkflows(workflowType) {
const connection = await Connection.connect({ address: process.env.TEMPORAL_ADDRESS || 'temporal:7233' });
try {
const resp = await connection.workflowService.countWorkflowExecutions({
namespace: 'default',
query: `WorkflowType = '${workflowType}' and ExecutionStatus = 'Running'`,
});
return Number(resp.count);
} finally {
connection.close();
}
}
module.exports = { getTemporalClient, countRunningWorkflows }; |