Function runTask

js/botasaurus-js/src/task.ts:76–169

(
            data: any,
            retryAttempt: number
        )

        }

        async function runTask(
            data: any,
            retryAttempt: number
        ): Promise<any> {
            let path: string | undefined

            if (cache === true) {
                path = _getCachePath(fn_name, data)
                if (_has(path)) {
                    try {
                        return _get(path)
                    } catch (error) {
                        if (!(error instanceof CacheMissException)) throw error
                    }
                }
            } else if (cache === 'REFRESH') {
                path = _getCachePath(fn_name, data)
            }

            let result: any
            try {
                result = await run({ data, metadata, taskId, parentTaskId, isAborted, pushData })
                if (result === undefined) {
                    result = null
                }

                if (cache === true || cache === 'REFRESH') {
                    if (isDontCache(result)) {
                        _remove(path!)
                    } else {
                        writeJson(result, path!)
                    }
                }

                if (isDontCache(result)) {
                    if (!returnDontCacheAsIs) {
                        result = result.data
                    }
                }
                return result
            } catch (error) {
                if (error instanceof NotFoundException && !error.raisedOnce) {
                    if (error.raiseMaximum1Time) {
                        error.raisedOnce = true
                    }
                    throw error
                } else if (mustRaiseExceptions &&
                    isErrorsInstance(mustRaiseExceptions, error)[0]) {
                    if (createErrorLogs) {
                        saveErrorLogs(formatExc(error), data)
                    }
                    throw error
                }

                if (maxRetry !== undefined && maxRetry !== null && maxRetry > retryAttempt) {
                    printExc(error)
                    if (retryWait) {
                        console.log(`Waiting for ${retryWait} seconds`)