Function insert_event_correlation 

pub async fn insert_event_correlation<'a, E>(
    executor: E,
    id: EventId,
    step_instance_id: StepInstanceId,
    run_id: RunId,
    correlation_key: &str,
    correlation_value: &str,
) -> Result<PgQueryResult, Error>
where
    E: Executor<'a, Database = Postgres>,

Insert event correlation.