in flux-common/src/main/java/software/amazon/aws/clients/swf/flux/step/StepAttributes.java [57:83]
public static Class<?> getSpecialAttributeType(String attributeName) {
switch (attributeName) {
case StepAttributes.ACTIVITY_COMPLETION_MESSAGE:
return String.class;
case StepAttributes.ACTIVITY_INITIAL_ATTEMPT_TIME:
return Instant.class;
case StepAttributes.RESULT_CODE:
return String.class;
case StepAttributes.RETRY_ATTEMPT:
return Long.class;
case StepAttributes.PARTITION_COUNT:
return Long.class;
case StepAttributes.PARTITION_ID:
return String.class;
case StepAttributes.WORKFLOW_ID:
return String.class;
case StepAttributes.WORKFLOW_EXECUTION_ID:
return String.class;
case StepAttributes.WORKFLOW_START_TIME:
return Instant.class;
// Hook-specific attributes below
case StepAttributes.ACTIVITY_NAME:
return String.class;
default:
throw new IllegalArgumentException("Unrecognized special attribute: " + attributeName);
}
}