Class: SDM::WorkflowsHistory
- Inherits:
-
Object
- Object
- SDM::WorkflowsHistory
- Extended by:
- Gem::Deprecate
- Defined in:
- lib/svc.rb
Overview
WorkflowsHistory provides records of all changes to the state of a Workflow.
See WorkflowHistory.
Instance Method Summary collapse
-
#initialize(channel, parent) ⇒ WorkflowsHistory
constructor
A new instance of WorkflowsHistory.
-
#list(filter, *args, deadline: nil) ⇒ Object
List gets a list of WorkflowHistory records matching a given set of criteria.
Constructor Details
#initialize(channel, parent) ⇒ WorkflowsHistory
Returns a new instance of WorkflowsHistory.
5607 5608 5609 5610 5611 5612 5613 5614 |
# File 'lib/svc.rb', line 5607 def initialize(channel, parent) begin @stub = V1::WorkflowsHistory::Stub.new(nil, nil, channel_override: channel) rescue => exception raise Plumbing::convert_error_to_porcelain(exception) end @parent = parent end |
Instance Method Details
#list(filter, *args, deadline: nil) ⇒ Object
List gets a list of WorkflowHistory records matching a given set of criteria.
5617 5618 5619 5620 5621 5622 5623 5624 5625 5626 5627 5628 5629 5630 5631 5632 5633 5634 5635 5636 5637 5638 5639 5640 5641 5642 5643 5644 5645 5646 5647 5648 5649 5650 5651 5652 5653 |
# File 'lib/svc.rb', line 5617 def list( filter, *args, deadline: nil ) req = V1::WorkflowHistoryListRequest.new() req. = V1::ListRequestMetadata.new() if @parent.page_limit > 0 req..limit = @parent.page_limit end if not @parent.snapshot_time.nil? req..snapshot_at = @parent.snapshot_time end req.filter = Plumbing::quote_filter_args(filter, *args) resp = Enumerator::Generator.new { |g| tries = 0 loop do begin plumbing_response = @stub.list(req, metadata: @parent.("WorkflowsHistory.List", req), deadline: deadline) rescue => exception if (@parent.shouldRetry(tries, exception)) tries + +@parent.jitterSleep(tries) next end raise Plumbing::convert_error_to_porcelain(exception) end tries = 0 plumbing_response.history.each do |plumbing_item| g.yield Plumbing::convert_workflow_history_to_porcelain(plumbing_item) end break if plumbing_response..next_cursor == "" req..cursor = plumbing_response..next_cursor end } resp end |