-
Notifications
You must be signed in to change notification settings - Fork 109
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Allow setting queue for each job #58
Conversation
Hey @devilankur18, thanks for the PR! Before we merge this can you clean up the unrelated changes you copied from here? aeris@c9f9d92 |
lib/gush/job.rb
Outdated
attr_reader :name, :output_payload, :params | ||
|
||
def initialize(opts = {}) | ||
options = opts.dup | ||
assign_variables(options) | ||
end | ||
|
||
def payload(clazz) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please remove this method, it's not related and not needed
lib/gush/job.rb
Outdated
@@ -98,6 +105,9 @@ def has_no_dependencies? | |||
end | |||
|
|||
private | |||
def logger |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Also not needed
lib/gush/worker.rb
Outdated
client.enqueue_job(workflow_id, out) | ||
end | ||
out | ||
end | ||
rescue RedisMutex::LockError |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Unrelated to queuing
@pokonski updated !! |
Looks good! Can you also fix the one failing spec and I'll merge it :) Thanks! |
@pokonski fixed !! |
@devilankur18 this is now released under version 2.0.0. Thanks again and sorry for the delay! |
#39 Added queue support as per the latest code.