summaryrefslogtreecommitdiff
path: root/src/queue
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2020-01-30 05:56:14 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2020-01-30 05:56:14 +0900
commit96648b651eaab8b37dc809ec48acb09bce834ea1 (patch)
tree9eeaa7d70e9c13c48b75b58e73290e342f6d5a92 /src/queue
parentFix bug (diff)
downloadsharkey-96648b651eaab8b37dc809ec48acb09bce834ea1.tar.gz
sharkey-96648b651eaab8b37dc809ec48acb09bce834ea1.tar.bz2
sharkey-96648b651eaab8b37dc809ec48acb09bce834ea1.zip
isMarkedAsClosed --> isSuspended
Diffstat (limited to 'src/queue')
-rw-r--r--src/queue/processors/deliver.ts10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/queue/processors/deliver.ts b/src/queue/processors/deliver.ts
index 980ca3a437..16b2f6e29a 100644
--- a/src/queue/processors/deliver.ts
+++ b/src/queue/processors/deliver.ts
@@ -21,15 +21,15 @@ export default async (job: Bull.Job) => {
return 'skip (blocked)';
}
- // closedなら中断
- const closedHosts = await Instances.find({
+ // isSuspendedなら中断
+ const suspendedHosts = await Instances.find({
where: {
- isMarkedAsClosed: true
+ isSuspended: true
},
cache: 60 * 1000
});
- if (closedHosts.map(x => x.host).includes(toPuny(host))) {
- return 'skip (closed)';
+ if (suspendedHosts.map(x => x.host).includes(toPuny(host))) {
+ return 'skip (suspended)';
}
try {