def METHOD_NAME(self):
    def _pipeline():
        _local_loader = local_loader(self.temp_file_path)
        component_connect_demo(_local_loader.output)
    run_result = run_pipeline_func_locally(
        _pipeline, {}, execution_mode=LocalClient.ExecutionMode("local"))
    output_file_path = run_result.get_output_file("component-connect-demo")
    with open(output_file_path, "r") as f:
        line = f.readline()
        assert "copied" in line