summaryrefslogtreecommitdiff
path: root/src/queue/index.ts
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2019-07-01 21:12:14 +0900
committersyuilo <syuilotan@yahoo.co.jp>2019-07-01 21:12:14 +0900
commit03e999875a7678c0e5293b87397ab67040010eeb (patch)
tree6451269e48a08baf562e6e57909df33ae95b708a /src/queue/index.ts
parentSet job concurrency to reduce performance issue (diff)
downloadsharkey-03e999875a7678c0e5293b87397ab67040010eeb.tar.gz
sharkey-03e999875a7678c0e5293b87397ab67040010eeb.tar.bz2
sharkey-03e999875a7678c0e5293b87397ab67040010eeb.zip
リモートファイルの削除が重い問題を修正
Diffstat (limited to 'src/queue/index.ts')
-rw-r--r--src/queue/index.ts7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/queue/index.ts b/src/queue/index.ts
index 70233d8318..a7e9b9814f 100644
--- a/src/queue/index.ts
+++ b/src/queue/index.ts
@@ -194,6 +194,13 @@ export function createDeleteObjectStorageFileJob(key: string) {
});
}
+export function createCleanRemoteFilesJob() {
+ return objectStorageQueue.add('cleanRemoteFiles', {}, {
+ removeOnComplete: true,
+ removeOnFail: true
+ });
+}
+
export default function() {
if (!program.onlyServer) {
deliverQueue.process(128, processDeliver);