mirror of
https://github.com/wassname/catalyst.git
synced 2026-07-05 17:53:17 +08:00
MAINT: treat Pipeline API as a proper noun
This commit is contained in:
@@ -222,7 +222,7 @@ class BlazeToPipelineTestCase(TestCase):
|
||||
|
||||
def test_non_pipeline_field(self):
|
||||
# NOTE: This test will fail if we ever allow string types in
|
||||
# the pipeline api. If this happens, change the dtype of the `a` field
|
||||
# the Pipeline API. If this happens, change the dtype of the `a` field
|
||||
# of expr to another type we don't allow.
|
||||
expr = bz.Data(
|
||||
[],
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
"""Blaze integration with the pipeline API.
|
||||
"""Blaze integration with the Pipeline API.
|
||||
"""
|
||||
from __future__ import division, absolute_import
|
||||
|
||||
@@ -65,7 +65,7 @@ class ExprData(namedtuple('ExprData', 'expr deltas resources')):
|
||||
|
||||
Parameters
|
||||
----------
|
||||
epxr : Expr
|
||||
expr : Expr
|
||||
The first known values.
|
||||
deltas : Expr, optional
|
||||
The deltas for the data.
|
||||
@@ -117,17 +117,17 @@ class NonNumpyField(InvalidField):
|
||||
|
||||
class NonPipelineField(InvalidField):
|
||||
error_format = (
|
||||
"field '{field}' was a non pipeline API compatible type:"
|
||||
"field '{field}' was a non Pipeline API compatible type:"
|
||||
" '{type_.__name__}'"
|
||||
)
|
||||
|
||||
|
||||
class NotPipelineCompatible(TypeError):
|
||||
"""Exception used to indicate that a dshape is not pipeline api
|
||||
"""Exception used to indicate that a dshape is not Pipeline API
|
||||
compatible.
|
||||
"""
|
||||
def __str__(self):
|
||||
return "'%s' is a non pipleine API compatible type'" % self.args
|
||||
return "'%s' is a non Pipleine API compatible type'" % self.args
|
||||
|
||||
|
||||
_new_names = ('_%d' % n for n in count())
|
||||
@@ -293,7 +293,7 @@ def from_blaze(expr,
|
||||
loader=None,
|
||||
resources=None,
|
||||
no_deltas_rule=_valid_no_deltas_rules[0]):
|
||||
"""Create a pipeline api object from a blaze expression.
|
||||
"""Create a Pipeline API object from a blaze expression.
|
||||
|
||||
Parameters
|
||||
----------
|
||||
@@ -389,7 +389,7 @@ def from_blaze(expr,
|
||||
_check_resources('expr', expr, resources)
|
||||
_check_resources('deltas', deltas, resources)
|
||||
|
||||
# Create or retrieve the pipeline api dataset.
|
||||
# Create or retrieve the Pipeline API dataset.
|
||||
ds = new_dataset(expr, deltas)
|
||||
# Register our new dataset with the loader.
|
||||
(loader if loader is not None else global_loader)[ds] = ExprData(
|
||||
|
||||
Reference in New Issue
Block a user