class CadenceThrift::WorkflowService::Processor
Public Instance Methods
process_CountWorkflowExecutions(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1410 def process_CountWorkflowExecutions(seqid, iprot, oprot) args = read_args(iprot, CountWorkflowExecutions_args) result = CountWorkflowExecutions_result.new() begin result.success = @handler.CountWorkflowExecutions(args.countRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'CountWorkflowExecutions', seqid) end
process_DeprecateDomain(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 853 def process_DeprecateDomain(seqid, iprot, oprot) args = read_args(iprot, DeprecateDomain_args) result = DeprecateDomain_result.new() begin @handler.DeprecateDomain(args.deprecateRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'DeprecateDomain', seqid) end
process_DescribeDomain(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 794 def process_DescribeDomain(seqid, iprot, oprot) args = read_args(iprot, DescribeDomain_args) result = DescribeDomain_result.new() begin result.success = @handler.DescribeDomain(args.describeRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'DescribeDomain', seqid) end
process_DescribeTaskList(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1534 def process_DescribeTaskList(seqid, iprot, oprot) args = read_args(iprot, DescribeTaskList_args) result = DescribeTaskList_result.new() begin result.success = @handler.DescribeTaskList(args.request) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'DescribeTaskList', seqid) end
process_DescribeWorkflowExecution(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1513 def process_DescribeWorkflowExecution(seqid, iprot, oprot) args = read_args(iprot, DescribeWorkflowExecution_args) result = DescribeWorkflowExecution_result.new() begin result.success = @handler.DescribeWorkflowExecution(args.describeRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'DescribeWorkflowExecution', seqid) end
process_GetSearchAttributes(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1429 def process_GetSearchAttributes(seqid, iprot, oprot) args = read_args(iprot, GetSearchAttributes_args) result = GetSearchAttributes_result.new() begin result.success = @handler.GetSearchAttributes() rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'GetSearchAttributes', seqid) end
process_GetWorkflowExecutionHistory(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 899 def process_GetWorkflowExecutionHistory(seqid, iprot, oprot) args = read_args(iprot, GetWorkflowExecutionHistory_args) result = GetWorkflowExecutionHistory_result.new() begin result.success = @handler.GetWorkflowExecutionHistory(args.getRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'GetWorkflowExecutionHistory', seqid) end
process_ListArchivedWorkflowExecutions(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1372 def process_ListArchivedWorkflowExecutions(seqid, iprot, oprot) args = read_args(iprot, ListArchivedWorkflowExecutions_args) result = ListArchivedWorkflowExecutions_result.new() begin result.success = @handler.ListArchivedWorkflowExecutions(args.listRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'ListArchivedWorkflowExecutions', seqid) end
process_ListClosedWorkflowExecutions(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1334 def process_ListClosedWorkflowExecutions(seqid, iprot, oprot) args = read_args(iprot, ListClosedWorkflowExecutions_args) result = ListClosedWorkflowExecutions_result.new() begin result.success = @handler.ListClosedWorkflowExecutions(args.listRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'ListClosedWorkflowExecutions', seqid) end
process_ListDomains(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 813 def process_ListDomains(seqid, iprot, oprot) args = read_args(iprot, ListDomains_args) result = ListDomains_result.new() begin result.success = @handler.ListDomains(args.listRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'ListDomains', seqid) end
process_ListOpenWorkflowExecutions(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1313 def process_ListOpenWorkflowExecutions(seqid, iprot, oprot) args = read_args(iprot, ListOpenWorkflowExecutions_args) result = ListOpenWorkflowExecutions_result.new() begin result.success = @handler.ListOpenWorkflowExecutions(args.listRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'ListOpenWorkflowExecutions', seqid) end
process_ListWorkflowExecutions(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1353 def process_ListWorkflowExecutions(seqid, iprot, oprot) args = read_args(iprot, ListWorkflowExecutions_args) result = ListWorkflowExecutions_result.new() begin result.success = @handler.ListWorkflowExecutions(args.listRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'ListWorkflowExecutions', seqid) end
process_PollForActivityTask(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 987 def process_PollForActivityTask(seqid, iprot, oprot) args = read_args(iprot, PollForActivityTask_args) result = PollForActivityTask_result.new() begin result.success = @handler.PollForActivityTask(args.pollRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'PollForActivityTask', seqid) end
process_PollForDecisionTask(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 918 def process_PollForDecisionTask(seqid, iprot, oprot) args = read_args(iprot, PollForDecisionTask_args) result = PollForDecisionTask_result.new() begin result.success = @handler.PollForDecisionTask(args.pollRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'PollForDecisionTask', seqid) end
process_QueryWorkflow(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1490 def process_QueryWorkflow(seqid, iprot, oprot) args = read_args(iprot, QueryWorkflow_args) result = QueryWorkflow_result.new() begin result.success = @handler.QueryWorkflow(args.queryRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::QueryFailedError => queryFailedError result.queryFailedError = queryFailedError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'QueryWorkflow', seqid) end
process_RecordActivityTaskHeartbeat(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1010 def process_RecordActivityTaskHeartbeat(seqid, iprot, oprot) args = read_args(iprot, RecordActivityTaskHeartbeat_args) result = RecordActivityTaskHeartbeat_result.new() begin result.success = @handler.RecordActivityTaskHeartbeat(args.heartbeatRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'RecordActivityTaskHeartbeat', seqid) end
process_RecordActivityTaskHeartbeatByID(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1033 def process_RecordActivityTaskHeartbeatByID(seqid, iprot, oprot) args = read_args(iprot, RecordActivityTaskHeartbeatByID_args) result = RecordActivityTaskHeartbeatByID_result.new() begin result.success = @handler.RecordActivityTaskHeartbeatByID(args.heartbeatRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'RecordActivityTaskHeartbeatByID', seqid) end
process_RegisterDomain(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 775 def process_RegisterDomain(seqid, iprot, oprot) args = read_args(iprot, RegisterDomain_args) result = RegisterDomain_result.new() begin @handler.RegisterDomain(args.registerRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::DomainAlreadyExistsError => domainExistsError result.domainExistsError = domainExistsError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'RegisterDomain', seqid) end
process_RequestCancelWorkflowExecution(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1194 def process_RequestCancelWorkflowExecution(seqid, iprot, oprot) args = read_args(iprot, RequestCancelWorkflowExecution_args) result = RequestCancelWorkflowExecution_result.new() begin @handler.RequestCancelWorkflowExecution(args.cancelRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::CancellationAlreadyRequestedError => cancellationAlreadyRequestedError result.cancellationAlreadyRequestedError = cancellationAlreadyRequestedError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'RequestCancelWorkflowExecution', seqid) end
process_ResetStickyTaskList(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1467 def process_ResetStickyTaskList(seqid, iprot, oprot) args = read_args(iprot, ResetStickyTaskList_args) result = ResetStickyTaskList_result.new() begin result.success = @handler.ResetStickyTaskList(args.resetRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'ResetStickyTaskList', seqid) end
process_ResetWorkflowExecution(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1267 def process_ResetWorkflowExecution(seqid, iprot, oprot) args = read_args(iprot, ResetWorkflowExecution_args) result = ResetWorkflowExecution_result.new() begin result.success = @handler.ResetWorkflowExecution(args.resetRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'ResetWorkflowExecution', seqid) end
process_RespondActivityTaskCanceled(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1148 def process_RespondActivityTaskCanceled(seqid, iprot, oprot) args = read_args(iprot, RespondActivityTaskCanceled_args) result = RespondActivityTaskCanceled_result.new() begin @handler.RespondActivityTaskCanceled(args.canceledRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'RespondActivityTaskCanceled', seqid) end
process_RespondActivityTaskCanceledByID(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1171 def process_RespondActivityTaskCanceledByID(seqid, iprot, oprot) args = read_args(iprot, RespondActivityTaskCanceledByID_args) result = RespondActivityTaskCanceledByID_result.new() begin @handler.RespondActivityTaskCanceledByID(args.canceledRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'RespondActivityTaskCanceledByID', seqid) end
process_RespondActivityTaskCompleted(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1056 def process_RespondActivityTaskCompleted(seqid, iprot, oprot) args = read_args(iprot, RespondActivityTaskCompleted_args) result = RespondActivityTaskCompleted_result.new() begin @handler.RespondActivityTaskCompleted(args.completeRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'RespondActivityTaskCompleted', seqid) end
process_RespondActivityTaskCompletedByID(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1079 def process_RespondActivityTaskCompletedByID(seqid, iprot, oprot) args = read_args(iprot, RespondActivityTaskCompletedByID_args) result = RespondActivityTaskCompletedByID_result.new() begin @handler.RespondActivityTaskCompletedByID(args.completeRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'RespondActivityTaskCompletedByID', seqid) end
process_RespondActivityTaskFailed(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1102 def process_RespondActivityTaskFailed(seqid, iprot, oprot) args = read_args(iprot, RespondActivityTaskFailed_args) result = RespondActivityTaskFailed_result.new() begin @handler.RespondActivityTaskFailed(args.failRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'RespondActivityTaskFailed', seqid) end
process_RespondActivityTaskFailedByID(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1125 def process_RespondActivityTaskFailedByID(seqid, iprot, oprot) args = read_args(iprot, RespondActivityTaskFailedByID_args) result = RespondActivityTaskFailedByID_result.new() begin @handler.RespondActivityTaskFailedByID(args.failRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'RespondActivityTaskFailedByID', seqid) end
process_RespondDecisionTaskCompleted(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 941 def process_RespondDecisionTaskCompleted(seqid, iprot, oprot) args = read_args(iprot, RespondDecisionTaskCompleted_args) result = RespondDecisionTaskCompleted_result.new() begin result.success = @handler.RespondDecisionTaskCompleted(args.completeRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'RespondDecisionTaskCompleted', seqid) end
process_RespondDecisionTaskFailed(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 964 def process_RespondDecisionTaskFailed(seqid, iprot, oprot) args = read_args(iprot, RespondDecisionTaskFailed_args) result = RespondDecisionTaskFailed_result.new() begin @handler.RespondDecisionTaskFailed(args.failedRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'RespondDecisionTaskFailed', seqid) end
process_RespondQueryTaskCompleted(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1444 def process_RespondQueryTaskCompleted(seqid, iprot, oprot) args = read_args(iprot, RespondQueryTaskCompleted_args) result = RespondQueryTaskCompleted_result.new() begin @handler.RespondQueryTaskCompleted(args.completeRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'RespondQueryTaskCompleted', seqid) end
process_ScanWorkflowExecutions(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1391 def process_ScanWorkflowExecutions(seqid, iprot, oprot) args = read_args(iprot, ScanWorkflowExecutions_args) result = ScanWorkflowExecutions_result.new() begin result.success = @handler.ScanWorkflowExecutions(args.listRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'ScanWorkflowExecutions', seqid) end
process_SignalWithStartWorkflowExecution(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1242 def process_SignalWithStartWorkflowExecution(seqid, iprot, oprot) args = read_args(iprot, SignalWithStartWorkflowExecution_args) result = SignalWithStartWorkflowExecution_result.new() begin result.success = @handler.SignalWithStartWorkflowExecution(args.signalWithStartRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::WorkflowExecutionAlreadyStartedError => workflowAlreadyStartedError result.workflowAlreadyStartedError = workflowAlreadyStartedError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'SignalWithStartWorkflowExecution', seqid) end
process_SignalWorkflowExecution(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1219 def process_SignalWorkflowExecution(seqid, iprot, oprot) args = read_args(iprot, SignalWorkflowExecution_args) result = SignalWorkflowExecution_result.new() begin @handler.SignalWorkflowExecution(args.signalRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'SignalWorkflowExecution', seqid) end
process_StartWorkflowExecution(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 874 def process_StartWorkflowExecution(seqid, iprot, oprot) args = read_args(iprot, StartWorkflowExecution_args) result = StartWorkflowExecution_result.new() begin result.success = @handler.StartWorkflowExecution(args.startRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::WorkflowExecutionAlreadyStartedError => sessionAlreadyExistError result.sessionAlreadyExistError = sessionAlreadyExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'StartWorkflowExecution', seqid) end
process_TerminateWorkflowExecution(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 1290 def process_TerminateWorkflowExecution(seqid, iprot, oprot) args = read_args(iprot, TerminateWorkflowExecution_args) result = TerminateWorkflowExecution_result.new() begin @handler.TerminateWorkflowExecution(args.terminateRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::LimitExceededError => limitExceededError result.limitExceededError = limitExceededError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'TerminateWorkflowExecution', seqid) end
process_UpdateDomain(seqid, iprot, oprot)
click to toggle source
# File lib/gen/thrift/workflow_service.rb, line 832 def process_UpdateDomain(seqid, iprot, oprot) args = read_args(iprot, UpdateDomain_args) result = UpdateDomain_result.new() begin result.success = @handler.UpdateDomain(args.updateRequest) rescue ::CadenceThrift::BadRequestError => badRequestError result.badRequestError = badRequestError rescue ::CadenceThrift::InternalServiceError => internalServiceError result.internalServiceError = internalServiceError rescue ::CadenceThrift::EntityNotExistsError => entityNotExistError result.entityNotExistError = entityNotExistError rescue ::CadenceThrift::ServiceBusyError => serviceBusyError result.serviceBusyError = serviceBusyError rescue ::CadenceThrift::DomainNotActiveError => domainNotActiveError result.domainNotActiveError = domainNotActiveError rescue ::CadenceThrift::ClientVersionNotSupportedError => clientVersionNotSupportedError result.clientVersionNotSupportedError = clientVersionNotSupportedError end write_result(result, oprot, 'UpdateDomain', seqid) end