@Override
    public boolean addEventExecution(EventExecution eventExecution) {
        try {
            String key =
                    nsKey(
                            EVENT_EXECUTION,
                            eventExecution.getName(),
                            eventExecution.getEvent(),
                            eventExecution.getMessageId());
            String json = objectMapper.writeValueAsString(eventExecution);
            recordRedisDaoEventRequests("addEventExecution", eventExecution.getEvent());
            recordRedisDaoPayloadSize(
                    "addEventExecution", json.length(), eventExecution.getEvent(), "n/a");
            boolean added = jedisProxy.hsetnx(key, eventExecution.getId(), json) == 1L;

            if (ttlEventExecutionSeconds > 0) {
                jedisProxy.expire(key, ttlEventExecutionSeconds);
            }

            return added;
        } catch (Exception e) {
            throw new TransientException(
                    "Unable to add event execution for " + eventExecution.getId(), 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