diff --git a/index.js b/index.js index 4cb8566..5bd157e 100644 --- a/index.js +++ b/index.js @@ -48,7 +48,9 @@ queue.process('taskqueue', function(job, done) { console.log(`Executing ${job.id}`); const appEngineHttpRequest = job.data.task.appEngineHttpRequest; const queueName = job.data.parent.queueName; - const headers = { 'x-appengine-queuename': queueName, 'x-appengine-taskname': job.id.toString() }; + let headers = {}; + if (appEngineHttpRequest.headers) headers = { ...headers, ...appEngineHttpRequest.headers }; + headers = { ...headers, 'x-appengine-queuename': queueName, 'x-appengine-taskname': job.id.toString() } const options = { baseUrl: appEngineHttpRequest.baseUrl, method: appEngineHttpRequest.httpMethod }; if (appEngineHttpRequest.body) { options.body = Buffer.from(appEngineHttpRequest.body, 'base64').toString('utf-8');