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