@Override
    public PipelineDef parse(Path pipelineDefPath, Configuration globalPipelineConfig)
            throws Exception {
        return parse(mapper.readTree(pipelineDefPath.toFile()), globalPipelineConfig);
    }
@Test
    void testEvaluateDefaultRpcTimeOut() throws Exception {
        URL resource = Resources.getResource("definitions/pipeline-definition-minimized.yaml");
        YamlPipelineDefinitionParser parser = new YamlPipelineDefinitionParser();
        PipelineDef pipelineDef =
                parser.parse(
                        Paths.get(resource.toURI()),
                        Configuration.fromMap(
                                ImmutableMap.<String, String>builder()
                                        .put(
                                                PipelineOptions.PIPELINE_SCHEMA_OPERATOR_RPC_TIMEOUT
                                                        .key(),
                                                "1h")
                                        .build()));
        assertThat(
                        pipelineDef
                                .getConfig()
                                .get(PipelineOptions.PIPELINE_SCHEMA_OPERATOR_RPC_TIMEOUT))
                .isEqualTo(Duration.ofSeconds(60 * 60));
    }