diff --git a/tests/pipeline/test_blaze.py b/tests/pipeline/test_blaze.py
index b08f5b82..5a1d39c2 100644
--- a/tests/pipeline/test_blaze.py
+++ b/tests/pipeline/test_blaze.py
@@ -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(
             [],
diff --git a/zipline/pipeline/loaders/blaze.py b/zipline/pipeline/loaders/blaze.py
index 0f2ff8f9..e6196ca9 100644
--- a/zipline/pipeline/loaders/blaze.py
+++ b/zipline/pipeline/loaders/blaze.py
@@ -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(