

def test_provided_resources(self):
    pp = pipeline_provider.PipelineProvider()
    self.configuration_manager.set('pipelines.test_pipeline', ['passthrough'])
    pp.configure(self.runtime_environment)
    pipeline_provider_dependency = self.dependency_manager.add_dependency(processor, dict(provider='pipeline_provider'))
    pipeline_dependency = self.dependency_manager.add_dependency(self, dict(provider='pipeline.test_pipeline'))
    self.dependency_manager.resolve_initial_states()
    self.assertEquals(pipeline_provider_dependency.get_resource(), pp)
    processor = pipeline_dependency.get_resource()
    self.assertTrue(hasattr(processor, '__call__'))
    self.assertEquals(processor.__call__.im_func.func_name, 'process')
    self.assertIsInstance(processor, processing.TwistedProcessorGraphEvaluator)

dataset/ETHPy150Open foundit/Piped/piped/providers/test/test_pipeline_provider.py PipelineProviderTest.test_provided_resources/VarMisuse@48/74 `self`->`processor`