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
  • Merge requests
  • !110

Implementation of tags to jobs

  • Review changes

  • Download
  • Email patches
  • Plain diff
Closed Administrator requested to merge github/fork/saromanov/tags into master Mar 22, 2015
  • Overview 4
  • Commits 1
  • Pipelines 0
  • Changes 3

Created by: saromanov

Hi, guys! I implemented tags for jobs, and its looks something like:

var videoQueue = Queue('video transcoding', 6379, '127.0.0.1');
videoQueue.process(function(job, done){
  videoQueue.getByTag('active', 'bar').then(function(jobs){
        console.log("Active jobs: ", jobs);
    })

  job.progress(42);
  done();
});
videoQueue.add({video: 'http://example.com/video1.mov'}, {tags:['bar']});
videoQueue.add({video: 'http://example.com/video2.mov'});
videoQueue.add({video: 'http://example.com/video3.mov'}, {tags:['foo','bar']});
videoQueue.add({video: 'http://example.com/video4.mov'}, {tags:['foo']});

Where, signature of getByTag is getByTag(type of jobs ['active','delayed',..], tag)

In general, we can group some of jobs by tag, get it during the work of queue on some of state(progress, paused, failed...) and process it. What do you think about this?

Assignee
Assign to
Reviewers
Request review from
Time tracking
Source branch: github/fork/saromanov/tags