summaryrefslogtreecommitdiff
path: root/src/queue/processors/export-blocking.ts
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2019-02-10 11:44:08 +0900
committersyuilo <syuilotan@yahoo.co.jp>2019-02-10 11:44:08 +0900
commit310371658bef90e8c982eaf94eea99c63617d7ab (patch)
treefd8ffbedc1d2424f128f08c0d85d61a4846bdac9 /src/queue/processors/export-blocking.ts
parentHide unusable follow buttons (#4208) (diff)
downloadsharkey-310371658bef90e8c982eaf94eea99c63617d7ab.tar.gz
sharkey-310371658bef90e8c982eaf94eea99c63617d7ab.tar.bz2
sharkey-310371658bef90e8c982eaf94eea99c63617d7ab.zip
重いのでジョブキュー無効化
Diffstat (limited to 'src/queue/processors/export-blocking.ts')
-rw-r--r--src/queue/processors/export-blocking.ts4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/queue/processors/export-blocking.ts b/src/queue/processors/export-blocking.ts
index 95465a5e51..b30d8e3bc8 100644
--- a/src/queue/processors/export-blocking.ts
+++ b/src/queue/processors/export-blocking.ts
@@ -48,7 +48,7 @@ export async function exportBlocking(job: bq.Job, done: any): Promise<void> {
if (blockings.length === 0) {
ended = true;
- job.reportProgress(100);
+ if (job.reportProgress) job.reportProgress(100);
break;
}
@@ -74,7 +74,7 @@ export async function exportBlocking(job: bq.Job, done: any): Promise<void> {
blockerId: user._id,
});
- job.reportProgress(exportedCount / total);
+ if (job.reportProgress) job.reportProgress(exportedCount / total);
}
stream.end();