lib/dynflow/director/running_steps_manager.rb
# turns the first event from the queue to the next work item to work on
turns the first event from the queue to the next work item to work on
turns the first event from the queue to the next work item to work on
def create_next_event_work_item(step)
        event = @events.shift(step.id)
        return unless event
        work = EventWorkItem.new(event.request_id, event.execution_plan_id, step, event.event, step.queue, @world.id)
        @work_items.push(step.id, work)
        work
      end
def create_next_event_work_item ( step ) event = @events . shift ( step . id ) return unless event work = EventWorkItem . new ( event . request_id , event . execution_plan_id , step , event . event , step . queue , @world . id ) @work_items . push ( step . id , work ) work end
turns the first event from the queue to the next work item to work on
turns the first event from the queue to the next work item to work on
step