def METHOD_NAME(self, mock_read_params,
                  mock_indicator_fn, mock_flash_fn,  mock_validator_fn, mock_archiver_fn, ):
    """Test that pipeline runs with validation and archiving."""
    mock_read_params.return_value = self.PARAMS
    run_indicator_pipeline(mock_indicator_fn,mock_flash_fn,  mock_validator_fn, mock_archiver_fn)
    mock_indicator_fn.assert_called_once_with(self.PARAMS)
    # mock_flash_fn.assert_called_once_with(self.PARAMS)
    mock_validator_fn.assert_called_once_with(self.PARAMS)
    mock_archiver_fn.assert_called_once_with(self.PARAMS)
    mock_validator_fn.return_value.validate.assert_called_once()
    mock_archiver_fn.return_value.run.assert_called_once()