Function finish

lib/workers.js:54–76

(callback)

    },

    finish(callback) {
        debug('finish()');
        if (!config.useWorkers) {
            callback(null);
            return;
        }
        const testFinished = () => {
            if (availablePythonCallers.length < pythonCallers.length) {
                // keep waiting for all pythonCallers to be returned
                debug('finish(): waiting for availablePythonCallers');
                setTimeout(testFinished, 100);
            } else {
                debug('finish(): calling done() on all pythonCallers');
                for (let i = 0; i < pythonCallers.length; i++) {
                    pythonCallers[i].done();
                }
                pythonCallers = [];
                availablePythonCallers = [];
                return callback(null);
            }
        };
        testFinished();
    },

    getPythonCaller(callback) {
        debug('getPythonCaller()');