@ExecuteOn(TaskExecutors.IO)
    @Get(uri = "/flows/{namespace}/{flowId}")
    @Operation(tags = {"Executions"}, summary = "Get flow information's for an execution")
    public FlowForExecution getFlowForExecution(
        @Parameter(description = "The namespace of the flow") @PathVariable String namespace,
        @Parameter(description = "The flow id") @PathVariable String flowId,
        @Parameter(description = "The flow revision") @Nullable Integer revision
    ) {

        return FlowForExecution.of(flowRepository.findByIdWithoutAcl(tenantService.resolveTenant(), namespace, flowId, Optional.ofNullable(revision)).orElseThrow());
    }
@SuppressWarnings("DataFlowIssue")
    @Test
    void getFlowForExecution() {
        FlowForExecution result = client.toBlocking().retrieve(
            GET("/api/v1/executions/flows/io.kestra.tests/full"),
            FlowForExecution.class
        );

        assertThat(result, notNullValue());
        assertThat(result.getTasks(), hasSize(5));
        assertThat((result.getTasks().getFirst() instanceof TaskForExecution), is(true));
    }