From 71e3dfda4e2bcc228415c0d66b09a84bb73dddd1 Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Wed, 9 May 2018 09:08:22 +0200 Subject: Add timeout and TTL to request jobs --- server/lib/job-queue/handlers/activitypub-http-fetcher.ts | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'server/lib/job-queue/handlers/activitypub-http-fetcher.ts') diff --git a/server/lib/job-queue/handlers/activitypub-http-fetcher.ts b/server/lib/job-queue/handlers/activitypub-http-fetcher.ts index 062211c85..4683beb2f 100644 --- a/server/lib/job-queue/handlers/activitypub-http-fetcher.ts +++ b/server/lib/job-queue/handlers/activitypub-http-fetcher.ts @@ -1,7 +1,7 @@ import * as kue from 'kue' import { logger } from '../../../helpers/logger' import { doRequest } from '../../../helpers/requests' -import { ACTIVITY_PUB } from '../../../initializers' +import { ACTIVITY_PUB, JOB_REQUEST_TIMEOUT } from '../../../initializers' import { processActivities } from '../../activitypub/process' import { ActivitypubHttpBroadcastPayload } from './activitypub-http-broadcast' @@ -18,7 +18,8 @@ async function processActivityPubHttpFetcher (job: kue.Job) { method: 'GET', uri: '', json: true, - activityPub: true + activityPub: true, + timeout: JOB_REQUEST_TIMEOUT } for (const uri of payload.uris) { -- cgit v1.2.3