sidekiq_pipeline

KO | EN

gitlite — search

#react #typescript #golang #go #android #rust #deep-learning #nodejs #windows #kubernetes #security #pytorch #mcp #open-source

sidekiq_pipeline

(★ 18)

Supports defining 'pipelines' of workers in Sidekiq

sidekiq_pipeline 최신버젼 다운로드

최종 버전 다운로드 (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# SidekiqPipeline

Allows you to define pipelines in Sidekiq, an ordered chain of jobs.

```ruby
class WorkerOne
  include Sidekiq::Worker
  include SidekiqPipeline

def pipeline_perform(params)
    puts params["key"]
  end
end

class WorkerTwo
  include Sidekiq::Worker
  include SidekiqPipeline

def pipeline_perform(params)
    puts params["data"]
  end
end

tasks = {
  pipeline: [{
    class: "WorkerOne",
    params: {key: 'foo'}
  },{
    class: "WorkerTwo",
    params: {data: 'bar'}
  }]
}

SidekiqPipeline.execute(tasks)
# WorkerOne will output: 'foo'
# WorkerTwo will output: 'bar'
```

Tasks will be run in the order they are defined. If a task fails, it will retry on the step it failed on, and it will continue down the pipeline if/when it retires successfully. Each worker can have it's own queue or share queues. Tries to be as unobtrusive as possible

## Installation

Add this line to your application's Gemfile:

gem 'sidekiq_pipeline'

And then execute:

$ bundle

Or install it yourself as:

$ gem install sidekiq_pipeline

## Contributing

1. Fork it
2. Create your feature branch (`git checkout -b my-new-feature`)
3. Commit your changes (`git commit -am 'Add some feature'`)
4. Push to the branch (`git push origin my-new-feature`)
5. Create new Pull Request

sidekiq_pipeline

sidekiq_pipeline 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

sidekiq_pipeline

sidekiq_pipeline 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

Download README