@ExecuteOn(TaskExecutors.IO)
    @Get(uri = "/{executionId}/flow")
    @Operation(tags = {"Executions"}, summary = "Get flow information's for an execution")
    public FlowForExecution getFlowForExecutionById(
        @Parameter(description = "The execution that you want flow information's") String executionId
    ) {
        Execution execution = executionRepository.findById(tenantService.resolveTenant(), executionId).orElseThrow();

        return FlowForExecution.of(flowRepository.findByExecutionWithoutAcl(execution));
    }
@SuppressWarnings("DataFlowIssue")
    @Test
    void getFlowForExecutionById() {
        Execution execution = client.toBlocking().retrieve(
            HttpRequest
                .POST(
                    "/api/v1/executions/webhook/" + TESTS_FLOW_NS + "/webhook/" + TESTS_WEBHOOK_KEY + "?name=john&age=12&age=13",
                    ImmutableMap.of("a", 1, "b", true)
                ),
            Execution.class
        );

        FlowForExecution result = client.toBlocking().retrieve(
            GET("/api/v1/executions/" + execution.getId() + "/flow"),
            FlowForExecution.class
        );

        assertThat(result.getId(), is(execution.getFlowId()));
        assertThat(result.getTriggers(), hasSize(1));
        assertThat((result.getTriggers().getFirst() instanceof AbstractTriggerForExecution), is(true));
    }