diff --git a/bubbles/execution/graph.py b/bubbles/execution/graph.py
index 7d194ff..d2bc15b 100644
--- a/bubbles/execution/graph.py
+++ b/bubbles/execution/graph.py
@@ -173,7 +173,7 @@ def __init__(self, nodes=None, connections=None):
 
         if connections:
             for connection in connections:
-                self.connect(*connectio)
+                self.connect(*connection)
 
     def _generate_node_name(self):
         """Generates unique name for a node"""
diff --git a/bubbles/ops/rows.py b/bubbles/ops/rows.py
index 3c84ebf..cbc185d 100644
--- a/bubbles/ops/rows.py
+++ b/bubbles/ops/rows.py
@@ -18,6 +18,7 @@
 from time import strptime
 from base64 import b64decode
 import json
+import re
 
 # FIXME: add cheaper version for already sorted data
 # FIXME: BasicAuditProbe was removed
@@ -676,7 +677,7 @@ def _(ctx, iterator, field, substitutions):
     """Substitute field using text substitutions"""
     # Compile patterns
     fields = iterator.fields
-    substitutions = [(re.compile(patt), r) for (patt, r) in subsitutions]
+    substitutions = [(re.compile(patt), r) for (patt, r) in substitutions]
     index = fields.index(field)
     for row in iterator:
         row = list(row)