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.
5602 5603 5604 5605 5606 5607 5608 5609 |
# File 'lib/svc.rb', line 5602 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.
5612 5613 5614 5615 5616 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 |
# File 'lib/svc.rb', line 5612 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 |