@Override
    public void updateEventExecution(EventExecution eventExecution) {
        try {

            String key =
                    nsKey(
                            EVENT_EXECUTION,
                            eventExecution.getName(),
                            eventExecution.getEvent(),
                            eventExecution.getMessageId());
            String json = objectMapper.writeValueAsString(eventExecution);
            LOGGER.info("updating event execution {}", key);
            jedisProxy.hset(key, eventExecution.getId(), json);
            recordRedisDaoEventRequests("updateEventExecution", eventExecution.getEvent());
            recordRedisDaoPayloadSize(
                    "updateEventExecution", json.length(), eventExecution.getEvent(), "n/a");
        } catch (Exception e) {
            throw new TransientException(
                    "Unable to update 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