Guides

SWF

Suggest Edits
docs.aws.amazon.com
AWS documentation

CountClosedWorkflowExecutions

enum_CloseStatus := [ "COMPLETED", "FAILED", "CANCELED", "TERMINATED", "CONTINUED_AS_NEW", "TIMED_OUT" ]

valid {
    input.Body.domain == STRING
    input.Body.startTimeFilter.oldestDate == TIMESTAMP
    input.Body.startTimeFilter.latestDate == TIMESTAMP
    input.Body.closeTimeFilter.oldestDate == TIMESTAMP
    input.Body.closeTimeFilter.latestDate == TIMESTAMP
    input.Body.executionFilter.workflowId == STRING
    input.Body.typeFilter.name == STRING
    input.Body.typeFilter.version == STRING
    input.Body.tagFilter.tag == STRING
    input.Body.closeStatusFilter.status == enum_CloseStatus[_]
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

CountOpenWorkflowExecutions

valid {
    input.Body.domain == STRING
    input.Body.startTimeFilter.oldestDate == TIMESTAMP
    input.Body.startTimeFilter.latestDate == TIMESTAMP
    input.Body.typeFilter.name == STRING
    input.Body.typeFilter.version == STRING
    input.Body.tagFilter.tag == STRING
    input.Body.executionFilter.workflowId == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

CountPendingActivityTasks

valid {
    input.Body.domain == STRING
    input.Body.taskList.name == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

CountPendingDecisionTasks

valid {
    input.Body.domain == STRING
    input.Body.taskList.name == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

DeleteActivityType

valid {
    input.Body.domain == STRING
    input.Body.activityType.name == STRING
    input.Body.activityType.version == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

DeleteWorkflowType

valid {
    input.Body.domain == STRING
    input.Body.workflowType.name == STRING
    input.Body.workflowType.version == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

DeprecateActivityType

valid {
    input.Body.domain == STRING
    input.Body.activityType.name == STRING
    input.Body.activityType.version == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

DeprecateDomain

valid {
    input.Body.name == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

DeprecateWorkflowType

valid {
    input.Body.domain == STRING
    input.Body.workflowType.name == STRING
    input.Body.workflowType.version == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

DescribeActivityType

valid {
    input.Body.domain == STRING
    input.Body.activityType.name == STRING
    input.Body.activityType.version == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

DescribeDomain

valid {
    input.Body.name == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

DescribeWorkflowExecution

valid {
    input.Body.domain == STRING
    input.Body.execution.workflowId == STRING
    input.Body.execution.runId == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

DescribeWorkflowType

valid {
    input.Body.domain == STRING
    input.Body.workflowType.name == STRING
    input.Body.workflowType.version == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

GetWorkflowExecutionHistory

valid {
    input.Body.domain == STRING
    input.Body.execution.workflowId == STRING
    input.Body.execution.runId == STRING
    input.Body.nextPageToken == STRING
    input.Body.maximumPageSize == INTEGER
    input.Body.reverseOrder == BOOLEAN
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

ListActivityTypes

enum_RegistrationStatus := [ "REGISTERED", "DEPRECATED" ]

valid {
    input.Body.domain == STRING
    input.Body.name == STRING
    input.Body.registrationStatus == enum_RegistrationStatus[_]
    input.Body.nextPageToken == STRING
    input.Body.maximumPageSize == INTEGER
    input.Body.reverseOrder == BOOLEAN
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

ListClosedWorkflowExecutions

enum_CloseStatus := [ "COMPLETED", "FAILED", "CANCELED", "TERMINATED", "CONTINUED_AS_NEW", "TIMED_OUT" ]

valid {
    input.Body.domain == STRING
    input.Body.startTimeFilter.oldestDate == TIMESTAMP
    input.Body.startTimeFilter.latestDate == TIMESTAMP
    input.Body.closeTimeFilter.oldestDate == TIMESTAMP
    input.Body.closeTimeFilter.latestDate == TIMESTAMP
    input.Body.executionFilter.workflowId == STRING
    input.Body.closeStatusFilter.status == enum_CloseStatus[_]
    input.Body.typeFilter.name == STRING
    input.Body.typeFilter.version == STRING
    input.Body.tagFilter.tag == STRING
    input.Body.nextPageToken == STRING
    input.Body.maximumPageSize == INTEGER
    input.Body.reverseOrder == BOOLEAN
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

ListDomains

enum_RegistrationStatus := [ "REGISTERED", "DEPRECATED" ]

valid {
    input.Body.nextPageToken == STRING
    input.Body.registrationStatus == enum_RegistrationStatus[_]
    input.Body.maximumPageSize == INTEGER
    input.Body.reverseOrder == BOOLEAN
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

ListOpenWorkflowExecutions

valid {
    input.Body.domain == STRING
    input.Body.startTimeFilter.oldestDate == TIMESTAMP
    input.Body.startTimeFilter.latestDate == TIMESTAMP
    input.Body.typeFilter.name == STRING
    input.Body.typeFilter.version == STRING
    input.Body.tagFilter.tag == STRING
    input.Body.nextPageToken == STRING
    input.Body.maximumPageSize == INTEGER
    input.Body.reverseOrder == BOOLEAN
    input.Body.executionFilter.workflowId == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

ListTagsForResource

valid {
    input.Body.resourceArn == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

ListWorkflowTypes

enum_RegistrationStatus := [ "REGISTERED", "DEPRECATED" ]

valid {
    input.Body.domain == STRING
    input.Body.name == STRING
    input.Body.registrationStatus == enum_RegistrationStatus[_]
    input.Body.nextPageToken == STRING
    input.Body.maximumPageSize == INTEGER
    input.Body.reverseOrder == BOOLEAN
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

PollForActivityTask

valid {
    input.Body.domain == STRING
    input.Body.taskList.name == STRING
    input.Body.identity == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

PollForDecisionTask

valid {
    input.Body.domain == STRING
    input.Body.taskList.name == STRING
    input.Body.identity == STRING
    input.Body.nextPageToken == STRING
    input.Body.maximumPageSize == INTEGER
    input.Body.reverseOrder == BOOLEAN
    input.Body.startAtPreviousStartedEvent == BOOLEAN
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

RecordActivityTaskHeartbeat

valid {
    input.Body.taskToken == STRING
    input.Body.details == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

RegisterActivityType

valid {
    input.Body.domain == STRING
    input.Body.name == STRING
    input.Body.version == STRING
    input.Body.description == STRING
    input.Body.defaultTaskStartToCloseTimeout == STRING
    input.Body.defaultTaskHeartbeatTimeout == STRING
    input.Body.defaultTaskList.name == STRING
    input.Body.defaultTaskPriority == STRING
    input.Body.defaultTaskScheduleToStartTimeout == STRING
    input.Body.defaultTaskScheduleToCloseTimeout == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

RegisterDomain

valid {
    input.Body.name == STRING
    input.Body.description == STRING
    input.Body.workflowExecutionRetentionPeriodInDays == STRING
    input.Body.tags[_].key == STRING
    input.Body.tags[_].value == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

RegisterWorkflowType

enum_ChildPolicy := [ "TERMINATE", "REQUEST_CANCEL", "ABANDON" ]

valid {
    input.Body.domain == STRING
    input.Body.name == STRING
    input.Body.version == STRING
    input.Body.description == STRING
    input.Body.defaultTaskStartToCloseTimeout == STRING
    input.Body.defaultExecutionStartToCloseTimeout == STRING
    input.Body.defaultTaskList.name == STRING
    input.Body.defaultTaskPriority == STRING
    input.Body.defaultChildPolicy == enum_ChildPolicy[_]
    input.Body.defaultLambdaRole == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

RequestCancelWorkflowExecution

valid {
    input.Body.domain == STRING
    input.Body.workflowId == STRING
    input.Body.runId == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

RespondActivityTaskCanceled

valid {
    input.Body.taskToken == STRING
    input.Body.details == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

RespondActivityTaskCompleted

valid {
    input.Body.taskToken == STRING
    input.Body.result == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

RespondActivityTaskFailed

valid {
    input.Body.taskToken == STRING
    input.Body.reason == STRING
    input.Body.details == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

RespondDecisionTaskCompleted

enum_ChildPolicy := [ "TERMINATE", "REQUEST_CANCEL", "ABANDON" ]
enum_DecisionType := [ "ScheduleActivityTask", "RequestCancelActivityTask", "CompleteWorkflowExecution", "FailWorkflowExecution", "CancelWorkflowExecution", "ContinueAsNewWorkflowExecution", "RecordMarker", "StartTimer", "CancelTimer", "SignalExternalWorkflowExecution", "RequestCancelExternalWorkflowExecution", "StartChildWorkflowExecution", "ScheduleLambdaFunction" ]

valid {
    input.Body.taskToken == STRING
    input.Body.decisions[_].decisionType == enum_DecisionType[_]
    input.Body.decisions[_].scheduleActivityTaskDecisionAttributes.activityType.name == STRING
    input.Body.decisions[_].scheduleActivityTaskDecisionAttributes.activityType.version == STRING
    input.Body.decisions[_].scheduleActivityTaskDecisionAttributes.activityId == STRING
    input.Body.decisions[_].scheduleActivityTaskDecisionAttributes.control == STRING
    input.Body.decisions[_].scheduleActivityTaskDecisionAttributes.input == STRING
    input.Body.decisions[_].scheduleActivityTaskDecisionAttributes.scheduleToCloseTimeout == STRING
    input.Body.decisions[_].scheduleActivityTaskDecisionAttributes.taskList.name == STRING
    input.Body.decisions[_].scheduleActivityTaskDecisionAttributes.taskPriority == STRING
    input.Body.decisions[_].scheduleActivityTaskDecisionAttributes.scheduleToStartTimeout == STRING
    input.Body.decisions[_].scheduleActivityTaskDecisionAttributes.startToCloseTimeout == STRING
    input.Body.decisions[_].scheduleActivityTaskDecisionAttributes.heartbeatTimeout == STRING
    input.Body.decisions[_].requestCancelActivityTaskDecisionAttributes.activityId == STRING
    input.Body.decisions[_].completeWorkflowExecutionDecisionAttributes.result == STRING
    input.Body.decisions[_].failWorkflowExecutionDecisionAttributes.reason == STRING
    input.Body.decisions[_].failWorkflowExecutionDecisionAttributes.details == STRING
    input.Body.decisions[_].cancelWorkflowExecutionDecisionAttributes.details == STRING
    input.Body.decisions[_].continueAsNewWorkflowExecutionDecisionAttributes.input == STRING
    input.Body.decisions[_].continueAsNewWorkflowExecutionDecisionAttributes.executionStartToCloseTimeout == STRING
    input.Body.decisions[_].continueAsNewWorkflowExecutionDecisionAttributes.taskList.name == STRING
    input.Body.decisions[_].continueAsNewWorkflowExecutionDecisionAttributes.taskPriority == STRING
    input.Body.decisions[_].continueAsNewWorkflowExecutionDecisionAttributes.taskStartToCloseTimeout == STRING
    input.Body.decisions[_].continueAsNewWorkflowExecutionDecisionAttributes.childPolicy == enum_ChildPolicy[_]
    input.Body.decisions[_].continueAsNewWorkflowExecutionDecisionAttributes.tagList[_] == STRING
    input.Body.decisions[_].continueAsNewWorkflowExecutionDecisionAttributes.workflowTypeVersion == STRING
    input.Body.decisions[_].continueAsNewWorkflowExecutionDecisionAttributes.lambdaRole == STRING
    input.Body.decisions[_].recordMarkerDecisionAttributes.markerName == STRING
    input.Body.decisions[_].recordMarkerDecisionAttributes.details == STRING
    input.Body.decisions[_].startTimerDecisionAttributes.timerId == STRING
    input.Body.decisions[_].startTimerDecisionAttributes.control == STRING
    input.Body.decisions[_].startTimerDecisionAttributes.startToFireTimeout == STRING
    input.Body.decisions[_].cancelTimerDecisionAttributes.timerId == STRING
    input.Body.decisions[_].signalExternalWorkflowExecutionDecisionAttributes.workflowId == STRING
    input.Body.decisions[_].signalExternalWorkflowExecutionDecisionAttributes.runId == STRING
    input.Body.decisions[_].signalExternalWorkflowExecutionDecisionAttributes.signalName == STRING
    input.Body.decisions[_].signalExternalWorkflowExecutionDecisionAttributes.input == STRING
    input.Body.decisions[_].signalExternalWorkflowExecutionDecisionAttributes.control == STRING
    input.Body.decisions[_].requestCancelExternalWorkflowExecutionDecisionAttributes.workflowId == STRING
    input.Body.decisions[_].requestCancelExternalWorkflowExecutionDecisionAttributes.runId == STRING
    input.Body.decisions[_].requestCancelExternalWorkflowExecutionDecisionAttributes.control == STRING
    input.Body.decisions[_].startChildWorkflowExecutionDecisionAttributes.workflowType.name == STRING
    input.Body.decisions[_].startChildWorkflowExecutionDecisionAttributes.workflowType.version == STRING
    input.Body.decisions[_].startChildWorkflowExecutionDecisionAttributes.workflowId == STRING
    input.Body.decisions[_].startChildWorkflowExecutionDecisionAttributes.control == STRING
    input.Body.decisions[_].startChildWorkflowExecutionDecisionAttributes.input == STRING
    input.Body.decisions[_].startChildWorkflowExecutionDecisionAttributes.executionStartToCloseTimeout == STRING
    input.Body.decisions[_].startChildWorkflowExecutionDecisionAttributes.taskList.name == STRING
    input.Body.decisions[_].startChildWorkflowExecutionDecisionAttributes.taskPriority == STRING
    input.Body.decisions[_].startChildWorkflowExecutionDecisionAttributes.taskStartToCloseTimeout == STRING
    input.Body.decisions[_].startChildWorkflowExecutionDecisionAttributes.childPolicy == enum_ChildPolicy[_]
    input.Body.decisions[_].startChildWorkflowExecutionDecisionAttributes.tagList[_] == STRING
    input.Body.decisions[_].startChildWorkflowExecutionDecisionAttributes.lambdaRole == STRING
    input.Body.decisions[_].scheduleLambdaFunctionDecisionAttributes.id == STRING
    input.Body.decisions[_].scheduleLambdaFunctionDecisionAttributes.name == STRING
    input.Body.decisions[_].scheduleLambdaFunctionDecisionAttributes.control == STRING
    input.Body.decisions[_].scheduleLambdaFunctionDecisionAttributes.input == STRING
    input.Body.decisions[_].scheduleLambdaFunctionDecisionAttributes.startToCloseTimeout == STRING
    input.Body.executionContext == STRING
    input.Body.taskList.name == STRING
    input.Body.taskListScheduleToStartTimeout == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

SignalWorkflowExecution

valid {
    input.Body.domain == STRING
    input.Body.workflowId == STRING
    input.Body.runId == STRING
    input.Body.signalName == STRING
    input.Body.input == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

StartWorkflowExecution

enum_ChildPolicy := [ "TERMINATE", "REQUEST_CANCEL", "ABANDON" ]

valid {
    input.Body.domain == STRING
    input.Body.workflowId == STRING
    input.Body.workflowType.name == STRING
    input.Body.workflowType.version == STRING
    input.Body.taskList.name == STRING
    input.Body.taskPriority == STRING
    input.Body.input == STRING
    input.Body.executionStartToCloseTimeout == STRING
    input.Body.tagList[_] == STRING
    input.Body.taskStartToCloseTimeout == STRING
    input.Body.childPolicy == enum_ChildPolicy[_]
    input.Body.lambdaRole == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

TagResource

valid {
    input.Body.resourceArn == STRING
    input.Body.tags[_].key == STRING
    input.Body.tags[_].value == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

TerminateWorkflowExecution

enum_ChildPolicy := [ "TERMINATE", "REQUEST_CANCEL", "ABANDON" ]

valid {
    input.Body.domain == STRING
    input.Body.workflowId == STRING
    input.Body.runId == STRING
    input.Body.reason == STRING
    input.Body.details == STRING
    input.Body.childPolicy == enum_ChildPolicy[_]
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

UndeprecateActivityType

valid {
    input.Body.domain == STRING
    input.Body.activityType.name == STRING
    input.Body.activityType.version == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

UndeprecateDomain

valid {
    input.Body.name == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

UndeprecateWorkflowType

valid {
    input.Body.domain == STRING
    input.Body.workflowType.name == STRING
    input.Body.workflowType.version == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

UntagResource

valid {
    input.Body.resourceArn == STRING
    input.Body.tagKeys[_] == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

Updated 5 days ago