Dynflow async task in rails intializer

dustin_t · July 8, 2014, 6:59am

Hi,

In the Katello plugin,
I'm trying to kick of a long running async task when rails starts. Putting
the following snippet in lib/katello/engine.rb doesn't seem to execute the
the task asynchronously:

  initializer &#39;katello.subs_sync&#39;, :after =&gt;

"katello.set_dynflow_middlewares" do |app|
ForemanTasks.async_task Katello::Actions::SubscriptionsSync
end

Since there is a continuous loop in the task, It blocks and prevents rails
from continuing to startup. Is there a way to do what I'm trying to do?

Thanks! Dustin

iNecas · July 8, 2014, 3:43pm

How does the action look like? Also, it should be ::Actions::Katello, not ::Katello::Actions (as this one is deprecated)

– Ivan

···

----- Original Message ----- > Hi, > > In the Katello plugin, > I'm trying to kick of a long running async task when rails starts. Putting > the following snippet in lib/katello/engine.rb doesn't seem to execute the > the task asynchronously: > > initializer 'katello.subs_sync', :after => > "katello.set_dynflow_middlewares" do |app| > ForemanTasks.async_task Katello::Actions::SubscriptionsSync > end > > Since there is a continuous loop in the task, It blocks and prevents rails > from continuing to startup. Is there a way to do what I'm trying to do? > > Thanks! Dustin > > -- > You received this message because you are subscribed to the Google Groups > "foreman-dev" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to foreman-dev+unsubscribe@googlegroups.com. > For more options, visit https://groups.google.com/d/optout. >

dustin_t · July 9, 2014, 2:06am

Hi Ivan,

Thanks for getting back to me so quickly. I changed my code from earlier, I
wasn't using suspend so it was continuing to run, preventing rails from
starting. I updated the action so that it uses the Dynflow::Action::Polling module
instead since it seemed to fit. Here's the contents of the action
currently:

github.com

dustints/katello/blob/1bc8dfe8829eb1bd3c3785b689e2ab288745ee5d/app/lib/actions/katello/subscription/poll_qpid_queue.rb

#
# Copyright 2014 Red Hat, Inc.
#
# This software is licensed to you under the GNU General Public
# License as published by the Free Software Foundation; either version
# 2 of the License (GPLv2) or (at your option) any later version.
# There is NO WARRANTY for this software, express or implied,
# including the implied warranties of MERCHANTABILITY,
# NON-INFRINGEMENT, or FITNESS FOR A PARTICULAR PURPOSE. You should
# have received a copy of GPLv2 along with this software; if not, see
# http://www.gnu.org/licenses/old-licenses/gpl-2.0.txt.

module Actions
  module Katello
    module Subscription
      class SyncQpidEntitlementPoolQueue < Dynflow::Action
        include Dynflow::Action::Polling

        def done?
          false

This file has been truncated. show original

However, there's one issue I'm still having difficulty with. I'm unable to
stop the rails server with ctrl-c. The job continues to run in the
background and I kill the process in order for rails to stop. Is there a
way to stop the job when rails stops?

Dustin

···

On Tuesday, July 8, 2014 8:43:49 AM UTC-7, Ivan Necas wrote: > > How does the action look like? Also, it should be ::Actions::Katello, not > ::Katello::Actions (as this one is deprecated) > > -- Ivan > > ----- Original Message ----- > > Hi, > > > > In the Katello plugin, > > I'm trying to kick of a long running async task when rails starts. > Putting > > the following snippet in lib/katello/engine.rb doesn't seem to execute > the > > the task asynchronously: > > > > initializer 'katello.subs_sync', :after => > > "katello.set_dynflow_middlewares" do |app| > > ForemanTasks.async_task Katello::Actions::SubscriptionsSync > > end > > > > Since there is a continuous loop in the task, It blocks and prevents > rails > > from continuing to startup. Is there a way to do what I'm trying to do? > > > > Thanks! Dustin > > > > -- > > You received this message because you are subscribed to the Google > Groups > > "foreman-dev" group. > > To unsubscribe from this group and stop receiving emails from it, send > an > > email to foreman-dev...@googlegroups.com . > > For more options, visit https://groups.google.com/d/optout. > > >

iNecas · July 9, 2014, 10:05am

Originally, the dynflow actions were not meant to be continuously running the whole
time the server is running and serve as the listening services. On the other hand,
I see the benefits of having this services trackes as dynflow/foreman tasks as it
can serve as the status indicator of the service.

For the issue for terminating on exit, you would need to hook to the on exit event and cause the termination. There are also better ways for managing it than just polling. Let me write some snipped to give you some pointers (I'm not sure I will get to it today though

– Ivan

···

----- Original Message ----- > Hi Ivan, > > Thanks for getting back to me so quickly. I changed my code from earlier, I > wasn't using suspend so it was continuing to run, preventing rails from > starting. I updated the action so that it uses the Dynflow::Action::Polling > module > instead since it seemed to fit. Here's the contents of the action > currently: > https://github.com/dustint-rh/katello/blob/1bc8dfe8829eb1bd3c3785b689e2ab288745ee5d/app/lib/actions/katello/subscription/poll_qpid_queue.rb#L16 > > However, there's one issue I'm still having difficulty with. I'm unable to > stop the rails server with ctrl-c. The job continues to run in the > background and I kill the process in order for rails to stop. Is there a > way to stop the job when rails stops? > > - Dustin > > > > > > > > On Tuesday, July 8, 2014 8:43:49 AM UTC-7, Ivan Necas wrote: > > > > How does the action look like? Also, it should be ::Actions::Katello, not > > ::Katello::Actions (as this one is deprecated) > > > > -- Ivan > > > > ----- Original Message ----- > > > Hi, > > > > > > In the Katello plugin, > > > I'm trying to kick of a long running async task when rails starts. > > Putting > > > the following snippet in lib/katello/engine.rb doesn't seem to execute > > the > > > the task asynchronously: > > > > > > initializer 'katello.subs_sync', :after => > > > "katello.set_dynflow_middlewares" do |app| > > > ForemanTasks.async_task Katello::Actions::SubscriptionsSync > > > end > > > > > > Since there is a continuous loop in the task, It blocks and prevents > > rails > > > from continuing to startup. Is there a way to do what I'm trying to do? > > > > > > Thanks! Dustin > > > > > > -- > > > You received this message because you are subscribed to the Google > > Groups > > > "foreman-dev" group. > > > To unsubscribe from this group and stop receiving emails from it, send > > an > > > email to foreman-dev...@googlegroups.com . > > > For more options, visit https://groups.google.com/d/optout. > > > > > > > -- > You received this message because you are subscribed to the Google Groups > "foreman-dev" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to foreman-dev+unsubscribe@googlegroups.com. > For more options, visit https://groups.google.com/d/optout. >