public List<EventExecution> getEventExecutions(
            String eventHandlerName, String eventName, String messageId, int max) {
        try {
            String key = nsKey(EVENT_EXECUTION, eventHandlerName, eventName, messageId);
            LOGGER.info("getting event execution {}", key);
            List<EventExecution> executions = new LinkedList<>();
            for (int i = 0; i < max; i++) {
                String field = messageId + "_" + i;
                String value = jedisProxy.hget(key, field);
                if (value == null) {
                    break;
                }
                recordRedisDaoEventRequests("getEventExecution", eventHandlerName);
                recordRedisDaoPayloadSize(
                        "getEventExecution", value.length(), eventHandlerName, "n/a");
                EventExecution eventExecution = objectMapper.readValue(value, EventExecution.class);
                executions.add(eventExecution);
            }
            return executions;

        } catch (Exception e) {
            throw new TransientException(
                    "Unable to get event executions for " + eventHandlerName, e);
        }
    }
Stores the correlation of a task to the workflow instance in the datastore

@param taskId the taskId to be correlated
@param workflowInstanceId the workflowId to which the tasks belongs to
redis-persistence/src/main/java/com/netflix/conductor/redis/dao/RedisExecutionDAO.java