mirror of
https://github.com/farcasclaudiu/Flowise.git
synced 2026-06-28 23:01:09 +03:00
Feature/add enable bull dashboard env var (#4373)
add enable bull dashboard env var
This commit is contained in:
@@ -101,3 +101,4 @@ BLOB_STORAGE_PATH=/root/.flowise/storage
|
|||||||
# REDIS_CERT=
|
# REDIS_CERT=
|
||||||
# REDIS_KEY=
|
# REDIS_KEY=
|
||||||
# REDIS_CA=
|
# REDIS_CA=
|
||||||
|
# ENABLE_BULLMQ_DASHBOARD=
|
||||||
|
|||||||
@@ -49,6 +49,7 @@ services:
|
|||||||
- REDIS_CERT=${REDIS_CERT}
|
- REDIS_CERT=${REDIS_CERT}
|
||||||
- REDIS_KEY=${REDIS_KEY}
|
- REDIS_KEY=${REDIS_KEY}
|
||||||
- REDIS_CA=${REDIS_CA}
|
- REDIS_CA=${REDIS_CA}
|
||||||
|
- ENABLE_BULLMQ_DASHBOARD=${ENABLE_BULLMQ_DASHBOARD}
|
||||||
ports:
|
ports:
|
||||||
- '${PORT}:${PORT}'
|
- '${PORT}:${PORT}'
|
||||||
healthcheck:
|
healthcheck:
|
||||||
|
|||||||
@@ -49,6 +49,7 @@ services:
|
|||||||
- REDIS_CERT=${REDIS_CERT}
|
- REDIS_CERT=${REDIS_CERT}
|
||||||
- REDIS_KEY=${REDIS_KEY}
|
- REDIS_KEY=${REDIS_KEY}
|
||||||
- REDIS_CA=${REDIS_CA}
|
- REDIS_CA=${REDIS_CA}
|
||||||
|
- ENABLE_BULLMQ_DASHBOARD=${ENABLE_BULLMQ_DASHBOARD}
|
||||||
ports:
|
ports:
|
||||||
- '${PORT}:${PORT}'
|
- '${PORT}:${PORT}'
|
||||||
volumes:
|
volumes:
|
||||||
|
|||||||
@@ -99,3 +99,4 @@ PORT=3000
|
|||||||
# REDIS_CERT=
|
# REDIS_CERT=
|
||||||
# REDIS_KEY=
|
# REDIS_KEY=
|
||||||
# REDIS_CA=
|
# REDIS_CA=
|
||||||
|
# ENABLE_BULLMQ_DASHBOARD=
|
||||||
|
|||||||
@@ -75,7 +75,8 @@ export abstract class BaseCommand extends Command {
|
|||||||
REDIS_TLS: Flags.string(),
|
REDIS_TLS: Flags.string(),
|
||||||
REDIS_CERT: Flags.string(),
|
REDIS_CERT: Flags.string(),
|
||||||
REDIS_KEY: Flags.string(),
|
REDIS_KEY: Flags.string(),
|
||||||
REDIS_CA: Flags.string()
|
REDIS_CA: Flags.string(),
|
||||||
|
ENABLE_BULLMQ_DASHBOARD: Flags.string()
|
||||||
}
|
}
|
||||||
|
|
||||||
protected async stopProcess() {
|
protected async stopProcess() {
|
||||||
@@ -210,5 +211,6 @@ export abstract class BaseCommand extends Command {
|
|||||||
if (flags.QUEUE_REDIS_EVENT_STREAM_MAX_LEN) process.env.QUEUE_REDIS_EVENT_STREAM_MAX_LEN = flags.QUEUE_REDIS_EVENT_STREAM_MAX_LEN
|
if (flags.QUEUE_REDIS_EVENT_STREAM_MAX_LEN) process.env.QUEUE_REDIS_EVENT_STREAM_MAX_LEN = flags.QUEUE_REDIS_EVENT_STREAM_MAX_LEN
|
||||||
if (flags.REMOVE_ON_AGE) process.env.REMOVE_ON_AGE = flags.REMOVE_ON_AGE
|
if (flags.REMOVE_ON_AGE) process.env.REMOVE_ON_AGE = flags.REMOVE_ON_AGE
|
||||||
if (flags.REMOVE_ON_COUNT) process.env.REMOVE_ON_COUNT = flags.REMOVE_ON_COUNT
|
if (flags.REMOVE_ON_COUNT) process.env.REMOVE_ON_COUNT = flags.REMOVE_ON_COUNT
|
||||||
|
if (flags.ENABLE_BULLMQ_DASHBOARD) process.env.ENABLE_BULLMQ_DASHBOARD = flags.ENABLE_BULLMQ_DASHBOARD
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -251,7 +251,7 @@ export class App {
|
|||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
if (process.env.MODE === MODE.QUEUE) {
|
if (process.env.MODE === MODE.QUEUE && process.env.ENABLE_BULLMQ_DASHBOARD === 'true') {
|
||||||
this.app.use('/admin/queues', this.queueManager.getBullBoardRouter())
|
this.app.use('/admin/queues', this.queueManager.getBullBoardRouter())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user