@staticmethod
    def test_construct_etl_pipeline():
        result = ETLPipeline(
            'test_pipeline',
            frequency='one-time',
            ec2_resource_config={'terminate_after':'2 Hours'},
            time_delta=timedelta(seconds=3600),
            emr_cluster_config={'cfg1': 'value'},
            load_time='12:34',
            topic_arn='sns:topic-arn:test-case',
            max_retries=5,
            bootstrap={'cfg1': 'value'},
        )
        assert result.name.endswith('test_pipeline')
        eq_(result.frequency, 'one-time')
        eq_(result.ec2_resource_config, {'terminate_after':'2 Hours'})
        eq_(result.load_hour, 12)
        eq_(result.load_min, 34)
        eq_(result.time_delta, timedelta(seconds=3600))
        eq_(result.max_retries, 5)
        eq_(result.topic_arn, 'sns:topic-arn:test-case')
        eq_(result.bootstrap_definitions, {'cfg1': 'value'})
        eq_(result.emr_cluster_config, {'cfg1': 'value'})
Return a mapping of target -> set of individual test cases that failed.
dataset/ETHPy150Open coursera/dataduct/dataduct/etl/tests/test_etl_pipeline.py/EtlPipelineTests.test_construct_etl_pipeline--crossover with--dataset/ETHPy150Open pantsbuild/pants/src/python/pants/backend/jvm/tasks/junit_run.py/JUnitRun._get_failed_targets