Skip to content
GitLab
Projects Groups Snippets
  • /
  • Help
    • Help
    • Support
    • Community forum
    • Submit feedback
    • Contribute to GitLab
  • Sign in / Register
  • B bull
  • Project information
    • Project information
    • Activity
    • Labels
    • Members
  • Repository
    • Repository
    • Files
    • Commits
    • Branches
    • Tags
    • Contributors
    • Graph
    • Compare
  • Issues 175
    • Issues 175
    • List
    • Boards
    • Service Desk
    • Milestones
  • Merge requests 9
    • Merge requests 9
  • CI/CD
    • CI/CD
    • Pipelines
    • Jobs
    • Schedules
  • Deployments
    • Deployments
    • Environments
    • Releases
  • Packages and registries
    • Packages and registries
    • Package Registry
    • Infrastructure Registry
  • Monitor
    • Monitor
    • Incidents
  • Analytics
    • Analytics
    • Value stream
    • CI/CD
    • Repository
  • Wiki
    • Wiki
  • Snippets
    • Snippets
  • Activity
  • Graph
  • Create a new issue
  • Jobs
  • Commits
  • Issue Boards
Collapse sidebar
  • OptimalBits
  • bull
  • Issues
  • #273
Closed
Open
Issue created Mar 23, 2016 by Administrator@rootContributor

Cleaning a queue with a corrupted job will lead to an error

Created by: jlukanta

I'm getting "SyntaxError: Unexpected token u at Object.parse" error when calling queue.clean() if a job is that to be removed is corrupted.

I think queue.clean() should still proceed even if a job is corrupted. Otherwise, the job will be stuck forever in the queue.

2016-03-23T00:21:52.154Z - error: [SyntaxError: Unexpected token u] { stack: 'SyntaxError: Unexpected token at Object.parse (native) at Function.Job.fromData (/Users/sanitized/node_modules/bull/lib/job.js:546:40) at /Users/sanitized/node_modules/bull/lib/job.js:50:18

From previous event: at Job.fromId (/Users/sanitized/node_modules/bull/lib/job.js:48:56) at Array.map (native) at /Users/sanitized/node_modules/bull/lib/queue.js:776:29 at RedisClient.return_reply (/Users/sanitized/node_modules/redis/index.js:664:25) at HiredisReplyParser.reply_parser.send_reply (/Users/sanitized/node_modules/redis/index.js:332:14) at HiredisReplyParser.execute (/Users/sanitized/node_modules/redis/lib/parsers/hiredis.js:30:18) at Socket. (/Users/sanitized/node_modules/redis/index.js:131:27) at emitOne (events.js:77:13) at Socket.emit (events.js:169:7) at readableAddChunk (_stream_readable.js:146:16) at Socket.Readable.push (_stream_readable.js:110:10) at TCP.onread (net.js:523:20)

From previous event: at Queue.getJobs (/Users/sanitized/node_modules/bull/lib/queue.js:775:15) at Queue.getCompleted (/Users/sanitized/node_modules/bull/lib/queue.js:748:15) at /Users/sanitized/node_modules/bull/lib/queue.js:822:18 From previous event: at Queue.clean (/Users/sanitized/node_modules/bull/lib/queue.js:801:10) at Queue. (/Users/sanitized/thumbnailWorker.js:694:11) at emitNone (events.js:67:13) at Queue.emit (events.js:166:7) at /Users/sanitized/node_modules/bull/lib/queue.js:130:11 at RedisClient.return_reply (/Users/sanitized/node_modules/redis/index.js:689:33) at HiredisReplyParser.reply_parser.send_reply (/Users/sanitized/node_modules/redis/index.js:332:14) at HiredisReplyParser.execute (/Users/sanitized/node_modules/redis/lib/parsers/hiredis.js:30:18) at Socket. (/Users/sanitized/node_modules/redis/index.js:131:27) at emitOne (events.js:77:13) at Socket.emit (events.js:169:7) at readableAddChunk (_stream_readable.js:146:16) at Socket.Readable.push (_stream_readable.js:110:10) at TCP.onread (net.js:523:20)

...

Assignee
Assign to
Time tracking