3.0.22

Author: HenryHengZJ

docker/worker/Dockerfile.worker

@@ -0,0 +1,40 @@
+# Stage 1: Build stage
+FROM node:20-alpine AS build
+
+USER root
+
+# Skip downloading Chrome for Puppeteer (saves build time)
+ENV PUPPETEER_SKIP_DOWNLOAD=true
+
+# Install latest Flowise globally (specific version can be set: flowise@1.0.0)
+RUN npm install -g flowise
+
+# Stage 2: Runtime stage
+FROM node:20-alpine
+
+# Install runtime dependencies
+RUN apk add --no-cache chromium git python3 py3-pip make g++ build-base cairo-dev pango-dev curl
+
+# Set the environment variable for Puppeteer to find Chromium
+ENV PUPPETEER_EXECUTABLE_PATH=/usr/bin/chromium-browser
+
+# Copy Flowise from the build stage
+COPY --from=build /usr/local/lib/node_modules /usr/local/lib/node_modules
+COPY --from=build /usr/local/bin /usr/local/bin
+
+# --- Healthcheck Setup ---
+WORKDIR /app/healthcheck
+
+COPY docker/worker/healthcheck/package.json . 
+
+RUN npm install --omit=dev
+
+COPY docker/worker/healthcheck/healthcheck.js .
+
+# --- End Healthcheck Setup ---
+
+# Set the main working directory 
+WORKDIR /app 
+
+# Start healthcheck in background and flowise worker in foreground
+ENTRYPOINT ["/bin/sh", "-c", "node /app/healthcheck/healthcheck.js & sleep 5 && flowise worker"]

docker/worker/healthcheck/healthcheck.js

@@ -0,0 +1,13 @@
+// docker/healthcheck/healthcheck.js
+const express = require('express')
+const app = express()
+const port = 3000
+
+app.get('/healthz', (req, res) => {
+    res.status(200).send('OK')
+})
+
+app.listen(port, () => {
+    // eslint-disable-next-line no-console
+    console.log(`Healthcheck server listening on port ${port}`)
+})

docker/worker/healthcheck/package.json

@@ -0,0 +1,13 @@
+{
+    "name": "flowise-bullmq-worker-healthcheck",
+    "version": "1.0.0",
+    "description": "Simple healthcheck server for Flowise worker",
+    "main": "healthcheck.js",
+    "private": true,
+    "scripts": {
+        "start": "node healthcheck.js"
+    },
+    "dependencies": {
+        "express": "^4.19.2"
+    }
+}

package.json

@@ -1,6 +1,6 @@
 {
     "name": "flowise-bullmq",
-    "version": "3.0.3",
+    "version": "3.0.22",
     "private": true,
     "homepage": "https://flowiseai.com",
     "workspaces": [

packages/server/package.json

@@ -1,11 +1,11 @@
 {
     "name": "flowise-bullmq",
-    "version": "3.0.3",
+    "version": "3.0.22",
     "description": "Flowiseai Server",
     "main": "dist/index",
     "types": "dist/index.d.ts",
     "bin": {
-        "flowise": "./bin/run"
+        "flowise-bullmq": "./bin/run"
     },
     "files": [
         "bin",
@@ -16,7 +16,7 @@
         "oauth2.html"
     ],
     "oclif": {
-        "bin": "flowise",
+        "bin": "flowise-bullmq",
         "commands": "./dist/commands"
     },
     "scripts": {

packages/server/src/utils/logger.ts

@@ -111,6 +111,7 @@ const logger = createLogger({
     defaultMeta: {
         package: 'server'
     },
+    exitOnError: false,
     transports: [
         new transports.Console(),
         ...(!process.env.STORAGE_TYPE || process.env.STORAGE_TYPE === 'local'
@@ -152,7 +153,11 @@ const logger = createLogger({
                   })
               ]
             : []),
-        ...(process.env.STORAGE_TYPE === 'gcs' ? [gcsErrorStream] : [])
+        ...(process.env.STORAGE_TYPE === 'gcs' ? [gcsErrorStream] : []),
+        // Always provide a fallback rejection handler when no other handlers are configured
+        ...((!process.env.DEBUG || process.env.DEBUG !== 'true') && process.env.STORAGE_TYPE !== 's3' && process.env.STORAGE_TYPE !== 'gcs'
+            ? [new transports.Console()]
+            : [])
     ]
 })